You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@beam.apache.org by nishant jain <ni...@gmail.com> on 2022/03/29 07:32:02 UTC

Issue with using CheckStopReadingFn in kafka

Hi

I am using kafka IO to dynamically read from topics along with
CheckStopreadingFn which returns false when called more than 5 times.

But my pipeline is failing with error "Last attempted offset should not not
be null. no work was claimed in non-empty range [24,9223372036854775807)"

Can someone help me with this?

Thanks
Nishant