【文件属性】：
文件名称：kafka-cassandra-poc:卡夫卡-卡桑德拉POC
文件大小：30KB
文件格式：ZIP
更新时间：2021-05-22 08:35:57
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)