Kafka Connectorチュートリアルの設定
このセクションのチュートリアルは、MongoDB Connector for Apache Kafka の実行に必要な依存関係と構成をパッケージ化するために Docker を使用して開発環境で実行されます。 チュートリアルに進む前に、開発環境のセットアップ手順が完了していることを確認してください。
要件
このチュートリアルに必要な Docker コンテナをダウンロードするには、Docker アカウントを作成またはサインインします。 アカウントをサインアップして Docker Desktop をインストールする方法については、 Docker Hub クイック スタートのサインアップとダウンロードの手順をお読みください。
ターミナルアプリと shell。 MacOS ユーザーの場合は、ターミナルまたは同様のアプリを使用します。 Windows ユーザーの場合は、 PowerShell を使用します。
任意。 設定ファイルをダウンロードするにはGitをインストールします。 Git をインストールする方法については、 Git ダウンロード を参照してください。 ページ。
Docker で開発環境を設定する
チュートリアルリポジトリのクローンまたはダウンロード
次に、次のコマンドを使用してチュートリアル Git リポジトリをクローンします。
git clone https://github.com/mongodb-university/kafka-edu.git
Git がインストールされていない場合は、 zip アーカイブ をダウンロードできます ください。
開発環境を実行する
このガイドのコマンドを実行する方法については、OS に一致するタブを選択してください。
Bash shell を使用して、リポジトリまたは解凍されたアーカイブ内のチュートリアル ディレクトリ「mongodb-kafka-base」に移動します。 Git を使用してリポジトリをクローンした場合、コマンドは次のようになります。
cd kafka-edu/docs-examples/mongodb-kafka-base/
PowerShell を使用して、リポジトリまたは解凍されたアーカイブ内のチュートリアル ディレクトリ「mongodb-kafka-base」に移動します。 Git を使用してリポジトリをクローンした場合、コマンドは次のようになります。
cd kafka-edu\docs-examples\mongodb-kafka-base\
次のコマンドを使用して Docker イメージを起動します。
docker-compose -p mongo-kafka up -d --force-recreate
注意
ポート マッピング
サンドボックスは、次のサービスをホスト マシンのポートにマッピングします。
サンドボックス MongoDB サーバーはホストマシンのポート
35001
にマッピングされますサンドボックス Kafka Connect JTX サーバーはホストマシンのポート
35000
にマッピングされます
サンドボックスを起動するには、これらのポートが無料である必要があります。
「mongo-kafka-base」イメージでは、次の図に示すように、チュートリアルで必要なすべてのサービスを含む Docker コンテナが作成され、「mongodb-kafka-base_localnet」と呼ばれる共有ネットワーク上で実行されます。
コマンドが正常に完了すると、次のテキストが出力されます。
... Creating zookeeper ... done Creating broker ... done Creating schema-registry ... done Creating connect ... done Creating rest-proxy ... done Creating mongo1 ... done Creating mongo1-setup ... done
設定が成功したことを確認する
次のコマンドを実行して、開発環境が正常に起動したことを確認します。
docker exec mongo1 status
Docker 開発環境が正常に設定されている場合は、このコマンドによって次の情報が出力されます。
Kafka topics: "topic": "docker-connect-status", "topic": "docker-connect-offsets", "topic": "docker-connect-configs", "topic": "__consumer_offsets", The status of the connectors: Currently configured connectors [] Version of MongoDB Connector for Apache Kafka installed: {"class":"com.mongodb.kafka.connect.MongoSinkConnector","type":"sink","version":"1.8.0"} {"class":"com.mongodb.kafka.connect.MongoSourceConnector","type":"source","version":"1.8.0"}
connector を起動していないため、ステータスと構成済みリストは空です。
開発環境のセットアップが完了し、チュートリアルの次のステップに進むことができます。
Tip
開発環境 MongoDB への接続
MongoDB次の 接続 を使用して、開発環境で実行されているstring クラスターに接続できます。
mongodb://localhost:35001/?directConnection=true