Merging and Adding a Sink Node
Explore how to merge two Kafka Streams into one using the merge operator and add a sink node to publish processed data as JSON to another Kafka topic. Learn to apply the to operator for writing data back to Kafka, enabling end-to-end stream processing and validation with Kafka CLI tools.
We'll cover the following...
We'll cover the following...
We have reached the last part of our topology! We want to publish each Feeling record we mapped in the last lesson as a JSON to another Kafka topic. We still have two streams and want to apply the same operator to all the records passing through them. For that, Kafka Streams offers us the merge operator.
Adding a merge operator and a sink processor
...