This can happen if you have an idle partition. Are all partitions receiving data consistently?
On Tue, Jul 13, 2021 at 2:59 PM Jerome Li <l...@vmware.com> wrote: > > 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 -- Cheers, Aeden GitHub: https://github.com/aedenj Linked In: http://www.linkedin.com/in/aedenjameson Blah Blah Blah: http://www.twitter.com/daliful
