獲取 Consumer group.id

當在多個容器中執行相同的監聽器程式碼時,能夠確定記錄來自哪個容器(由其 `group.id` Consumer 屬性標識)可能很有用。

您可以在監聽器執行緒上呼叫 `KafkaUtils.getConsumerGroupId()` 來實現此目的。或者,您可以在方法引數中訪問 group id。

@KafkaListener(id = "id", topicPattern = "someTopic")
public void listener(@Payload String payload, @Header(KafkaHeaders.GROUP_ID) String groupId) {
    ...
}
此功能在接收 `List` 記錄的記錄監聽器和批處理監聽器中可用。它在接收 `ConsumerRecords` 引數的批處理監聽器中**不可用**。在這種情況下,請使用 `KafkaUtils` 機制。