我正在尝试调试与kafka流状态应用程序相关的性能问题(我们仅使用处理器API(。该应用程序查询许多状态存储(接近55个(。因此,为了找出处理缓慢的原因,我一直在寻找指标。我发现我们可以在调试模式下为rocksdb启用jmx度量。
我已经设置了"metrics.recording.level"进行调试。但是,由于某些原因,应用程序没有报告任何度量。我开始获取任务级别的度量(这意味着该级别是调试级别(。我需要启用其他功能吗?
此外,应用程序作为kubernetes pod运行,并在部署/重新启动时创建状态(来自changelog(。
卡夫卡版本:2.4.1Kafka客户端版本:2.4.1
我打这个了吗https://issues.apache.org/jira/browse/KAFKA-9355
此外,是否有任何本地工具可以用于直接查询应用程序pod上的rocksdb。顺便说一句,我可以执行到pod中进行任何调试。
我认为您正在命中:https://issues.apache.org/jira/browse/KAFKA-9675
它已经修复,但修复程序尚未发布。