说明:Kafka Scala模板
这是使用scala与kafka一起工作的模板。 使用自动生成的avro代码,一切都被docker化,所有消息均以avro格式发送。 该模板针对使用Linux / Ubuntu / Mac和Intellij的人群。
目录
该程序做什么
该程序在生产者中产生小的“ Hello there”消息,并且kafka-connect自动将它们传输到postgres。 流模块添加了!!! 在每封邮件的末尾。 消费者显示生产者和流模块已发出的消息。
如何运行
build.gradle
<weixin_42118701> 上传 | 大小:865kb