Почему сообщение, которое отправляется в тему 2 через тему 1, может иметь более раннюю временную метку брокера, чем тема 1 в Apache Kafka? - PullRequest
0 голосов
/ 14 сентября 2018

Наша топология шторма обрабатывает сообщения из Темы 1 и отправляет их в Тему 2, и сообщение имеет уникальный ключ и совпадает с темой в боте Темы 1 и Темы 2. Мы пытаемся измерить фактическую задержку путем измерения разницымежду отметкой времени посредника в Теме 2 и отметкой времени посредника в Теме 1 на основе уникального ключа.Как ни странно, иногда для нескольких сообщений показывается отрицательное число, но не всегда.Почему сообщение, которое отправляется в тему 2 через тему 1, может иметь более раннюю отметку времени посредника, чем тема 1. Я проверил NTP между всеми посредниками в кластере, и оно синхронизировано.

Кто-нибудь знает и сталкивался с таким видомвопроса.Мы используем HDP 2.6.5 vesrion.

...