カフカのパーティション間でメッセージを表示するトピック

Question

4人の消費者を持つコンシューマーグループがあるので、私は4つのパーティションを持つカフカトピックを持っています。

私の目的は、メッセージがパーティション間で均等に分散されるようにすることです。

カフカトピックのパーティション間でメッセージの配信を確認する方法はありますか？

Answer 1

私はカフカの新しいプロデューサーを使用していると仮定しています。次に、各メッセージにキーを指定することはできません。つまり、カフカはすべてのパーティションにメッセージを均等に配布するためにラウンドロビン方式を採用しています。

あなたはすべてのパーティション間で分布を確認するには、以下のコマンドを呼び出すことができます：それは働いた@amethystic

bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list broker1:9092 --topic <topic> --time -1