Кафка сообщение написать латентность - PullRequest
0 голосов
/ 04 марта 2019

Мы пытаемся измерить задержку записи сообщений в Infosphere CDC - Confluent kafka setup.У нас есть фиктивная таблица, и фиктивные транзакции будут выполняться.

Поток данных - таблица MF DB2 -> IIDR -> тема Кафки

(Для Кафки производитель - iidr)

Каким может быть правильный способ определения задержки записи типовых транзакций без какого-либо инструмента корпоративного мониторинга?Можем ли мы проверить журналы на предмет записей и рассмотреть каждую временную метку транзакции и сравнить с журналами транзакций cdc, чтобы узнать задержку записи?

PS - у меня есть jconsole, настроенный для сбора метрик kafka.Но как найти задержку записи определенного потока CDC в тему kafka?

Спасибо!

...