如何获取java中Kafka监听器的groupId？

Question

我有一个 Kafka 侦听器，我在其中使用 SpEL（Spring 表达式）设置组 ID，以便为每个 run/instance 生成随机生成的唯一 ID。我需要获取此组 ID 以用于记录和监视目的。有什么建议吗？

Answer 1

使用 org.springframework.kafka.support 包中的 KafkaUtils.getConsumerGroupId()。

/**
 * Get the group id for the consumer bound to this thread.
 * @return the group id.
 * @since 2.3
 */
public static String getConsumerGroupId() {...}

See the KafkaUtils docs了解更多详情。