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

戻る

Tutorials

MongoDB Change Streams を探索

要件