Files
Nacho Munoz e547d0a96d Kafka Streams sample demo for TopologyTestDriver
Fixes: #1853

* Demonstrating Kafka Streams `TopologyTestDriver`
* README updates in the sample
* Update Spring Boot parent version of the samples to 3.2.5
2024-04-29 17:03:19 -04:00
..
2018-11-05 14:11:17 -05:00
2022-12-20 13:34:33 -05:00
2018-11-05 14:11:17 -05:00
2021-03-05 12:59:15 -05:00

== Sample 2

This sample demonstrates a simple producer and a multi-method consumer; the producer sends objects of types `Foo1` and `Bar1` and the consumer receives objects of type `Foo2` and `Bar2` (the objects have the same field, `foo`).

The producer uses a `JsonSerializer`; the consumer uses a `ByteArrayDeserializer`, together with a `ByteArrayJsonMessageConverter` which converts to the required type of the listener method argument.
We can't infer the type in this case (because the type is used to choose the method to call).
We therefore configure type mapping on the producer and consumer side.
See the `application.yml` for the producer side and the `converter` bean on the consumer side.

The `MultiMethods` `@KafkaListener` has 3 methods; one for each of the known objects and a fallback default method for others.

Run the application and use curl to send some data:

`$ curl -X POST http://localhost:8080/send/foo/bar`

`$ curl -X POST http://localhost:8080/send/bar/baz`

`$ curl -X POST http://localhost:8080/send/unknown/xxx`

Console:

`Received: Foo2 [foo=bar]`
`Received: Bar2 [bar=baz]`
`Received unknown: xxx`