Добавьте KafkaEx.ConsumerGroup в дерево контроля приложений.

Question

Возникла проблема при попытке добавить KafkaEx.ConsumerGroup в дерево наблюдения приложения.

Функция KafkaEx.ConsumerGroup.start_link / 1 не определена или закрыта

Что следуетЯ делаю, чтобы потребитель работал над прослушиванием сообщения в kafka_ex?

Answer 1

Я нашел новую библиотеку, которую очень легко интегрировать, Каффе.https://github.com/spreedly/kaffe

Кафе - это обертка Эликсира вокруг Брода, Брод - клиент кафки для уроженца Эрланга.