首页 文章

Apache Kafka - 消费者基础

提问于
浏览
0

我必须使用Apache Kafka连接到我公司的经纪人 . 问题是我之前从未使用过这种技术,这是我需要澄清的一点 .

实际上,我创建了一个带有Zookeeper / Server / Consumer的“本地”Kafka,它使用命令〜/ bin / kafka-console-consumer.sh --zookeeper localhost:2181 --topic testGaultier - from-beginning

我现在处于另一种情况,其中服务器/ 生产环境 者已经由另一个人管理,我只需要创建一个消费者 . 是否有必要下载整个Kafka包以创建消费者,还是有另一种方式?我想只对数据进行恢复 .

谢谢 ! :)

1 回答

  • 1

    如果要使用控制台使用者,则它与本地实例完全相同,但现在在启动使用者时指定kafka服务器的zookeeper和主题名称 .

    或者,如果要创建自定义使用者,可以使用Java使用者API或google获取其他语言的API .

    在第一种情况下,您必须下载Kafka包,因为它具有所有必需的脚本和类 . 对于第二种情况,没有必要这样做 .

相关问题