0
私は使用しているkafkaスパウトに15人のエグゼキュータがあり、70人のエグゼキュータがないのでメッセージを失う可能性があるので、3つのレプリカと70のパーティションを持つカフカのトピックからメッセージを読んでいます。 ?コンシューマより多くのパーティションがあるとメッセージが消えますか?
kafkaのすべてのメッセージが消費者によって受信されたことを確認するにはどうすればよいですか?
は私は使用しているkafkaスパウトに15人のエグゼキュータがあり、70人のエグゼキュータがないのでメッセージを失う可能性があるので、3つのレプリカと70のパーティションを持つカフカのトピックからメッセージを読んでいます。 ?コンシューマより多くのパーティションがあるとメッセージが消えますか?
kafkaのすべてのメッセージが消費者によって受信されたことを確認するにはどうすればよいですか?
はカフカは、デフォルトですでにカフカにそれを作って知っているデータのために少なくとも一回配信保証を持っていただきありがとうございます。コンシューマ・グループのコンシューマ・インスタンスよりもコンシューマ・インスタンスが少ない場合、コンシューマ・グループには、パーティション割当て方式に従って複数のパーティションが割り当てられます。デフォルトでは、RangeAssignorが使用されます。 Kafka hereの配信セマンティクスについて詳しく読むことができます。