9.2.3. 分散 Kafka Connect の実行

この手順では、Kafka Connect を分散モードで設定および実行する方法を説明します。

前提条件

クラスターの実行

すべての 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
```
すべての Kafka Connect ワーカーノードで /opt/kafka/config/connect-distributed.properties Kafka Connect ワーカーを起動します。
```
su - kafka
/opt/kafka/bin/connect-distributed.sh /opt/kafka/config/connect-distributed.properties
```
KafkaConnect が実行されていることを確認します。
```
jcmd | grep ConnectDistributed
```

関連情報