【文件属性】:
文件名称:kafka-case:定制的Kafka生产者和消费者
文件大小:9KB
文件格式:ZIP
更新时间:2021-02-15 04:41:22
Java
卡夫卡案
自定义Kafka Producer和Consumer应用程序。
文章: :
目标:
创建自己的CustomConsumer。
创建自己的CustomProducer,以使用Twitter API自动生成并向主题发送至少10条消息。
使用自定义名称空间,以避免与其他“ CustomProducer”类的命名冲突。
备用:
使用Facebook API,或创建随机单词生成器,选择随机名词-动词名词,或循环浏览每秒发送一条消息的列表。
实验-目标是轻松将外部消息添加到任何Java应用。
推荐环境
先决条件
Twitter开发人员帐户
OpenJDK或JDK(8或更高版本)
阿帕奇Maven
Apache Zookeeper
阿帕奇·卡夫卡
还:
配置系统环境变量,包括Path。
配置Zookeeper
配置卡夫卡
完成你的专案
确定您的名称空间。
遵循M
【文件预览】:
kafka-case-master
----.gitignore(375B)
----src()
--------main()
----pom.xml(2KB)
----README.md(3KB)