获取消费者 group.id
当在多个容器中运行相同的监听器代码时，能够确定记录来自哪个容器（由其group.id消费者属性标识）可能会很有用。
您可以在监听器线程上调用KafkaUtils.getConsumerGroupId()来执行此操作。或者，您可以在方法参数中访问组 ID。
@KafkaListener(id = "id", topicPattern = "someTopic")
public void listener(@Payload String payload, @Header(KafkaHeaders.GROUP_ID) String groupId) {
...
}此功能适用于接收List<?>记录的记录监听器和批量监听器。它不适用于接收ConsumerRecords<?, ?>参数的批量监听器。在这种情况下，请使用KafkaUtils机制。 |
