apache-kafka - 如何检测保留策略已从硬盘中删除未处理的消费者数据?
问题描述
如何检测保留策略已从硬盘中删除未处理的消费者数据?
我只找到了一种解决方案,它是 set consumer setting AUTO_OFFSET_RESET_CONFIG="none"
。如果保留策略已删除未处理的消费者数据,则消费者抛出org.apache.kafka.clients.consumer.OffsetOutOfRangeException
异常。
这是正确的解决方案吗?是否存在更好的解决方案?
解决方案
推荐阅读
- c# - 而协程内部的条件不循环,挂起
- javascript - 如何动态测试 CSS 类中的文本,然后根据标准更新 CSS?
- javascript - 重复一个while循环延迟,直到其中的ajax调用完成
- javascript - How does gmail and facebook change the URL path without having to change the entire HTML DOM?
- javascript - WebDriverIO - 处理提示登录消息
- python - How to install pip specifically for Python3 on CentOS 7?
- sql - Informix 窗口函数范围子句的行为类似于行子句
- javascript - Javascript Discord,给提到的用户一个角色
- django - 如何调试从计算机到服务器的连接,服务器端
- javascript - Split array into chunks/bulks and made operations with them one by one