文件名称:kafka-cassandra-poc:卡夫卡-卡桑德拉POC
文件大小:30KB
文件格式:ZIP
更新时间:2024-06-11 02:22:37
Java
Kafka-Cassandra演示 该应用程序包括两个部分: Kafka Producer-生成随机消息并将其发送给Kafka Kafka Consumer-从Kafka主题读取消息并将其存储在Cassandra中 要求 Java 8 吉特 玛文 设置 要运行该应用程序,请首先从项目根目录执行以下cmd: vagrant up 这将启动“ Vagrant”框。 第一次需要一段时间,因为它必须下载OS映像和其他依赖项。 要启动生产者应用,请从kafka-producer文件夹中运行以下cmd: $ mvn spring-boot:run 注意:生产者将在消息发送后终止 要启动消费者应用程序,请从kafka-consumer文件夹运行以下cmd: $ mvn spring-boot:run 注意:使用者将继续监听新消息,直到手动终止 关闭流浪者框可以通过键入以下内容来完成
【文件预览】:
kafka-cassandra-poc-master
----.gitignore(788B)
----README.md(2KB)
----kafka-producer()
--------pom.xml(1KB)
--------src()
----Vagrantfile(1KB)
----kafka-consumer()
--------pom.xml(2KB)
--------src()
----vagrant()
--------bootstrap-always.sh(442B)
--------bootstrap-once.sh(966B)