时间戳

首页 > 解决方案 > 新的消费群体从一开始就挑选信息

apache-kafka - 新的消费群体从一开始就挑选信息

问题描述

我有一个使用 StreamListener 注释的 Kafka 消费者，没有任何组 ID。现在，当我通过它添加 group-id 时，spring.cloud.stream.bindings.input.group它开始处理从头开始处理的所有较旧的消息，这些消息在没有 group-id 时已被该消费者消费。

如何将其配置为仅选择之前未选择的未处理消息？

我尝试添加spring.cloud.stream.bindings.input.startOffset到 latest 和 resetOffsets 为 true 但它没有工作。

提前致谢。:)

标签： apache-kafkakafka-consumer-apiapache-kafka-streamsspring-cloud-streamspring-cloud-stream-binder-kafka

解决方案

如果您已经给出了一个组 id（这是一个必需的属性，我假设 spring 为您生成了一个），那么设置起始偏移量或 auto.offset.reset 将不会生效。

您可以再次更改 ID 以使其正常工作，或者您可以使用 Kafka cli 工具将组调整为您想要的偏移量

推荐阅读