功能改进:图表有时难以阅读,因为y轴图例上出现非整数,实际绘制的数据总是整数。将y轴设置为仅绘制整数,以使图表更易于解释。支持命令行参数kafkaOffsetForceFromStart,通过实现ConsumerRebalanceListener从日志的开头开始消费者偏移监听客户端。稳定性改进:创建tryParseOffsetMessage函数,尝试解析从内部提交的偏移主题检索到的kafka偏移消息:处理其他类型的消息和可疑正确性。为这个新函数添加了100%的单元测试覆盖率。增强日志末端偏移获取线程的健壮性:不再关闭应用程序错误。而是关闭和销毁客户端,然后重新创建它。在错误发生时休眠后重新创建客户端,并继续处理处理在线程之间共享内存的线程安全问题。