Reactive Driver and Kafka

Projects overview :

• kafka-dse-core contains domain beans and utility classes
• kafka-dse-producer is a standalone Spring Boot application that generates random Tick Data load from AlphaVantage and then random
• kafka-dse-webui is the standalone web UI.

Start the project

Use docker compose to start all components

docker-compose up -d

A docker ps command will list you the following containers :

• datastax/dse-server:6.7.0 is the DataStax enterprise server (listening on 9042)
• datastax/dse-studio:6.7.0 is the WebUI available 9091 DataStax Studio
• wurstmeister/zookeeper:3.4.6 is the Zookeeper ensuring consistency for Kafka (listening on 2181)
• wurstmeister/kafka:1.0.0 the kafka server (listening on 9092)

2. Start the kafka-dse-producer component.

Open the folder kafka-dse-producer :

# Start Web Application
mvn spring-boot:run 

This will create the KeySpace demo_kafka if needed, the tables to work with and fill the reference table stocks_infos with Data coming fron the CSV

This is a Camel Application with no UI, still you should access the SpringBoot Administration Console

3. Start the kafka-dse-webui component.

Open the folder kafka-dse-webui :

# Start Web Application
mvn spring-boot:run 

Access the web UI