couchbase-kafka-hadoop-demo

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