apache-kafka - 将 KafkaEx.ConsumerGroup 添加到应用程序的监督树

Question

尝试添加KafkaEx.ConsumerGroup到应用程序的监督树时遇到问题。

函数 KafkaEx.ConsumerGroup.start_link/1 未定义或私有

我应该怎么做才能让消费者在 kafka_ex 中收听消息？

标签： apache-kafkaelixirphoenix-framework

Answer 1

我发现很容易集成的新库，kaffe。 https://github.com/spreedly/kaffe

kaffe 是 Brod 的 Elixir 包装器，Brod 是 Erlang 本机的 kafka 客户端。