Hi All, I’m consuming data from a compacted kafka topic using

upsert-kafka

connector and converting the same to a DataStream using

.toChangelogStream

. I have another DataStream from source kafka created using

kafka

connector. Now, I’m doing a keyBy on both of these and connecting them using a

KeyedCoProcessFunction

implementation. I’m facing an issue where I see huge number of records in the source kafka operator in the flink UI, even though I do not have those many records being published to that topic. When I avoid

.connect

I could see less records in the source operator. Any idea what could be wrong here?