Kafka Smallrye MicrpProfile

Kafka messaging java example of SmallRye micro-profile using maven

this app requires kafka

./run-local-kafka.sh
# or: ./run-kafka-in-docker.sh

build and run fatJar

mvn clean package
java -jar target/*-all.jar

run using maven

mvn clean compile exec:java -Dexec.mainClass=com.github.daggerok.App
# or
mvn clean compile exec:java -Dexec.mainClass=org.jboss.weld.environment.se.StartMain 

for debugging purpose run App main class right from IDE in debug mode

• SmallRye Reactive Messaging: Interacting with Apache Kafka
• GitHub: useful kafka tests / configs