Does anyone know how one stream processing application can map messages to different topics based on the data in the original message?
Lets say you have (for historical reasons) one topic with messages containing several statuses (aproved,denied,evaluating etc)… I would like one topic containg only messages with status aproved , one with all the denied and so on. This is simple with several applications, but it feels a bit “over engineering”. Is it posible to routute to different topics based on message content?
yes this is possible by using TopicNameExtractor. Please check
https://kafka.apache.org/20/javadoc/org/apache/kafka/streams/processor/TopicNameExtractor.html