producer это не указываю явно и тут вот непонятно кто это делает - сам продюсер берет системное время (наш случай, там время в будущее убежало на сервере) или все же kafka должна ставить время сохранения в топик?
Я был уверен, что кафка ставит отметку времени
по умолчанию ставит продюсер, если хотите это исправить, на топик нужно выставить параметр message.timestamp.type=logappendtime, тогда сама кафка будет ставить таймстемп. в формате могу ошибаться, по памяти пишу
Обсуждают сегодня