Я пытаюсь отладить проблему с производительностью, связанную с приложением с состоянием kafka streams (мы используем только процессорный API). Приложение запрашивает ряд государственных магазинов (около 55). Итак, чтобы выяснить причину медленной обработки, я искал метрики. Я обнаружил, что мы можем включить метрики jmx для roadsdb в режиме отладки.
Я установил "metrics.recording.level" для отладки. Но по какой-то причине приложение не сообщает о каких-либо показателях. Я начал получать метрики уровня задачи (что означает, что уровень отлажен). Нужно ли мне что-то еще включать?
Кроме того, приложение работает как модуль kubernetes и создает состояние (из журнала изменений) при развертывании / перезапуске.
Версия Kafka: 2.4.1 Версия клиента Kafka: 2.4.1
Ударяю ли я это https://issues.apache.org/jira/browse/KAFKA-9355
Кроме того, есть ли нативные инструменты, которые могут быть использованы для прямого запроса rockdb в модуле приложения. Кстати, я могу exe c в модуль для любой отладки.