kafka自定义消费者读取传入记录
kafka custom consumer to read incoming records
我使用新的 API (http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html)
创建了一个 kafka 消费者
当前消费者正在阅读主题中从最小偏移量开始的消息。我想覆盖它以从最新的偏移量读取。关于如何做到这一点的任何指示？
尝试设置 auto.offset.reset = largest，虽然这应该是默认设置。
一旦您开始读取给定消费者组的消息，您将需要使用 seekToEnd() 方法明确强制消费者到达它所跟随的分区的末尾。对于还没有阅读过任何消息的消费者群体，可以使用auto.offset.reset=largest属性来告诉消费者去哪里阅读它的第一条消息。
我使用新的 API (http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html)
创建了一个 kafka 消费者当前消费者正在阅读主题中从最小偏移量开始的消息。我想覆盖它以从最新的偏移量读取。关于如何做到这一点的任何指示？
尝试设置 auto.offset.reset = largest，虽然这应该是默认设置。
一旦您开始读取给定消费者组的消息，您将需要使用 seekToEnd() 方法明确强制消费者到达它所跟随的分区的末尾。对于还没有阅读过任何消息的消费者群体，可以使用auto.offset.reset=largest属性来告诉消费者去哪里阅读它的第一条消息。