Spring Boot + Apache Camel + Kafka + Cassandra

Documentation:

• Cassandra CQL Camel Component

Test

./gradlew check

Run

docker compose up -d
./gradlew bootRun
docker compose down

Build and Run Jar

docker compose up -d
./gradlew build
java -jar build/libs/spring-boot-camel-kafka-cassandra-0.0.1-SNAPSHOT.jar
docker compose down

CQL shell

docker compose up -d
docker exec -it spring-boot-camel-kafka-cassandra-cassandra-1 cqlsh cassandra 9042 --cqlversion='3.4.7'
use test_keyspace;
select * from hits;

Send to Kafka using kcat

kcat -b localhost:9094 -t hits -P src/test/resources/message.json