Я работаю над созданием конвейера обработки в реальном времени, используя Kafka Streams для обработки данных, поступающих из Kafka и Kafka Connect, для интеграции данных в MongoDB. Следующим этапом является запись в журнал показателей Kafka Streams и Connect (задержка, пропускная способность, пропущенные записи, ...) и запись в стандартный вывод. Какой эффективный способ добиться этого?
Заранее спасибо