bbejeck / kafka-streams Goto Github PK

Hello,
I deployed your repo with the generation of the data everything is OK however when the data is displayed by the consumers nothing happens.
I only noticed that the topic stocks and src-topic are filled
could you help me

Usually we set one processor forward to one sink.
There is any way to forward data to multiple topics?

@Override
public void process(byte[] key, byte[] value) {
     context.forward(key, value);
}

I have one source,but i want sent data to two topics,such as:

// message = {"type":"1",........}
Topic-1（source）
Topic-2、Topic-3

if(type == "1") 
     send data to Topic-2
else if(type == "2")
    send data to Topic-3