Skip to content

Commit c61cbf7

Browse files
committed
chore(kafka): add kafka binding to example
1 parent f36b119 commit c61cbf7

File tree

2 files changed

+12
-2
lines changed

2 files changed

+12
-2
lines changed

springwolf-examples/springwolf-kafka-example/src/main/java/io/github/stavshamir/springwolf/example/kafka/consumers/StringConsumer.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33

44
import io.github.stavshamir.springwolf.asyncapi.scanners.channels.operationdata.annotation.AsyncListener;
55
import io.github.stavshamir.springwolf.asyncapi.scanners.channels.operationdata.annotation.AsyncOperation;
6+
import io.github.stavshamir.springwolf.asyncapi.scanners.channels.operationdata.annotation.KafkaAsyncOperationBinding;
67
import io.github.stavshamir.springwolf.asyncapi.scanners.channels.payload.AsyncApiPayload;
78
import io.swagger.v3.oas.annotations.media.Schema;
89
import lombok.Data;
@@ -25,6 +26,7 @@ public class StringConsumer {
2526
description =
2627
"Final classes (like String) can be documented using an envelope class and the @AsyncApiPayload annotation.",
2728
payloadType = StringEnvelope.class))
29+
@KafkaAsyncOperationBinding
2830
public void receiveStringPayload(String stringPayload) {
2931
log.info("Received new message in {}: {}", TOPIC, stringPayload);
3032
}

springwolf-examples/springwolf-kafka-example/src/test/resources/asyncapi.json

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -176,7 +176,11 @@
176176
"publish": {
177177
"operationId": "string-topic_publish",
178178
"description": "Final classes (like String) can be documented using an envelope class and the @AsyncApiPayload annotation.",
179-
"bindings": { },
179+
"bindings": {
180+
"kafka": {
181+
"bindingVersion": "0.4.0"
182+
}
183+
},
180184
"message": {
181185
"oneOf": [
182186
{
@@ -189,7 +193,11 @@
189193
"headers": {
190194
"$ref": "#/components/schemas/HeadersNotDocumented"
191195
},
192-
"bindings": { }
196+
"bindings": {
197+
"kafka": {
198+
"bindingVersion": "0.4.0"
199+
}
200+
}
193201
},
194202
{
195203
"schemaFormat": "application/vnd.oai.openapi+json;version=3.0.0",

0 commit comments

Comments
 (0)