Kafka时间戳顺序与偏移量对应吗?

p8h8hvxi  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(591)

我们使用kafka作为消息队列,我们的业务要求消息时间戳必须与偏移量的顺序相同,即:如果有消息m1和消息m2,以及(m1.timestamp)

yhived7q

yhived7q1#

它取决于使用的时间戳类型,有两种类型: CreateTime -时间戳是在创建生产者记录时分配的,所以在发送之前。可以重试,因此不能保证保留顺序。 LogAppendTime -将记录附加到代理上的日志时,会分配时间戳。在这种情况下,将保留每个分区的顺序。多个消息可能会分配相同的时间戳。
默认情况下, CreateTime 已使用。要更改此设置,请设置 log.message.timestamp.type 经纪人或 message.timestamp.type 针对特定主题。

相关问题