8.2. 분산 모드에서 Kafka 연결 사용

클러스터 실행

1. 모든 Kafka Connect 작업자 노드에서 /opt/kafka/config/connect-distributed.properties Kafka Connect 구성 파일을 편집합니다.

   • Kafka 브로커를 가리키도록 bootstrap.server 옵션을 설정합니다.
   • group.id 옵션을 설정합니다.
   • config.storage.topic 옵션을 설정합니다.
   • offset.storage.topic 옵션을 설정합니다.

   • status.storage.topic 옵션을 설정합니다.

     예를 들면 다음과 같습니다.

     bootstrap.servers=kafka0.my-domain.com:9092,kafka1.my-domain.com:9092,kafka2.my-domain.com:9092
     group.id=my-group-id
     config.storage.topic=my-group-id-configs
     offset.storage.topic=my-group-id-offsets
     status.storage.topic=my-group-id-status

2. 모든 Kafka Connect 노드에서 /opt/kafka/config/connect-distributed.properties 구성 파일을 사용하여 Kafka Connect 작업자를 시작합니다.

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

3. Kafka Connect가 실행 중인지 확인합니다.

   jcmd | grep ConnectDistributed

4. Kafka Connect REST API를 사용하여 커넥터를 관리합니다.