【文件属性】：
文件名称：couchbase-kafka-hadoop-demo
文件大小：74KB
文件格式：ZIP
更新时间：2021-06-24 10:58:54
Java
Couchbase-Kafka 集成演示
环境
下载 。 在开始之前，请确保 Zookeeper ( 2181 ) 和 Kafka ( 6667 ) 端口已转发。
启动虚拟机。 导航到并确保 kafka 服务已启动。
建造
编译jar文件：
./gradlew shadowJar
执行演示应用程序，它侦听默认存储桶中的所有更改并在 kafka 中发布相应的消息。
java -cp build/libs/couchbase-kafka-hadoop-demo-1.0-all.jar example.ClickStreamProducer
java -cp build/libs/couchbase-kafka-hadoop-demo-1.0-all.jar example.ClickStreamConsumer
【文件预览】：
couchbase-kafka-hadoop-demo-master
----.gitignore(106B)
----gradle()
--------wrapper()
----README.md(669B)
----build.gradle(1KB)
----gradlew.bat(2KB)
----gradlew(5KB)
----couchbase-kafka-hadoop-demo.iml(21KB)
----src()
--------main()
----.idea()
--------encodings.xml(164B)
--------vcs.xml(284B)
--------misc.xml(511B)
--------modules.xml(294B)
--------scopes()
--------.name(28B)
--------findbugs-idea.xml(12KB)
--------copyright()
--------compiler.xml(739B)
--------checkstyle-idea.xml(294B)
----settings.gradle(50B)