offset - 这次我怎么能得到kafka服务器的偏移量？

Question

我已经保留了我的 kafka 客户端偏移量，但是 kafka 服务器在时间增量中删除了数据。

所以当我调用 kafka 服务器获取数据时，我什么也得不到。

这次我怎么能得到kafka服务器的偏移量？

我只想从现在开始获取数据

我有保存我的卡夫卡客户端还有，但卡夫卡服务器会在之后删除数据。</p>

因此，当我向卡夫卡服务器要数据时，我不能得到任何东西。</p>

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

我只是想从现在开始获取数据</p>

Answer 1

SimpleConsumer.getOffsetsBefore（主题，分区，时间，1）

时间应该是 kafka.api.OffsetRequest.EarliestTime() ，得到最小的有效偏移量