Skip to content

Reactive functional endpoint that receives data and sends it to kafka asynchronously, reactively, and non-blocking.

Notifications You must be signed in to change notification settings

ivanas93/sample-reactive-kafka-producer

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

5 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

sample-reactive-kafka-producer

Quick start

1 - (Optional) Modify the Netty port in the application.yml file.

2 - Modify Kafka bootstrap server url and kafka topic in file application-standalone.yml

spring:
  kafka:
    bootstrap-servers: localhost:9092
    template:
      default-topic: app.local.alert

3 - Run the application.

mvn spring-boot:run 

3 - Make an HTTP call by POST to the endpoint with the necessary information. e.g:

POST http://localhost:9090/message
Content-Type: application/json

{json}

About

Reactive functional endpoint that receives data and sends it to kafka asynchronously, reactively, and non-blocking.

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages