|
该版本仍在开发中,尚未被视为稳定。对于最新稳定版本,请使用 Spring for Apache Kafka 4.0.0! |
获取消费者group.id
当在多个容器中运行相同的监听器代码时,能够确定是哪个容器(由其标识)可能很有用group.id消费者财产)中,记录来自该财产。
你可以打电话KafkaUtils.getConsumerGroupId()在听众帖里做这件事。
或者,你也可以在方法参数中访问组ID。
@KafkaListener(id = "id", topicPattern = "someTopic")
public void listener(@Payload String payload, @Header(KafkaHeaders.GROUP_ID) String groupId) {
...
}
这适用于唱片听众和批量听众,这些听众获得了名单<?>记录。
该数据不存在于接收消费者记录<?, ?>论点。
使用该卡夫卡实用主义者在这种情况下,机制。 |