私はC++ kafka実装を C++ rdkafkaから使用しています。 質問はRdKafka :: KafkaConsumerについてです。トピックの最初から開始するように消費者を設定するにはどうすればよいですか？C++ kafkaクライアント（rdkafka）
P.S. リンクでの消費者の例はRdKafkaに基づいています::によってマークされている消費者「のみレガシー、代わりにKafkaConsumerを使用する」「auto.offset.reset」はどのように動作するかではありません
おかげ先
を。 "auto.offset.reset"は有効なコミットされたオフセットがない場合にのみ有効です。流れが似ている：、見つから見つからない場合はオフセット
は、実際には全くオフセットをコミットする理由はありません。オフセットをコミットする目的は、再起動後にこのオフセットから再開したいので、あなたがどこにいたかを知ることです。
OK、ありがとう。クライアントの遅延結合を実装するベストプラクティスは何ですか？ （例えば、私は構成メッセージを生成し、それから多くの消費者が自分の時間とスケジューリングでそれを読むべきです）コミットを行わないと仮定すると、実際にはgroup.id = GUIDを持つ各コンシューマを作成すると同じ動作になりますそれはしませんでした。 –
私は正確に理解できません。あなたは何をしたいのですか？新しい質問があるように思えます。あなたはきれいに保つために、新しい質問を始めたいと思うかもしれません。 –
@ MatthiasJ.Saxまた、この現象が発生しています。私はauto.offset.reset = falseを使用しています。消費者がいなくても、新しいランダム生成group.idはまだ役に立ちませんでした。消費者は常に最新のメッセージを読む。 – user1116377
"conf-> set（" auto.offset.reset "、" smallest "、errstr）"または "conf-> set（" auto.offset.reset "、" earliest "、errstr）"を試しましたか？新しいカフカ版の場合） –
はい。しかし、それは役に立たなかった。私が消費者を再起動すると、最初からすべてのメッセージを読むことを期待しています（消費者アプリケーションがクラッシュする前に私がコミットしたメッセージを含む） –
問題を解決しましたか？もしそうなら、どのように？ –