Oracle | DBMS_KAFKA

Oracle DBMS_KAFKA_MD Version 23c

General Information

Library Note

Morgan's Library Page Header

ACE Director Alum Daniel Morgan, founder of Morgan's Library, is scheduling complimentary technical Workshops on Database Security for the first 30 Oracle Database customers located anywhere in North America, EMEA, LATAM, or APAC that send an email to asra_us@oracle.com. Request a Workshop for your organization today.

Purpose TBD

AUTHID DEFINER

Dependencies

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

Documented No

First Available 23.1 Beta

Security Model Owned by SYS with no privileges granted

This package is protected from misuse by an Accessible By clause

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

Subprograms

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

DELETE_APPLICATION_INFO (new 23c)

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

TBD

DELETE_LOAD_METRICS_INFO (new 23c)

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

TBD

DELETE_MESSAGE_INFO (new 23c)

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

TBD

DELETE_OPS_DATA_INFO (new 23c)

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 23c)

Undocumented

Protected by Accessible By Clause dbms_kafka_md.delete_ops_partition_info;

exec dbms_kafka_md.delete_ops_partition_info;

      BEGIN dbms_kafka_md.delete_ops_partition_info; END;

            *

      ERROR at line 1:

      ORA-06550L line 1, column 7:

      PLS-00904: insufficient privilege to access object DBMS_KAFKA_MD

      ORA-06550: line 1, column 7:

      PL/SQL Statement ignored

DELETE_PARTITION_INFO (new 23c)

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 23c)

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);

      SELECT dbms_kafka_md.get_sessions_per_user(USER)

             * 

      ERROR at line 1:

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

INSERT_APPLICATION_INFO (new 23c)

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 23c)

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 23c)

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 23c)

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 23c)

Undocumented dbms_kafka_md.insert_ops_partition_info;

exec dbms_kafka_md.insert_ops_partition_info;

INSERT_PARTITION_INFO (new 23c)

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

UPDATE_APPLICATION_INFO (new 23c)

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 23c)

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 23c)

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 23c)

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 23c)

Undocumented dbms_kafka_md.update_ops_seq_info(p_view_name IN VARCHAR2);

TBD