Docs Menu
Docs Home
/
MongoDB Kafka Connector
/

Kafka Connectorチュートリアルの設定

このセクションのチュートリアルは、MongoDB Connector for Apache Kafka の実行に必要な依存関係と構成をパッケージ化するために Docker を使用して開発環境で実行されます。 チュートリアルに進む前に、開発環境のセットアップ手順が完了していることを確認してください。

  • このチュートリアルに必要な Docker コンテナをダウンロードするには、Docker アカウントを作成またはサインインします。 アカウントをサインアップして Docker Desktop をインストールする方法については、 Docker Hub クイック スタートのサインアップとダウンロードの手順をお読みください。

  • ターミナルアプリと shell。 MacOS ユーザーの場合は、ターミナルまたは同様のアプリを使用します。 Windows ユーザーの場合は、 PowerShell を使用します。

  • 任意。 設定ファイルをダウンロードするにはGitをインストールします。 Git をインストールする方法については、 Git ダウンロード を参照してください。 ページ。

1

次に、次のコマンドを使用してチュートリアル Git リポジトリをクローンします。

git clone https://github.com/mongodb-university/kafka-edu.git

Git がインストールされていない場合は、 zip アーカイブ をダウンロードできます ください。

2

このガイドのコマンドを実行する方法については、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」と呼ばれる共有ネットワーク上で実行されます。

Docker が mongo-kafka ベースのコンテナを構成する図

コマンドが正常に完了すると、次のテキストが出力されます。

...
Creating zookeeper ... done
Creating broker ... done
Creating schema-registry ... done
Creating connect ... done
Creating rest-proxy ... done
Creating mongo1 ... done
Creating mongo1-setup ... done
3

次のコマンドを実行して、開発環境が正常に起動したことを確認します。

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