Tom-Causs/kafka-cassandra-poc

The app consists of two parts:Kafka Producer - generates random messages and sends them to KafkaKafka Consumer - reads messages from Kafka topic and stores them in CassandraRequirementsJava 8GitMavenVirtualBoxVagrantSetupTo run the app, first execute the following cmd from the project root:vagrant upThis will start up the Vagrant box. The first time will take a while as it has to download the OS image and other dependencies.To start-up the producer app, run the following cmd from the kafka-producer folder:$ mvn spring-boot:runNote: the producer will terminate after the messages have been sentTo start-up the consumer app, run the following cmd from the kafka-consumer folder:$ mvn spring-boot:runNote: the consumer will keep listening for new messages until manually terminatedShutting down the vagrant box can be done by typingvagrant haltMisc. commandsCreating a Kafka topic:./kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic myTopicList all Kafka topics:./kafka/bin/kafka-topics.sh --list --zookeeper localhost:2181Run the console producer:./kafka/bin/kafka-console-producer.sh --broker-list 192.168.33.10:9092 --topic myTopicRun the console consumer:./kafka/bin/kafka-console-consumer.sh --zookeeper 192.168.33.10:2181 --topic myTopic --from-beginningRun Cassandra terminal client:./cassandra/bin/cqlshAboutA simple demo to show how Kafka works together with CassandraUsed technologies:Spring BootApache KafkaCassandra