I have 2 kafka streams , i want to merge by some key and on top of the merged stream i want to perform stateful operation so that i can sum up counts from both streams
this what i tried, but dint work .. PCollection<String> stream1 = .. read from kafka PCollection<String> stream2 = .. read from kafka PCollection<String,Long> wonrdCount1 = stream1.apply(...) PCollection<String,Long> wonrdCount2 = stream2.apply(...) PCollection<String,Long> merged = merge wordcount1 and wordcount2 using CoGroupByKey Pcolection<String,Long> finalStream = mergred.apply(...) for finalstream apply state.. Please suggest solution .. -- Regards, *Kiran M Hurakadli.*
