kafka-api-blueprint

Reference / template for a Kafka producer-consumer mechanism.

See also:

• kafka-producer-blueprint
• kafka-consumer-blueprint

Build the JAR files

cd ../kafka-producer-blueprint
./gradlew clean build

cd ../kafka-consumer-blueprint
./gradlew clean build

cd ../kafka-api-blueprint
./gradlew clean build

Start the services

docker-compose up --build

Verify Kafka Installation

Create a Kafka topic

docker-compose exec kafka kafka-topics.sh --create --topic another-test-topic --bootstrap-server kafka:9092 --partitions 1 --replication-factor 1

List Kafka topics

docker-compose exec kafka kafka-topics.sh --list --bootstrap-server kafka:9092

Test the Kafka integration

• Use Postman or a browser to access the API endpoint:

  http://localhost:8083/publish?message=HelloKafka
  

• The message will be forwarded to the producer application, which will then publish it to Kafka.

Stop and remove all containers

docker-compose down

Remove existing containers, volumes, and images

docker-compose down -v --rmi all

---

Reference Documentation

• Official Gradle documentation
• Spring Boot Gradle Plugin Reference Guide
• Spring Configuration Processor
• Spring Boot DevTools
• Spring Integration
• Spring for Apache Kafka

Additional Links

These additional references should also help you:

• Gradle Build Scans – insights for your project's build