我的spring boot应用程序中有3个侦听器。只有一个听众应该从头开始读这个主题。如果我添加到yml文件： spring.kafka.consumer.auto-offset-reset: earliest 然后它适用于所有的听众，但我只需要一个。我补充说：
import static org.apache.kafka.clients.consumer.ConsumerConfig.AUTO_OFFSET_RESET_DOC;
......
@KafkaListener(groupId = "${random.uuid}",
properties = {AUTO_OFFSET_RESET_DOC + ":earliest"})但它不起作用，设置没有被拿起，因为我看到一个发布会上打印的设置：
ConsumerConfig values:
auto.commit.interval.ms = 5000
auto.offset.reset = latest你知道怎么做吗？
1条答案
按热度按时间y3bcpkx11#
你提供的配置应该是错误的
AUTO_OFFSET_RESET_CONFIG不是AUTO_OFFSET_RESET_DOC```@KafkaListener(groupId = "${random.uuid}",
properties = {AUTO_OFFSET_RESET_CONFIG + ":earliest"})
@KafkaListener(groupId = "${random.uuid}",
properties = {"auto.offset.reset = earliest"})
key=value
key:value
key value