【发布时间】:2020-04-26 18:56:54
【问题描述】:
我正在尝试调试与 kafka 流状态应用程序相关的性能问题(我们仅使用处理器 API)。应用程序查询许多状态存储(接近 55 个)。因此,为了找出处理缓慢的原因,我一直在寻找指标。我发现我们可以在调试模式下为 RocksDB 启用 jmx 指标。
我已将“metrics.recording.level”设置为调试。但是,由于某种原因,应用程序没有报告任何指标。我开始获取任务级别指标(这意味着该级别是调试的)。我还需要启用其他功能吗?
此外,应用程序作为 kubernetes pod 运行,并在部署/重启时创建状态(来自更改日志)。
卡夫卡版本:2.4.1 Kafka客户端版本:2.4.1
我在打这个https://issues.apache.org/jira/browse/KAFKA-9355
另外,有没有本地工具可以用来直接查询应用程序pod上的rocksdb。顺便说一句,我可以执行到 pod 中进行任何调试。
【问题讨论】:
标签: java apache-kafka apache-kafka-streams rocksdb