Kafka の Docker デプロイメントと Spring Kafka 実装

この記事は主にDockerによるKafkaのデプロイとSpring Kafkaの実装について紹介します。この記事のサンプルコードは非常に詳細で、皆さんの勉強や仕事に一定の参考値があります。困っている友人は参考にしてください。

https://hub.docker.com/ から kafka を見つけます

3 番目はアクティブで、星の数が多くなっています。中に入って使い方を確認してください。

イメージの構築にはdocker-composeを使用します

ドキュメントのdocker-compose.ymlファイルを参照してください。

KafkaはZookeeperと一緒に使用されるため、このドキュメントにはZookeeperも含まれています。

バージョン番号と変数パラメータを変更しました

これら 2 つのパラメータは外部ネットワーク アクセスに公開されているようです (他のブログから見つかった答えは、Spring Kafka が設定されていない場合は接続できないということです)

2 つのコンテナを起動するには、コマンド docker-compose up -d を実行します。

Kafka コンテナに入り、公式ウェブサイトのガイドを使用してテストします http://kafka.apache.org/quickstart

docker exec -it {コンテナIDと名前} /bin/bash

コンテナに入ったら、コマンドディレクトリcd /opt/kafka/bin/を入力します。

ステップ1: 新しいトピックを作成する

kafka-topics.sh --create --bootstrap-server 192.168.17.165:9092 --replication-factor 1 --partitions 1 --topic mytest (localhost を自分の IP 番号に変更します)

ステップ 2: 情報を送信します: kafka-console-producer.sh --broker-list 192.168.17.165:9092 --topic mytest

ステップ 3: 情報を取得するために別のウィンドウを開きます: kafka-console-consumer.sh --bootstrap-server 192.168.17.165:9092 --topic mytest --from-beginning

ビルドが成功したことを意味します。

Spring Kafkaの構築を開始する

ドキュメント:

プロデューサー構成を設定します。

コンシューマー構成を構成する

関連する構成は、Spring の公式 Web サイトの kafka ドキュメントから取得されます: https://docs.spring.io/spring-kafka/docs/2.3.1.RELEASE/reference/html/

コントローラリクエストを作成した後に情報を送信する

リスナーを構成します。

@KafkaListener アノテーションを使用します。ドキュメントには関連する手順が記載されているので、一つ一つ説明することはしません。

プロジェクトを実行し、ログを表示するための URL を要求します。

設定は成功しました。

以上がこの記事の全内容です。皆様の勉強のお役に立てれば幸いです。また、123WORDPRESS.COM を応援していただければ幸いです。