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
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
23.1 Beta
Security Model
Owned by SYS with EXECUTE granted to the OSAK_ADMIN_ROLE role
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);
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);