Kafka Connector 설정 / 시작 (PostgreSQL Debezuim)

- Kafka Connector?

 

Kafka Connector는 Apache Kafka의 데이터 파이프라인을 구성하기 위한 구성 요소로, 외부 시스템(데이터베이스, 메시징 시스템, 파일 시스템 등)과 Kafka 클러스터 간의 데이터 전송을 자동화하는 역할을 합니다.

 

 

 

1. Connector 의 Log 및 설정 변경

 

- connector 설정 변경
vi /usr/local/kafka/config/connect-distributed.properties
# plugin.path=/usr/local/share/java,/usr/local/share/kafka/plugins,/opt/connectors,
plugin.path=/usr/local

- connector 로그 설정
vi /usr/local/kafka/config/connect-log4j.properties
log4j.rootLogger=INFO, stdout, connectAppender,file
log4j.appender.connectAppender.File=/usr/local/kafka/logs/connect.log

 

 

 

 

2. Connector 실행

$ bin/connect-distributed.sh config/connect-distributed.properties

 

 

 

 Connector가 실행되면 INFO 가 계속 뜨고, 

설정한 Log 에서도 동일하게 로그가 뜬다. 

 

 

만약 디비지움에서 성공적으로 커넥터에 연결 시 위처럼 연결 성공 로그가 뜨니 참고 !