獲取消費者 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機制。 |
