...
We will add a merge()
method to the KStream interface.
static <K,V> KStream<K,V> merge(StreamsBuilder builder, KStream<K,V> ... streams);
Proposed Changes
...
public static <K,V> KStream<K,V> merge(StreamsBuilder builder, KStream<K,V> ... streamsstream)
{
return this.builder.merge(streamsstream); //builder (type:InternalStreamsBuilder) was defined in the AbstractStream superclass
}
Compatibility, Deprecation, and Migration Plan
...