kafka自定义消费者读取传入记录答案

【问题标题】：kafka custom consumer to read incoming recordskafka自定义消费者读取传入记录
【发布时间】：2017-02-25 20:51:09
【问题描述】：

当前消费者正在从最小偏移量开始读取主题中的消息。我想覆盖它以从最新的偏移量中读取。关于如何做到这一点的任何指示？

【问题讨论】：

【解决方案1】：

尝试设置auto.offset.reset = largest，尽管这应该是默认设置。

【讨论】：

【解决方案2】：

一旦您开始读取给定消费者组的消息，您需要使用 seekToEnd() 方法显式地强制消费者到达它所遵循的分区的末尾。对于尚未读取任何消息的消费者组，您可以使用 auto.offset.reset=largest 属性告诉消费者在哪里读取其第一条消息。

【讨论】：