Java Кафка клиент регистрирует все конфиги для каждого потока

Question

У меня есть java клиент (с использованием клиента kafka версии 2.4.1), который подключен к kafka (версия 2.4.1), который имеет 5 топи c с 5 разделами в каждом. Я создаю 1 поток на раздел. Моя проблема заключается в том, что для каждого потока регистрируется вся потребительская конфигурация:

Сначала я хотел бы знать, является ли это нормальным поведением (как у меня есть 25 потоков я вижу 25 раз журналы тезисов)? Может я что то не так делаю. На данный момент каждый мой потребительский поток подписывается на него topi c. Поэтому я вызываю метод 25 раз, и каждый из вызовов, похоже, генерирует журналы тезисов.

Тогда что я могу сделать, чтобы отключить их?

Answer 1

Это нормальное поведение, он просто регистрирует всю конфигурацию потребителя каждый раз, когда вы создаете новый KafkaConsumer в каждом потоке (это правильный способ использования нескольких потребителей в многопоточном приложении, каждый потребитель должен использоваться только в одном тема).

Вы можете отключить журнал Kafka, если вы используете log4j, добавив регистратор для фильтрации отладочных сообщений Kafka:

<loggers>
    <logger name="org.apache.kafka" level="ERROR"/>
</loggers>