Spring cloud stream Kafka broker binder

A practical training stand for working with message brokers - Kafka using a data streaming adapter. In this project, a simple docker configuration for Kafka has been assembled, as well as 2 simple message consumers and a message producer have been developed, two channels have been created for receiving and sending to topics.

Docker compose config:

• kafka broker
• kafka ui - graphical admin dashboard for kafka broker
• zookeeper kafka

kafka topics:

• simple_data - send simple text
• messages_authors - messages authors

Package and components:

• The class ConsumerMessage from the package package com.artemrogov.streamkafka.exchange.business is used to accept messages from the topic - messages_authors
• The class ProducerMessage from the package package com.artemrogov.streamkafka.exchange.business used to send messages to a topic - messages_authors
• The class ConsumerData from the package package com.artemrogov.streamkafka.exchange.simple is used to accept messages from the topic - simple_data
• The class ProducerData from the package package com.artemrogov.streamkafka.exchange.simple used to send messages to a topic - simple_data

Send simple message to simple_data topic kafka:

curl -XPOST http://localhost:9000/send-simple-message

Send message authors to messages_authors topic kafka:

curl --location 'http://localhost:9000/publish-message' \
--header 'Content-Type: application/json' \
--data '{
    "author":"Xeng Yourk",
    "body":"My China Message!!"
}'

Run project

Run kafka broker:

bash docker-compose up -d

Run kafka admin dashboard - http://localhost:8090/ui

Links help:

1. Documentation Spring Cloud Stream
2. Spring Cloud Stream Kafka Binder