Как получить groupId прослушивателя Kafka в java?

У меня есть прослушиватель Kafka, в котором я устанавливаю идентификатор группы с помощью SpEL (Spring Expression) для создания случайно сгенерированного уникального идентификатора для каждого запуска/экземпляра. Мне нужно получить идентификатор этой группы для ведения журнала и мониторинга. Какие-либо предложения?

Журналы уже должны печатать ConsumerConfig раздел с идентификатором группы.

— 20.03.2022 16:13

KafkaUtils.getConsumerGroupId().

— 21.03.2022 14:00

спасибо @GaryRussell ... я обновил версию spring-kafka и смог получить идентификатор группы

— 22.03.2022 16:51

тем временем я также смог получить ConsumerConfig, внедрив KafkaListenerEndpointRegistry в свой класс слушателя... спасибо @OneCricketeer за вклад в ConsumerConfig

— 22.03.2022 16:53

java spring apache-kafka spring-kafka spring-el

20.03.2022 03:04

Пользовательский скаляр GraphQL

Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...

Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами

В компьютерном программировании биты играют важнейшую роль в представлении и манипулировании данными на двоичном уровне. Побитовые операции...

Поднятие тревоги для долго выполняющихся методов в Spring Boot

Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...

Принятие принципов SOLID в Spring Boot: Создание обслуживаемых и масштабируемых приложений

Коллекции (ArrayList , HashSet , HashMap)

Полный курс Java для разработчиков веб-сайтов и приложений

Получите сертификат Java Web и Application Developer, используя наш курс.

Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Используйте KafkaUtils.getConsumerGroupId() из пакета org.springframework.kafka.support.

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

См. документы KafkaUtils для более подробной информации.

21.03.2022 13:59