Kafka：リモートブローカのトピックコンテンツを取得するためのkafka-connect-sinkコネクタの設定方法

Question

私はカフカ接続シンクコネクタを設定しようとしています。 Kafka connectはKafka connect broker（コンフルエント3.2.0）の一部です。私はKafkaブローカー（コンフルエント3.2.0）をマシンAで稼働させています。カフカコネクトシンクコネクタを使用してメッセージを消費するために、別のマシンBにKafkaコネクトシンクコネクタを設定します。マシンAのKafkaブローカーと動物園のキーパーポートがマシンBに開かれていると仮定します。

マシンBにコンフルエント-3.2.0をインストールする必要があります（Kafka ConnectはKafka Brokerパッケージのコンフルエント3.2です。 0）をクラスパスをKafka-connect-sinkコネクタjarに設定して、次のコマンドを実行しますか？

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

おかげ

Answer 1

はい。あなたが説明するものは動作し、マシンBではスタートスクリプト、設定プロパティファイル、Kafka Connect用のJAR、カスタムコネクタ用のJARだけが必要ですが、このシステムをセットアップする最も簡単な方法です。