sarama

0热度

1回答

Kafka 0.11/Golang Sarama版本支持

我花了一些时间发现连接到Kafka 0.11群集的Go应用程序正在使用库的旧版本0.8.2，它在响应中缺少Timestamp值。 然后我发现Kafka 0.11.x API /版本不被支持（但他们正在处理它）。 我现在有两种解决方案。 首先是在我的应用程序中明确设置所需版本。 其次是“调整”Sarama代码以使用版本0.10.x作为最低版本，使我可以使用所有的0.10.x API /功能。 我还在

go apache-kafka sarama 2017-09-25

---

0热度

2回答

如何通知消费者在Kafka中已创建新主题？

我想让我的消费者动态更新其消费。 让我给你一个更具体的例子，使用动物。想象一下，我有一家宠物商店，每个话题都是一种动物（如狗，猫，鱼）。我的卡夫卡消费者的主要责任是抓住我们在卡夫卡的任何日志/记录/消息并将它们存储到数据库中。 假设我的消费者正在主动消费dogs和cats主题并且一切正常，现在有一种新型动物进入商店并在卡夫卡群集中生成新主题。我如何通知我的消费者已添加新主题？ 我有两个建议，我想看

apache-kafka sarama 2017-10-10

---