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
