この記事は機械翻訳のミラー記事です。元の記事にジャンプするにはこちらをクリックしてください。

Architect_Programmer_Code農業ネットワーク»建築家 › プログラミング › ジャワ › Spring BootはKafkaのトピックまたはGroupIDを動的に設定します
眺める： 21474|答える： 0

[出典] Spring BootはKafkaのトピックまたはGroupIDを動的に設定します

[リンクをコピー]
掲載地 2021/11/14 20:03:45 | | | |
クラスタ内でマイクロサービスを展開する際、すべてのアプリケーションにコマンドを発行したい場合、アプリケーションをKafkaトピックにサブスクライブできますが、同じトピックをすべてのアプリケーションで受信するには異なるグループIDを設定する必要があることに注意してください。

Dockerを使って以下のコマンドでKafkaアプリケーションを作成できます:

注意:192.168.1.166を実際のIPアドレスに置き換えてください

pom.xml spring-kafkaパッケージを以下のように紹介します:


Kafkaの消費者構成をカスタマイズするには、新しいKafkaSummerファイルを作成します。


新しいコンシューマーConfigConsumerを作成し、デフォルトの設定はtopic:defaultTopic、groupid:defaultGroupIdで、コードは以下の通りです。

application.propertiesを使ってKafkaのアドレスを設定する:


プロジェクトを開始するには、アプリのサブスクリプションがデフォルトの設定で、以下のように適用されます。



KafkaMessageListenerContainerはAbstractMessageListenerContainerの抽象クラスを継承し、createSimpleLoggingConsumerRebalanceListenerメソッドはそのコンシューマーのgroupidとトピック、partitionを出力します。

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: partitions assigned: [defaultTopic-0]
トピックとグループIDを動的に設定すると、プロジェクト開始コマンドは以下の通りです:



トピックはa1に設定され、グループIDは itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: partitions assigned: [a1-0]
Springはjarパッケージ内のデフォルト設定を上書きします
https://www.itsvse.com/thread-10129-1-1.html

(終わり)





先の：MySQLパフォーマンス最適化のためのスロークエリ
次に：Spring Boot Kafkaが再起動して古いデータを破棄します

関連記事
免責事項：
Code Farmer Networkが発行するすべてのソフトウェア、プログラミング資料、記事は学習および研究目的のみを目的としています。 上記の内容は商業的または違法な目的で使用されてはならず、そうでなければ利用者はすべての結果を負うことになります。 このサイトの情報はインターネットからのものであり、著作権紛争はこのサイトとは関係ありません。 ダウンロード後24時間以内に上記の内容を完全にパソコンから削除してください。 もしこのプログラムを気に入ったら、正規のソフトウェアを支持し、登録を購入し、より良い本物のサービスを受けてください。 もし侵害があれば、メールでご連絡ください。
Mail To:help@itsvse.com