lfernandez93 opened a new issue #8219:
URL: https://github.com/apache/pinot/issues/8219


   the realtime consumption of records on realtime tables stops when given 
realtime table need to access an offset that has been already wiped by kafka, 
this can happen because the retention policy in the kafka side is lesser than 
how often we commit segments in pinot, however when this happens, there's no 
easy way for us to recover and start consumption again on the realtime table, 
the log message in the pinot-servers shows the following:
   
   `Fetch position xxxx FetchPosition xxx is out of range for partition 
resetting offset xxxx`
   
   There should be a way to recover from this scenario without having to 
recreate the table or having to manually update the zk options for the 
consuming segment which is hard to find in the zk side. 


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]



---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to