Kafka时间戳顺序是否与偏移量相对应？

Question

我们使用kafka作为我们的消息队列，我们​​的业务要求消息时间戳必须与偏移量具有相同的顺序，这意味着：如果有消息m1和消息m2，并且（m1.timestamp

Answer 1

这取决于使用的时间戳类型，有两种类型：

• CreateTime- 创建生产者记录时分配时间戳，因此在发送之前。可以重试，因此不能保证保留顺序。
• LogAppendTime- 将记录附加到代理上的日志时分配时间戳。在这种情况下，每个分区的排序将被保留。多条消息可能会分配相同的时间戳。

默认情况下，CreateTime使用。要更改此设置，请log.message.timestamp.type为代理或message.timestamp.type特定主题设置。