Kafka join не показывает результаты для 2 потоков после ключа groupby и уменьшения java

Question

У меня 2 потока из 2 тем. Предположим, что stream1 и stream2.

Я делаю как

      KStream<String,String> Outstream1 = stream1.selectKey((key,value)-> {
......//some extraction from JsonObject of value part
return event | '|' | timestamp //these fields are extracted from values.
})
.groupByKey()
.reduce(some reduce logic here)
.toStream();

KStream<String,String> Outstream2 = stream2.selectKey((key,value)-> {
......//some extraction from JsonObject of value part
return event | '|' | timestamp //these fields are extracted from values.
})
.groupByKey()
.reduce(some reduce logic here)
.toStream();

//Then here is the join

KStream<String,String> JoinStream = Outstream1.join(outstream2,(dataOfStream1,dataOfStream2) -> {
//Some logic to create the data from the joins
},JoinWindows.of(Duration.ofMinutes(10)));

Это код высокого уровня. Выходные данные для этой логики не генерируются. Что не так, что я здесь делаю ?? Не могли бы вы направить.