Показатели производительности Kafka с Prometheus

Question

У меня есть две службы (serviceA и serviceB), с двумя темами (topicIn, topicOut).

Поток одного сообщения выглядит следующим образом:

1. ServiceA выдает сообщение topicIn,
2. ServiceB потребляет сообщение от topicIn и обрабатывает сообщение.
3. Когда serviceB обработал сообщение, он отправляет его topicOut,
4. serviceA затем потребляет от topicOut

Я ищу метрики для очистки с прометеем, которые будут определять время, необходимое для обслуживания службы B (topicIn), обработать и вывести сообщение (topicOut).

Любые предложения будут великолепны. Спасибо