Re: Kafka Streams - Stream threads processing two input topics

2022-01-10 Thread Guozhang Wang
Hi Miguel, I suspect it's due to the timestamps in your topic A, which are earlier than topic B. Note that Kafka Streams tries to synchronize joining topics by processing records with smaller timestamps, and hence if topic A's messages have smaller timestamps, they will be selected over the other.

Kafka Streams - Stream threads processing two input topics

2022-01-10 Thread Miguel González
Hello We are consuming two topics (A and B) and joining them, but I have noticed no matter what I do, topic A gets consumed first in a batch and then topic B , increasing *num.stream.threads* will only get topic A process a lot of records faster. Topic B has lots of messages compared to Topic A