2017-05-29 11 views
0

私は使用しているkafkaスパウトに15人のエグゼキュータがあり、70人のエグゼキュータがないのでメッセージを失う可能性があるので、3つのレプリカと70のパーティションを持つカフカのトピックからメッセージを読んでいます。 ?コンシューマより多くのパーティションがあるとメッセージが消えますか?

kafkaのすべてのメッセージが消費者によって受信されたことを確認するにはどうすればよいですか?

答えて

2

カフカは、デフォルトですでにカフカにそれを作って知っているデータのために少なくとも一回配信保証を持っていただきありがとうございます。コンシューマ・グループのコンシューマ・インスタンスよりもコンシューマ・インスタンスが少ない場合、コンシューマ・グループには、パーティション割当て方式に従って複数のパーティションが割り当てられます。デフォルトでは、RangeAssignorが使用されます。 Kafka hereの配信セマンティクスについて詳しく読むことができます。

関連する問題