Указание группы консьюмеров#
Группа консьюмеров обработчика указывается в файле *.conf в поле consumer блока source (в параметре «group.id»).
Рекомендуется разворачивать обработчик сразу с уникальной группой.
# Блок-источник события
source: {
name: "default"
type: "source"
topic: "input"
config: ${defaults.kafka} {
consumer: {
"group.id": "e-p-f-g-<наименование обработчика>" # consumer-группа обработчика при вычитке из Kafka
"client.id": "event-process-flow-client"
}
producer: {
"client.id": "event-process-flow-producer"
}
}
destination: ${transformStep}
}