kafka-streams-example收集了我使用Kafka stream进行过的小型项目。 这是我第一次编写Java 8 lambda并使用gradle构建。 这些项目的灵感来自kafka-src streams-examples。 我计划也包括scala示例。
主题包括:
WordCountLambdaDemo(工作示例)通过启动真正的Kafka服务器等来运行集成测试的指令位于该类的javadoc中
在流中运行WordCountDemo-Kafka-src的示例
将我在脚本文件夹下放在一起的run-streams-examples.sh复制到kafka-src目录中
转到该目录
摇动
./gradlew stream:examples:tasks(如果要找出要使用的gradle任务)
./gradlew clean -PscalaVersion = 2.12 stream:ex
评论0
最新资源