From 78be3a6b2065cee80c53ea53fc06947ec74ce202 Mon Sep 17 00:00:00 2001 From: deogicorgi Date: Fri, 1 Apr 2022 22:52:48 +0900 Subject: [PATCH] =?UTF-8?q?README=20=EC=9E=91=EC=84=B1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 56 +++++++++++++++++++ .../producer/message/KafkaProduceMessage.java | 4 -- 2 files changed, 56 insertions(+), 4 deletions(-) delete mode 100644 src/main/java/com/github/deogicorgi/reactor/kafka/producer/message/KafkaProduceMessage.java diff --git a/README.md b/README.md index 3402043..0ffff9c 100644 --- a/README.md +++ b/README.md @@ -1,7 +1,63 @@ Reactive Kafka with Spring Webflux +============= - Versions - Java : 11 - Spring boot : 2.6.6 - Reactive Kafka : 1.3.11 - Spring Webflux : 2.6.6 + +How send a message? +------------- + +The default Path is : +``` +curl --location --request POST 'localhost:18080/produce' \ +--header 'Content-Type: application/json' +``` + +###There are two types of messages you can send (using request body) : +1. URI Message type +``` +{ + "type" : "uri", + "topic" : "my-topic", + "uri" : "http://com.github.deogicorgi/users/1", + "requestedAt" : "2022-04-01T13:00:00" +} +``` + +2. Body Message type +``` +{ + "type": "message", + "topic": "my-topic", + "message": "{\"message\":\"My Message\"}", + "requestedAt": "2022-04-01T13:00:00" +} +``` + +###Depending on the message you send, you will receive the following response : + + +1. Success +``` +{ + "status": true, + "message": "{\"message\":\"myMessage\"}", + "errorMessage": null, + "requestedAt": "2022-04-01T13:00:00", + "producedAt": "2022-04-01T22:49:25.695124" +} +``` + +2. Failure +``` +{ + "status": false, + "message": "{\"message\":\"myMessage\"}", + "errorMessage": "Invalid value null for configuration bootstrap.servers: entry must be non null", + "requestedAt": "2022-04-01T13:00:00", + "producedAt": "2022-04-01T22:49:25.695124" +} +``` \ No newline at end of file diff --git a/src/main/java/com/github/deogicorgi/reactor/kafka/producer/message/KafkaProduceMessage.java b/src/main/java/com/github/deogicorgi/reactor/kafka/producer/message/KafkaProduceMessage.java deleted file mode 100644 index 540ece3..0000000 --- a/src/main/java/com/github/deogicorgi/reactor/kafka/producer/message/KafkaProduceMessage.java +++ /dev/null @@ -1,4 +0,0 @@ -package com.github.deogicorgi.reactor.kafka.producer.message; - -public class KafkaProduceMessage extends AbstractKafkaProduceMessage { -}