amirvaza opened a new issue #10566: URL: https://github.com/apache/druid/issues/10566
Hi All, Would love a little help as I can't find a proper solution anywhere at the docs or google. We are using a Kafka cluster with 100 partitions, and 10 middle managers. All works good until Kafka disks are starting to get full. I tried using the api /druid/indexer/v1/supervisor/data_source/status in order to get the currentOffsets and to tell Kafka to delete all prior those offsets, but then we get OffsetOutOfRangeException. What is the correct way to advance the Kafka offsets in order to delete ingested data? Thanks. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
