Можем ли мы использовать APPLICATION_ID_CONFIG для производителей? - PullRequest
0 голосов
/ 10 мая 2018

Я прочитал несколько блоков для достижения масштабируемости в Kafka. мы должны использовать концепцию группировки, используя application.id и group.id, мы можем создавать группы для потребителей. таким же образом мы можем сделать группы для производителей, используя application.id и group.id?

1 Ответ

0 голосов
/ 10 мая 2018

Клиенты Kafka используют идентификаторы только тогда, когда им нужно сохранить какое-либо состояние на брокерах.

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

Вы также заметите, что у транзакционного производителя есть transactional.id, поскольку у него есть состояние. http://kafka.apache.org/documentation/#producerconfigs

...