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

卡夫卡案 自定义Kafka Producer和Consumer应用程序。 文章: : 目标: 创建自己的CustomConsumer。 创建自己的CustomProducer,以使用Twitter API自动生成并向主题发送至少10条消息。 使用自定义名称空间,以避免与其他“ CustomProducer”类的命名冲突。 备用: 使用Facebook API,或创建随机单词生成器,选择随机名词-动词名词,或循环浏览每秒发送一条消息的列表。 实验-目标是轻松将外部消息添加到任何Java应用。 推荐环境 先决条件 Twitter开发人员帐户 OpenJDK或JDK(8或更高版本)