Добавить KafkaEx.ConsumerGroup в дерево наблюдения за приложением
Возникла проблема при попытке добавить KafkaEx.ConsumerGroup в дерево наблюдения за приложением.
function KafkaEx.ConsumerGroup.start_link/1 is undefined or private
Что мне делать, чтобы потребитель работал, чтобы прослушать сообщение в kafka_ex?
Построение конвейеров данных в реальном времени с Apache Kafka: Руководство по Python
Apache Kafka - популярная платформа распределенной потоковой передачи данных, которую можно использовать для построения конвейеров данных в реальном...
0
0
134
1
Ответы 1
Я нашел новую библиотеку, которую очень легко интегрировать, kaffe. https://github.com/spreedly/kaffe
kaffe - это оболочка Elixir для Brod, Brod - это клиент kafka для родного Erlang.
Другие вопросы по теме
Insert_all не соответствует типу: utc_datetime
Эликсир феникса kafka_ex Connection
Ecto Queryable не реализован для модуля Phoenix
Как выбрать случайный элемент из набора ets в Erlang / Elixir?
Понимание функций Elixir с несколькими предложениями
Has_many - ограничение до одного для заданной области (например, 1 лайк на пользователя для данного комментария)
Как я могу использовать Erlang с Docker для запуска приложения Phoenix?
Редактировать зависимости проекта напрямую
Какие гарантии времени компиляции я получаю, когда запускаю phx.server?
Как вы загружаете репо при тестировании веб-компонентов в Phoenix?
Похожие вопросы
Потоки Kafka: чтение из ВСЕХ разделов в каждом экземпляре приложения
Как десериализовать сообщение Kafka в структуру Avro, используя в конечном итоге libserdes?
Платформа слияния или утешение?
KafkaIO withLogAppendTime против withProcessingTime
Эликсир феникса kafka_ex Connection
В KafkaProducer.send (сообщение) я получаю «исключение Ошибка сериализации сообщения Avro»
Десериализация зашифрованного сообщения kafka в потребителе
Kafka Avro Сериализатор и исключение десериализатора. Поддерживаемые типы Avro
Spring Cloud Stream - не удается настроить адрес брокера kafka
Springboot Cloud Stream с Kafka