8.2.3. 分散 Kafka Connect の実行

クラスターの実行

1. すべての Kafka Connect ワーカーノードで /opt/kafka/config/connect-distributed.properties Kafka Connect 設定ファイルを編集します。

   • bootstrap.server オプションを設定して、Kafka ブローカーを指定します。
   • 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