kafka-case:定制的Kafka生产者和消费者

时间:2024-03-06 22:28:02
【文件属性】:

文件名称:kafka-case:定制的Kafka生产者和消费者

文件大小:9KB

文件格式:ZIP

更新时间:2024-03-06 22:28:02

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)

网友评论