Несколько экземпляров производителя kafka

Я понимаю, что несколько экземпляров приложения-производителя могут быть запущены для создания данных для темы. Какие изменения конфигурации необходимы для этого? Мне нужен другой client_id? Без всяких изменений работает. Так что не уверены, есть ли какая-либо польза от изменения идентификатора клиента или любого другого параметра конфигурации? Спасибо,


apache-kafka spring-kafka kafka-producer-api
person Sanjay    schedule 08.04.2020    source источник

Ответы (1)


arrow_upward
2
arrow_downward

Идентификатор клиента просто используется для регистрации на сервере.

Цель этого состоит в том, чтобы иметь возможность отслеживать источник запросов, помимо IP/порта, позволяя включать логическое имя приложения в журнал запросов на стороне сервера.

Так что это не очень важно, если у вас много производителей в одном приложении.

Чтобы получить разные идентификаторы клиентов для каждого производителя, вам потребуется фабрика производителей для каждого.

На стороне потребителя вы можете указать идентификатор клиента на уровне контейнера (или @KafkaListener).

person Gary Russell    schedule 08.04.2020