kafka Debezium 오라클11g 소스커넥터 추가

기존 설치 과정 참조 : Kafka로 CDC구현하기(1/3) - Kafka Source Connector 생성하기 (tistory.com)

 

오라클 11g 소스커넥터 추가하여 테스트  진행함

 

1. 도커접속

 docker exec -it kafka /bin/bash

 

2. 도커 timezone 변경 ( 오라클은 도커와 타임존이 동일해야함. 다르면 timezone 에러 발생

참고 : [Docker] Container timezone 변경(setting) — R=VD (tistory.com)

 

 

3. 오라클 커넥터 추가 ( /opt/kafka_2.13-2.8.1/connectors )

 

wget  https://repo1.maven.org/maven2/io/debezium/debezium-connector-oracle/2.7.0.Final/debezium-connector-oracle-2.7.0.Final-plugin.tar.gz

tar -zxvf debezium-connector-oracle-2.7.0.Final-plugin.tar.gz

 

4. JDBC 드라이버 ojdbc6.jar 추가 ( /opt/kafka_2.13-2.8.1/connectors )

      ( 로컬-> 컨테이너 파일 전송)

       docker cp ~/data/ojdbc6-11.2.0.4.jar 181b474a66b3:/opt/kafka_2.13-2.8.1/connectors

 

5. 분산모드 중지 후 재실행

 

       connect-distributed.sh /opt/kafka/config/connect-distributed.properties

 

* 오라클커넥터 

curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" localhost:8083/connectors -d '{ "name": "ora-cdc_test-source-connector",

"config": {

    "connector.class": "io.debezium.connector.oracle.OracleConnector",

    "database.hostname": "0.0.0.0",

    "database.port": "1521",

    "database.user": "userid",

    "database.password": "pw",

    "database.dbname": "DBNAME",

    "database.names":" DBNAME ",

    "database.server.name": " 0.0.0.0 ",

    "table.include.list": "xtmp_cdc_test",

    "topic.prefix": "ora-cdc_test",

"time.precision.mode": "connect",

"tasks.max": "1",

"database.oracle.version": "11",

    "snapshot.max.threads": "4",

   

    "schema.history.internal.store.only.captured.tables.ddl": "true",

    "database.history.kafka.bootstrap.servers": "kafka:9092",

    "database.history.kafka.topic": "ora-cdc_test_db_hst",

    "schema.history.internal.kafka.bootstrap.servers": "kafka:9092", 

    "schema.history.internal.kafka.topic": "ora-cdc_test-schm_hst"  }

}';