Несколько экземпляров производителя кафки - PullRequest
0 голосов
/ 08 апреля 2020

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

1 Ответ

2 голосов
/ 08 апреля 2020

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

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

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

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

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

...