Kafka Streams branching return type affects bindings when using multiple output bindings: intentional behaviour?

2024-06-20 Thread Jenny Qiao
Hello, KIP-418 (>=2.8) improved the branching return type from KStream<>[] to HashMap. This changes the output binding when using multiple branches in the Kafka Streams binder of Spring Cloud Stream - the bindings are possibly wrong because the map storing the KStream branches is unordered.

Re: Kafka Streams branching return type affects bindings when using multiple output bindings: intentional behaviour?

2024-06-27 Thread Jenny Qiao
s it "naively" create the array via `streamMap.values().toArray(new KStream[0])` introducing the problem? It seem, Spring could implement the binder using more sophisticated logic to fix the problem (or just return the `Map` instead of an array to begin with)? HTH. -Matthias On 6/20/24