通过忽略所有现有消息开始仅使用来自 Kafka 主题的最新消息答案

【问题标题】：Start consuming only latest messages from Kafka Topic by Ignoring all existing messages通过忽略所有现有消息开始仅使用来自 Kafka 主题的最新消息
【发布时间】：2021-09-19 16:08:51
【问题描述】：

如何通过忽略主题中的所有现有消息来仅使用来自 kafka 主题的最新消息。我有两个相同主题的消费者，当我开始使用来自该主题的消息时，它会获取最旧的消息。我的消费者开始后我需要消费消息。我在我的 Consumer 配置中尝试了此配置，但这不起作用。

config.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest");
config.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");

【问题讨论】：

你需要在消费者中提交偏移量，以便消费者保持最新的偏移量。请检查此以获取更多信息kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/…

标签： java spring-boot apache-kafka

【解决方案1】：

auto.offset.reset

在不更改 groud.id 设置上述参数后，我将再次从消息 0 开始读取。如果您想从 topic 读取当前消息，请先设置：

  config.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest");

然后更改您的 group.id 并重新部署您的消费者。它将开始使用最新消息。

【讨论】：

【解决方案2】：

你试过了吗

auto.offset.reset

https://www.oreilly.com/library/view/kafka-the-definitive/9781491936153/ch04.html

【讨论】：

是的，有问题的代码行显示相同