【文件属性】：
文件名称：kafka-through-demo:测试KStream.through操作行为
文件大小：59KB
文件格式：ZIP
更新时间：2021-04-30 21:48:57
Java
测试KStream.through操作行为
这是一个小应用程序，演示了当使用KStream.through操作并且另一流应用程序或生产者使用目标主题时流应用程序的行为。
包含三个部分：
InputProducer-产生随机消息并将其写入名为input-topic的主题
StreamingApp-使用输入主题作为源的流应用程序，转换消息，将其写入名为“ side-topic”的主题，然后将该消息写入系统输出，最后将其写入名为output-topic的主题
IntermediateProducer-这是“坏蛋”。 它将消息直接写到侧面，导致StreamingApp组件出现意外行为
先决条件
Zookeeper和Kafka服务器已安装并可以使用创建的主题：“输入主题”，“侧面主题”，“输出主题”
用法
启动InputProducer并使其运行
启动StreamingApp并观察其输出。 您
【文件预览】：
kafka-through-demo-master
----README.MD(2KB)
----gradlew.bat(2KB)
----gradlew(5KB)
----crete-topics.sh(400B)
----gradle()
--------wrapper()
----src()
--------main()
----.gitignore(276B)
----settings.gradle(40B)
----build.gradle(275B)