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
```
Kafka Connect が実行されていることを確認します。
```
jcmd | grep ConnectDistributed
```

関連情報