Oracle | DBMS_KAFKA

Oracle DBMS_KAFKA_MD 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 TBD

AUTHID DEFINER

Dependencies

DBA_PROFILES	DBMS_KAFKA_LOAD_METRICS	DBMS_KAFKA_PARTITIONS
DBA_USERS	DBMS_KAFKA_LOCATION_SEQ	DBMS_KAFKA_UTL
DBMS_KAFKA	DBMS_KAFKA_MESSAGES	DBMS_STANDARD
DBMS_KAFKA_APPLICATIONS	DBMS_KAFKA_OPS	V$PARAMETER
DBMS_KAFKA_CLUSTERS	DBMS_KAFKA_OPS_RESULTS

Documented No

First Available 23ai

Security Model Owned by SYS with no privileges granted

Direct access to this package is prevented by an Accessible By clause.

Source {ORACLE_HOME}/rdbms/admin/prvtkafkamds.plb
{ORACLE_HOME}/rdbms/admin/prvtkafkamdb.plb

Subprograms

DELETE_APPLICATION_INFO	INSERT_APPLICATION_INFO	MAX_VARCHAR2_SIZE
DELETE_LOAD_METRICS_INFO	INSERT_LOAD_METRICS_INFO	UPDATE_APPLICATION_INFO
DELETE_MESSAGE_INFO	INSERT_MESSAGE_INFO	UPDATE_OPS_INIT_INFO
DELETE_OPS_DATA_INFO	INSERT_OPS_DATA_INFO	UPDATE_OPS_INIT_TS_INFO
DELETE_OPS_PARTITION_INFO	INSERT_OPS_PARTITION_INFO	UPDATE_OPS_RAND_TS_INFO
DELETE_PARTITION_INFO	INSERT_PARTITION_INFO	UPDATE_OPS_SEQ_INFO
GET_SESSIONS_PER_USER	MAX_RAW_SIZE

DELETE_APPLICATION_INFO (new 23ai)

Undocumented dbms_kafka_md.delete_application_info( p_cluster_id IN VARCHAR2, p_application_name IN VARCHAR2);

TBD

DELETE_LOAD_METRICS_INFO (new 23ai)

Undocumented dbms_kafka_md.delete_load_metrics_info( p_cluster_id IN VARCHAR2, p_application_name IN VARCHAR2);

TBD

DELETE_MESSAGE_INFO (new 23ai)

Undocumented dbms_kafka_md.delete_message_info( p_cluster_id IN VARCHAR2, p_application_name IN VARCHAR2);

TBD

DELETE_OPS_DATA_INFO (new 23ai)

Undocumented dbms_kafka_md.delete_ops_data_info( p_cluster_id IN VARCHAR2, p_application_name IN VARCHAR2, p_partition_id IN NUMBER);

TBD

DELETE_OPS_PARTITION_INFO (new 23ai)

Undocumented

Protected by Accessible By Clause dbms_kafka_md.delete_ops_partition_info;

exec dbms_kafka_md.delete_ops_partition_info;

           *

      PLS-00904: insufficient privilege to access object DBMS_KAFKA_MD

DELETE_PARTITION_INFO (new 23ai)

Undocumented dbms_kafka_md.delete_partition_info( p_cluster_id IN VARCHAR2, p_application_name IN VARCHAR2, p_partition_id IN NUMBER);

TBD

GET_SESSIONS_PER_USER (new 23ai)

Undocumented

Protected by Accessible By Clause dbms_kafka_md.get_sessions_per_user(user_name IN VARCHAR2) RETURN NUMBER;

SELECT dbms_kafka_md.get_sessions_per_user(USER);

             *

      ORA-06553: PLS-904: insufficient privilege to access object DBMS_KAFKA_MD

INSERT_APPLICATION_INFO (new 23ai)

Undocumented dbms_kafka_md.insert_application_info( p_cluster_id IN VARCHAR2, p_application_name IN VARCHAR2, p_topic_name IN VARCHAR2, p_num_views IN NUMBER, p_num_partitions IN NUMBER, p_num_views_requested IN NUMBER, p_application_type IN VARCHAR2, p_ext_table_name IN VARCHAR2, p_part_table_name IN VARCHAR2, p_part_view_name IN VARCHAR2, p_options IN BLOB, p_avro_schema IN BLOB, p_key_avro_schema IN BLOB);

TBD

INSERT_LOAD_METRICS_INFO (new 23ai)

Undocumented dbms_kafka_md.insert_load_metrics_info( p_cluster_id IN VARCHAR2, p_application_name IN VARCHAR2, p_target_table IN VARCHAR2, p_target_table_schema IN VARCHAR2, p_inserted_rows IN NUMBER, p_kafka_records IN NUMBER, p_started_time IN TIMESTAMP WITH TIME ZONE, p_finished_time IN TIMESTAMP WITH TIME ZONE);

TBD

INSERT_MESSAGE_INFO (new 23ai)

Undocumented dbms_kafka_md.insert_message_info( p_cluster_id IN VARCHAR2, p_application_name IN VARCHAR2, p_view_name IN VARCHAR2, p_message_type IN VARCHAR2, p_message IN VARCHAR2);

TBD

INSERT_OPS_DATA_INFO (new 23ai)

Undocumented dbms_kafka_md.insert_ops_data_info( p_cluster_id IN VARCHAR2, p_application_name IN VARCHAR2, p_topic_name IN VARCHAR2, p_partition_id IN NUMBER, p_op_key OUT VARCHAR2);

TBD

INSERT_OPS_PARTITION_INFO (new 23ai)

Undocumented dbms_kafka_md.insert_ops_partition_info;

exec dbms_kafka_md.insert_ops_partition_info;

      *

      PLS-00904: insufficient privilege to access object DBMS_KAFKA_MD

INSERT_PARTITION_INFO (new 23ai)

Undocumented dbms_kafka_md.insert_partition_info( p_cluster_id IN VARCHAR2, p_application_name IN VARCHAR2, p_topic_name IN VARCHAR2, p_partition_id IN NUMBER, p_view_id IN NUMBER, p_view_name IN VARCHAR2, p_temp_table_name IN VARCHAR2);

TBD

MAX_RAW_SIZE (new 23ai)

Undocumented dbms_kafka_md.max_raw_size RETURN NUMBER;

SELECT dbms_kafka_md.max_raw_size;


      *

      PLS-00904: insufficient privilege to access object DBMS_KAFKA_MD

MAX_VARCHAR2_SIZE (new 23ai)

Undocumented dbms_kafka_md.max_varchar2_size RETURN NUMBER;

SELECT dbms_kafka_md.max_varchar2_size;

*

      PLS-00904: insufficient privilege to access object DBMS_KAFKA_MD

UPDATE_APPLICATION_INFO (new 23ai)

Undocumented dbms_kafka_md.update_application_info( p_cluster_id IN VARCHAR2, p_application_name IN VARCHAR2, p_num_views IN NUMBER, p_num_partitions IN NUMBER);

TBD

UPDATE_OPS_INIT_INFO (new 23ai)

Undocumented dbms_kafka_md.update_ops_init_info( p_view_name IN VARCHAR2, p_record_count IN NUMBER, p_water_mark IN VARCHAR2);

TBD

UPDATE_OPS_INIT_TS_INFO (new 23ai)

Undocumented dbms_kafka_md.update_ops_init_ts_info( p_view_name IN VARCHAR2, p_start_ts_millis IN NUMBER);

TBD

UPDATE_OPS_RAND_TS_INFO (new 23ai)

Undocumented dbms_kafka_md.update_ops_rand_ts_info( p_view_name IN VARCHAR2, p_start_timestamp_ms IN NUMBER, p_end_timestamp_ms IN NUMBER);

TBD

UPDATE_OPS_SEQ_INFO (new 23ai)

Undocumented dbms_kafka_md.update_ops_seq_info(p_view_name IN VARCHAR2);

TBD