Zookeeper と 3 つの kafka ブローカーをローカルで実行しました。1 つのプロデューサーと 1 つのコンシューマーを開始しました。コンシューマーがメッセージを消費していることがわかります。
次に、同じコンシューマー グループ名で 3 つのコンシューマーを開始しました (Spring Boot プロジェクトなのでポートが異なります)。しかし、私が見つけたのは、すべてのコンシューマーが現在メッセージを消費 (受信) していることです。ただし、メッセージのみがコンシューマー間で繰り返されないという点で、メッセージの負荷が分散されることを期待しています。何が問題なのかわからない。
ここに私のプロパティファイルがあります
spring.cloud.stream.bindings.input.destination=timerTopicLocal
spring.cloud.stream.kafka.binder.zkNodes=localhost
spring.cloud.stream.kafka.binder.brokers=localhost
spring.cloud.stream.bindings.input.group=timerGroup
ここでのグループは timerGroup です。
消費者コード: https://github.com/codecentric/edmp-sample-stream-sink
プロデューサーコード: https://github.com/codecentric/edmp-sample-stream-source