对于最新的稳定版本，请使用 Spring for Apache Kafka 3.3.9！spring-doc.cadn.net.cn

获取消费者group.id

当在多个容器中运行相同的侦听器代码时，能够确定哪个容器（由其group.id消费者属性），记录来自。spring-doc.cadn.net.cn

您可以调用KafkaUtils.getConsumerGroupId()在侦听器线程上执行此作。 或者，您可以在方法参数中访问组 ID。spring-doc.cadn.net.cn

@KafkaListener(id = "id", topicPattern = "someTopic")
public void listener(@Payload String payload, @Header(KafkaHeaders.GROUP_ID) String groupId) {
    ...
}
这在接收List<?>的记录。 它在接收ConsumerRecords<?, ?>论点。 使用KafkaUtils在这种情况下的机制。