Задается через флаг в конфигурации. либо Kafka, либо REST API
Задается через флаг в конфигурации.
либо Kafka, либо REST API