README 작성

This commit is contained in:
deogicorgi
2022-04-01 22:52:48 +09:00
parent 433a76a721
commit 78be3a6b20
2 changed files with 56 additions and 4 deletions

View File

@@ -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"
}
```

View File

@@ -1,4 +0,0 @@
package com.github.deogicorgi.reactor.kafka.producer.message;
public class KafkaProduceMessage extends AbstractKafkaProduceMessage {
}