Oracle DBMS_KAFKA_ADM
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
Constants
Name Data Type Value
 Cluster Definition States
STATE_CONNECTED INTEGER 0
STATE_MAINTENANCE INTEGER 1
STATE_BROKEN INTEGER 2
STATE_DEREGISTERED INTEGER 3
 Kafka Connection Modes
CONNECTION_MODE_HI_THRU VARCHAR2(15) 'high_throughput'
CONNECTION_MODE_LO_LAT VARCHAR2(11) 'low_latency'
 Kafka providers
KAFKA_PROVIDER_APACHE VARCHAR2(6) 'APACHE'
KAFKA_PROVIDER_OSS VARCHAR2(3) 'OSS'
     
 Options
OPT_CONNECTION_MODE VARCHAR2(30) 'connmode'
Data Types TYPE PROPERTIES_TYPE IS TABLE OF VARCHAR2(1000)
INDEX BY VARCHAR2(1000);
Dependencies
DBMS_ASSERT DBMS_LOB JSON_ELEMENT_T
DBMS_KAFKA_APPLICATIONS DBMS_STANDARD JSON_KEY_LIST
DBMS_KAFKA_CLUSTERS DBMS_SYS_ERROR JSON_OBJECT_T
DBMS_KAFKA_INT DUAL PLITBLM
DBMS_KAFKA_UTL    
Documented No
First Available 23.1 Beta
Pragmas PRAGMA SUPPLEMENTAL_LOG_DATA(default, NONE);
Security Model Owned by SYS with EXECUTE grnated to the OSAK_ADMIN_ROLE role
Owned by SYS with EXECUTE granted to PUBLIC?
Source {ORACLE_HOME}/rdbms/admin/dbmskafkaadm.sql
{ORACLE_HOME}/rdbms/admin/prvtkafkaadm.plb
Subprograms
 
CHECK_CLUSTER (new 23c)
Test Kafka cluster connectivity

Returns the cluster state or an exception
dbms_kafka_adm.check_cluster(cluster_name IN VARCHAR2) RETURN INTEGER;
TBD
 
DEREGISTER_CLUSTER (new 23c)
Deregister a Kafka cluster dbms_kafka_adm.deregister_cluster(
cluster_name IN VARCHAR2,
forced       IN BOOLEAN DEFAULT FALSE);
TBD
 
DISABLE_CLUSTER (new 23c)
Disable a Kafka cluster dbms_kafka_adm.disable_cluster(cluster_name IN VARCHAR2);
TBD
 
ENABLE_CLUSTER (new 23c)
Enable a Kafka cluster dbms_kafka_adm.enable_cluster(cluster_name IN VARCHAR2);
TBD
 
REGISTER_CLUSTER (new 23c)
Register a Kafka cluster dbms_kafka_adm.register_cluster(
cluster_name        IN VARCHAR2,
bootstrap_servers   IN VARCHAR2,
kafka_provider      IN VARCHAR2,
cluster_access_dir  IN VARCHAR2,
credential_name     IN VARCHAR2 DEFAULT NULL,
cluster_config_dir  IN VARCHAR2 DEFAULT NULL,
cluster_description IN VARCHAR2 DEFAULT NULL,
options             IN CLOB     DEFAULT NULL)
RETURN INTEGER;
TBD
 
UPDATE_CLUSTER_INFO (new 23c)
Update the bootstrap server and/or the options for the Kafka cluster dbms_kafka_adm.update_cluster_info(
cluster_name      IN VARCHAR2,
bootstrap_servers IN VARCHAR2 DEFAULT NULL,
options           IN CLOB     DEFAULT NULL);
TBD

Related Topics
Built-in Functions
Built-in Packages
Database Security
DBMS_KAFKA
DBMS_KAFKA_INT
DBMS_KAFKA_MD
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