How to write a stream processor

Kafka Streams
1

Hi,
I’m working on a PoC with cp-all-in-one-community for the local infrastructure.
My goal is to write a processor that transform messages from an input topic and send the output to another topic.
The messages have different Avro schemas and the Avro union is registered in the schema registry. The producer works fine, the problem is that the processor doesn’t seem to be invoked once the message is sent to the input topic.

In stackoverflow I did already post the details of the problem.

Hope to get better support in this forum.

Thank you.

2

Solution in the stackoverflow post.

3

This topic was automatically closed 7 days after the last reply. New replies are no longer allowed.