Hi,

I got question about Flink Kafka consumer. I am facing the issue that the Kafka 
consumer somehow stop consuming data from Kafka after start for few minutes or 
after few hours. While stopping, I checked the backpressure and cpu and memory 
consumption. It all looks like not data consuming instead of stunk at busy 
computing. And not notable logs in either JM or TM.

I want to know what scenarios could cause the Kafak consumer stop consuming?

Any help would be appreciated!

Best,
Jerome

Reply via email to