0

私はまだカフカクライアントのオフセットを保持していますが、カフカサーバーは時間差でデータを削除していました。

そのため、データ用にカフカサーバーを呼び出しても何も取得できません。

今回はどうすればkafkaサーバーのオフセットを取得できますか?

今からデータを取得したいだけです

私は保存されています。

したがって、私が卡夫卡服务器を要求するとき、私は何の东西にも到達できません。</p>

我怎么能得卡夫卡服务器现在的偏移量?

私はちょうど想从现在開始获取得データ</p>

4

1 に答える 1

0

SimpleConsumer.getOffsetsBefore(トピック、パーティション、時間、1)

時間は kafka.api.OffsetRequest.EarliestTime() である必要があり、最小の有効なオフセットを取得します

于 2013-08-13T09:22:45.287 に答える