Идентификатор клиента просто используется для входа на сервер.
Цель этого состоит в том, чтобы иметь возможность отслеживать источник запросов за пределами только ip / порта, позволяя логическому имени приложения быть включенным в ведение журнала запросов на стороне сервера.
Так что это не очень важно, если у вас в одном приложении много производителей.
Чтобы получить разные идентификаторы клиента для каждого производителя, вы потребуется фабрика производителя для каждого.
На стороне потребителя вы можете указать идентификатор клиента на уровне контейнера (или @KafkaListener
).