Split Topic Data

Question

I want to split a topic into serveral topics, based on specific fields in the data. Is there a possibility to do such operations in the streaming itself?

Or should I write a typically Consumer and Producer?

Example:

Input Topic: Data with attributes A (values AAA, BBB, CCC), B, C, D and E

Output Topics: 3 Topics with Name AAA, BBB and CCC with the same data as in Input Topic

Kind Regards, Lukas

Answer 1

You can use branch() method in your stream to split into several streams. Than each stream can write in own topic.