Kafka-streams filter messages using headers
We’re trying to use kafka streams for our project to read data from one topic and write to another, and we have a use case to use KafkaHeaders as a mechanism to filter our certain records.
The message is logged even though topic is deleted
My tester has found that if a topic is deleted then the logging is still ongoing even if the message is not sent to target. The idea is not to log the Outgoing Enum if we are not sure that the message was successfully sent. Here is the piece of problematic code:
Kafka Streams List Serdes : is always empty
What I am doing wrong ?
Kafka Streams List Serdes : is always empty
What I am doing wrong ?