Соответствует ли метка времени Кафки смещению?

Question

Мы используем kafka для нашей очереди сообщений. Наш бизнес требовал, чтобы временная метка сообщения была в том же порядке со смещением, что означает: если есть сообщение m1 и сообщение m2, и (m1.timestamp

Answer 1

Это зависит от типа используемой метки времени, есть два типа:

• CreateTime - временная метка назначается при создании записи производителя, поэтому перед отправкой. Возможны повторные попытки, поэтому нет гарантии, что порядок сохранен.
• LogAppendTime - временная метка назначается, когда запись добавляется в журнал в брокере. В этом случае порядок на раздел сохраняется. Для нескольких сообщений может быть назначена одна и та же временная метка.

По умолчанию используется CreateTime. Чтобы изменить это, установите log.message.timestamp.type для брокера или message.timestamp.type для конкретной темы.