Oracle | DBMS_KAFKA

Oracle DBMS_KAFKA_INT Version 26ai

General Information

Library Note

Morgan's Library Page Header

The best Oracle News for FY2026

Oracle Database 26ai is now availble. If you haven't you downloaded already: Why?

Purpose Kafka Cluster Internal Utilities.

AUTHID DEFINER

Dependencies

ALL_DIRECTORIES	DBMS_PDB_LIB
DBA_ROLE_PRIVS	DBMS_STANDARD
DBMS_ASSERT	DBMS_SYS_ERROR
DBMS_KAFKA_ADM	JSON_ELEMENT_T
DBMS_KAFKA_CLUSTERS	JSON_KEY_LIST
DBMS_KAFKA_CLUSTER_SEQ	JSON_OBJECT_T
DBMS_KAFKA_INT_LIB	ODCIRIDLIST
DBMS_KAFKA_MESSAGES	PLITBLM
DBMS_KAFKA_OPS_RESULTS	USER_TAB_PRIVS
DBMS_KAFKA_PARTITIONS	UTL_FILE
DBMS_KAFKA_SEC_ALLOWED_PROPERTIES	V$INSTANCE
DBMS_LOB

Documented No

First Available 23ai

Security Model Owned by SYS with EXECUTE granted to the OSAK_ADMIN_ROLE role

Source {ORACLE_HOME}/rdbms/admin/prvtkafkaints.plb
{ORACLE_HOME}/rdbms/admin/prvtkafkaintb.plb

Subprograms

CONNECT_TO_KAFKA	INSERT_MESSAGE_INFO
DELETE_CLUSTER_INFO	UPDATE_CLUSTER_BOOTSTRAP_INFO
DELETE_MESSAGE_INFO	UPDATE_CLUSTER_CONNECTION_TS_INFO
DISCONNECT_FROM_KAFKA	UPDATE_CLUSTER_OPTIONS_INFO
FILE_EXISTS	UPDATE_CLUSTER_STATE_INFO
GET_OSAKAFKA_FILE_PROPS	UPSERT_OPS_RESULTS_INFO
INSERT_CLUSTER_INFO

CONNECT_TO_KAFKA (new 23ai)

Connect to an existing Kafka Cluster dbms_kafka_int.connect_to_kafka( cluster_id IN VARCHAR2, state OUT NUMBER, connection_ts OUT TIMESTAMP, prev_connection_ts IN TIMESTAMP)l

TBD

DELETE_CLUSTER_INFO (new 23ai)

Delete Kafka Cluster metadata dbms_kafka_int.delete_cluster_info(p_cluster_id IN VARCHAR2);

TBD

DELETE_MESSAGE_INFO (new 23ai)

Undocumented dbms_kafka_int.delete_message_info(p_cluster_id IN VARCHAR2);

TBD

DISCONNECT_FROM_KAFKA (new 23ai)

Disconnect from a Kafka Cluster dbms_kafka_int.disconnect_from_kafka(cluster_id IN VARCHAR2);

TBD

FILE_EXISTS (new 23ai)

Undocumented dbms_kafka_int.file_exists( p_dir_name IN VARCHAR2, p_file_name IN VARCHAR2) RETURN BOOLEAN;

SELECT dbms_kafka_int.file_exists('EXPORTDIR', 
      'testfile.txt');

GET_OSAKAFKA_FILE_PROPS (new 23ai)

Undocumented dbms_kafka_int.get_osakafka_file_props(cluster_id IN VARCHAR2);

TBD

INSERT_CLUSTER_INFO (new 23ai)

Undocumented dbms_kafka_int.insert_cluster_info( p_cluster_name IN VARCHAR2, p_bootstrap_servers IN VARCHAR2, p_cluster_access_dir IN VARCHAR2, p_kafka_provider IN VARCHAR2, p_credential_name IN VARCHAR2, p_credential_schema IN VARCHAR2, p_cluster_config_dir IN VARCHAR2, p_options IN sys.json_object_t, p_cluser_id OUT VARCHAR2);

TBD

INSERT_MESSAGE_INFO (new 23ai)

Undocumented

Overload 1 dbms_kafka_int.insert_message_info( p_cluster_id IN VARCHAR2, p_message_type IN VARCHAR2, p_message IN VARCHAR2);

TBD

Undocumented

Overload 2 dbms_kafka_int.insert_message_info( p_cluster_id IN VARCHAR2, p_application_name IN VARCHAR2, p_topic_name IN VARCHAR2, p_partition_id IN NUMBER, p_message_type IN VARCHAR2, p_message IN VARCHAR2);

TBD

UPDATE_CLUSTER_BOOTSTRAP_INFO (new 23ai)

Undocumented dbms_kafka_int.update_cluster_bootstrap_info( p_cluster_id IN VARCHAR2, p_boostrap_servers IN VARCHAR2);

TBD

UPDATE_CLUSTER_CONNECTION_TS_INFO (new 23ai)

Undocumented dbms_kafka_int.update_cluster_connection_ts_info( p_cluster_id IN VARCHAR2, p_connection_ts IN TIMESTAMP);

TBD

UPDATE_CLUSTER_OPTIONS_INFO (new 23ai)

Undocumented dbms_kafka_int.update_clsuter_options_info( p_cluster_id IN VARCHAR2, p_options IN VARCHAR2);

TBD

UPDATE_CLUSTER_STATE_INFO (new 23ai)

Undocumented

Overload 1 dbms_kafka_int.update_cluster_state_info( p_cluser_id IN VARCHAR2, p_state IN NUMBER);

TBD

Overload 2 dbms_kafka_int.update_cluster_state_info( p_cluser_id IN VARCHAR2, p_state IN NUMBER, p_connection_ts IN TIMESTAMP);

TBD

UPSERT_OPS_RESULTS_INFO (new 23ai)

Undocumented dbms_kafka_int.upsert_ops_results_info( p_op_key IN VARCHAR2, p_rows_read IN NUMBER, p_last_offset IN NUMBER);

TBD