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 is now availble. If you haven't you downloaded already: Why?

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