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 will be available on generic Linux platforms in January and soon on AIX and Windows

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