10.2. 分散モードでの Kafka Connect の使用

クラスターの実行

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

   • 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

     Copy to Clipboard Toggle word wrap

2. すべての Kafka Connect ノードで設定ファイル ./config/connect-distributed.properties を使用して Kafka Connect ワーカーを起動します。

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

   Copy to Clipboard Toggle word wrap

3. Kafka Connect が実行されていることを確認します。

   jcmd | grep ConnectDistributed

   Copy to Clipboard Toggle word wrap
4. Kafka Connect REST API を使用して コネクターを管理 します。