我必须用Apache·Kafka来联系我公司的经纪人。问题是我以前从未使用过这种技术，这是我需要澄清的一点。
实际上，我创建了一个带有zookeeper/server/consumer的“local”kafka，它与命令一起工作
~/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic testGaultier --from-beginning我现在在另一个案例中，服务器/生产者已经由另一个人管理。我只需要创造一个消费者。
是否有必要下载Kafka的整个软件包来创建消费者，还是有其他方法？我只想对数据进行恢复。
1条答案
按热度按时间xv8emn3q1#
如果您想使用console consumer，那么它与您对本地示例所做的完全相同，但是现在在启动consumer时指定zookeeper和kafka服务器的主题名。
或者，如果您想创建一个定制的使用者，您可以使用java使用者api或google作为另一种语言的api。
在第一种情况下，您必须下载kafka包，因为它有所有必要的脚本和类。对于第二种情况，没有必要这样做。