kafkaを設定して、最も早い、最新の、そして任意のオフセットから読み取るオプションがあるようにするには？

Question

カフカを設定して、最古のメッセージや最新のメッセージを読むことができます。 以前のオフセットから読み取る必要がある場合に備えて、追加オプションを含めるにはどうすればよいですか？ これを行う必要があるのは、先に処理ロジックが間違っているため、読み取られた以前のメッセージを再度処理する必要があるからです。

Answer 1

java kafkaクライアントでは、次の消費位置を指定するために使用できるカフカ消費者に関するいくつかの方法があります。

ます。public void 消費者は、次のポーリング（タイムアウト）に使用するオフセットをフェッチ（TopicPartitionパーティション、 が長いオフセット）

オーバーライドをを求めています。このAPIを同じパーティションに対して複数回呼び出すと、次のpoll（）で最新のオフセットが使用されます。このAPIが消費の途中で任意に使用され、フェッチオフセットをリセットする場合、データが失われる可能性があることに注意してください。

これで十分です。また、seekToBeginningとseekToEndもあります。

Answer 2

私は同様の回答ですが、全く同じ質問ではありませんので、私の情報があなたに役立つかどうかを見てみましょう。

まず、要するにI have been working from this other SO question/answer

は、あなたのオフセットをコミットしたいし、そのための最も一般的な解決策は、ZooKeeperのです。したがって、消費者がエラーに遭遇したり、シャットダウンする必要がある場合、消費者は中断したところから再開することができます。

私は非常に大容量の大量のストリームを扱っています。私の消費者（テスト用）は毎回末尾から開始する必要があります。私の出発点を宣言するためには、KafkaConsumer seekを使用しなければならないことが書類に示されています。

成功して信頼できるものになったら、ここで私の発見を更新しようとします。確かに、これは解決された問題です。