首页 > 解决方案 > 如何检测保留策略已从硬盘中删除未处理的消费者数据?

问题描述

如何检测保留策略已从硬盘中删除未处理的消费者数据?

我只找到了一种解决方案,它是 set consumer setting AUTO_OFFSET_RESET_CONFIG="none"。如果保留策略已删除未处理的消费者数据,则消费者抛出org.apache.kafka.clients.consumer.OffsetOutOfRangeException异常。

这是正确的解决方案吗?是否存在更好的解决方案?

标签: apache-kafka

解决方案


推荐阅读