jorgeavelar/spring-kafka-request-reply

This example demonstrates spring boot and kafka using request-reply semantics.

Java

Synchronous Request-Reply with Spring Boot and Kafka

This example demonstrates spring-kafka using request-reply semantics.

Requirements

Java 11+
Maven 3+
Apache Kafka
Lombok
Docker Compose (optional but preferred)

Running

To start this app:

Start kafka with compose 'docker-compose up'
Start server running './mvnw spring-boot:run'

How to test

Open you console and enter command below:

curl -X POST  http://localhost:8080/coffee/create -d '{"varietal": "Yellow Bourbon","quantity": 5, "price": 30.00}' -H "Content-Type: application/json" | python -m json.tool

Response:

{
    "id": "34ff3987-aa3f-4e8b-8d92-f43d80849e6c",
    "price": 30.0,
    "varietal": "Yellow Bourbon",
    "quantity": 5,
    "amount": 150.0
}

Monitoring application:

curl -X GET http://localhost:8080/monitoring -H "Content-Type: application/json" | python -m json.tool

Maintainers