【原创】OGG21.3 CENTOS配置ORACLE 19C ADG至KAFKA

以下是一个示例配置Oracle GoldenGate 21.3以将Oracle 19c的Active Data Guard配置到Kafka的简化步骤：

1. 安装Oracle GoldenGate 21.3。
2. 配置Oracle GoldenGate数据库日志读取模式。
3. 配置Kafka连接。
4. 创建Oracle GoldenGate复制进程。

以下是相关配置的伪代码示例：

# 安装Oracle GoldenGate 21.3
# 安装Kafka驱动（例如：Confluent Kafka JAR）
 
# 配置Oracle日志读取模式
-- 在主库上配置日志读取模式
ALTER DATABASE ADD SUPPLEMENTAL LOG DATA;
ALTER DATABASE ADD SUPPLEMENTAL LOG DATA (PRIMARY KEY) COLUMNS;
ALTER DATABASE ADD SUPPLEMENTAL LOG DATA (UNIQUE INDEX) COLUMNS;
ALTER DATABASE ADD SUPPLEMENTAL LOG DATA (FOREIGN KEY) COLUMNS;
ALTER DATABASE ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS;
 
# 配置Kafka连接
-- 配置GoldenGate参数文件
GGSCI> EDIT PARAMS ./GLOBALS
-- 添加Kafka连接参数
KAFKA.BROKERLIST localhost:9092
KAFKA.ZOOKEEPER localhost:2181
 
# 创建Oracle GoldenGate复制进程
-- 在GoldenGate目录下创建GLOBALS文件
GGSCI> EDIT PARAMS ./GLOBALS
-- 添加Kafka为目标的GLOBALS设置
KAFKA.TOPIC OGG-KAFKA-TEST
 
-- 启动复制进程
GGSCI> ADD EXTRACT EXT_ORCL, EXTTRAILSOURCE ./dirdat/aa, EXTTRAIL ./dirrpt/aa
GGSCI> ADD RMTTRAIL ./dirrpt/aa, EXTTRAILSOURCE ./dirdat/aa
GGSCI> ADD DOMAIN DO_ORCL, TRANLOG, EXT_ORCL, MANAGED
GGSCI> ADD REPLICAT REP_KAFKA, EXTTRAILSOURCE ./dirrpt/aa, KAFKA, DOMAIN DO_ORCL
 
-- 配置复制进程参数
GGSCI> EDIT PARAMS REP_KAFKA
-- 在参数文件中指定Kafka连接参数
KAFKA.BROKERLIST localhost:9092
KAFKA.ZOOKEEPER localhost:2181
KAFKA.TOPIC OGG-KAFKA-TEST
 
-- 启动复制进程
GGSCI> START REP_KAFKA

请注意，这个示例假定您已经有了一个配置好的Oracle GoldenGate环境和Oracle 19c数据库，并且Kafka集群也已经配置好并且运行中。您需要根据自己环境的具体配置调整参数。