该版本仍在开发中,尚未被视为稳定。对于最新稳定版本,请使用 Spring for Apache Kafka 4.0.0spring-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) {
    ...
}
这适用于唱片听众和批量听众,这些听众获得了名单<?>记录。 该数据存在于接收消费者记录<?, ?>论点。 使用该卡夫卡实用主义者在这种情况下,机制。