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 (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

Related Topics
Built-in Functions
Built-in Packages
Database Security
DBMS_KAFKA
DBMS_KAFKA_ADM
DBMS_KAFKA_INT
DBMS_KAFKA_UTL
What's New In 21c
What's New In 23c

Morgan's Library Page Footer
This site is maintained by Dan Morgan. Last Updated: This site is protected by copyright and trademark laws under U.S. and International law. © 1998-2023 Daniel A. Morgan All Rights Reserved
  DBSecWorx