bugfix> apache-kafka > 投稿

ステップ1: 1つのパーティションのみでトピックを作成します。

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

ステップ2: トピック test へのメッセージを生成する 。

ステップ3: トピック test で消費を開始する 。ステップ2でプッシュされるすべてのメッセージを取得できます。

1パーティションのトピックで正常に機能します。

しかし、2つのパーティションでトピックを使用しようとすると、コンシューマーは、コンシューマーが起動した後に生成されたメッセージのみを取得します。

再現:

ステップ1: 1つのパーティションのみでトピックを作成します。

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test2

ステップ2: トピック test2 へのメッセージを生成する 。

ステップ3: トピック test2 でコンシューマーを開始する 。手順2でメッセージを取得できません。

ステップ4: 消費者を維持し、トピック test2 へのメッセージを生成する 、その後、消費者はメッセージを取得できます。

それはうまく機能しますか?または私は何かが恋しいですか?