Hi Aljoscha, I tested ConnectedStream and CoFlatMapFunction as you told me but the result is not as I wait.
*For the execution:* 1) I added 3 rules on "rules" topic (imei: "01","02,"03") 2) Perform 15 events with different imei but i guess i have problem with "keyby" *Result : * <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/n12998/2222222.jpg> Code : Best, -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Join-two-kafka-topics-tp12954p12998.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
