👾Scripts and samples to support Confluent Demos and Talks. ⚠️Might be rough around the edges ;-) 👉For automated tutorials and QA'd code, see https://github.com/confluentinc/examples/
The consumer and the deseralisation works fine. As the next step I want use a new class copy the values and send it back to Kafka with a new topic.
Do you have a recommendation how to do? Or where in the documenation I could find an example.
I think it's called processor and I did not get it to run correct with StreamBuilder.
I forgot to mention that a SchemaRegistry is used.
Hi Markus,
Sorry for the delay responding. If this is still an issue, please post this over at https://forum.confluent.io/ and I'll try to get someone to help you there.
Hi,
I have question about this sample code
The consumer and the deseralisation works fine. As the next step I want use a new class copy the values and send it back to Kafka with a new topic.
Do you have a recommendation how to do? Or where in the documenation I could find an example. I think it's called processor and I did not get it to run correct with StreamBuilder.
I forgot to mention that a SchemaRegistry is used.
Thanks, Markus