2.3. MySQL コネクターのデプロイ
2.3.1. MySQL コネクターのインストール
Debezium MySQL コネクターのインストールは簡単なプロセスで、JAR のみをダウンロードし、Kafka Connect 環境に展開し、プラグインの親ディレクトリーが Kafka Connect 環境に指定されていることを確認してください。
前提条件
- Zookeeper、Kafka、および Kafka Connect がインストールされている。
- MySQL Server がインストールされ、設定されている。
手順
- Debezium MySQL コネクター をダウンロードします。
- ファイルを Kafka Connect 環境に抽出します。
-
プラグインの親ディレクトリーを Kafka Connect に追加し
plugin.path
ます。
plugin.path=/kafka/connect
注記
上記の例では、Debezium MySQL コネクターを /kafka/connect/debezium-connector-mysql
パスに抽出していることを前提としています。
- Kafka Connect プロセスを再起動します。これにより、新しい JAR が確実に検出されます。