Kafka timestamp order 对应的是offset吗?
Is Kafka timestamp order corresponding to the offset?
我们的消息队列使用kafka,我们的业务要求消息时间戳必须与偏移量顺序相同,也就是说:如果有消息m1和消息m2,并且(m1.timestamp
这取决于使用的时间戳类型,有两种类型:
CreateTime
- 在创建生产者记录时分配时间戳,因此在发送之前分配。可以重试,因此不能保证保留顺序。
LogAppendTime
- 当记录附加到代理上的日志时分配时间戳。在这种情况下,每个分区的顺序将被保留。多封邮件可能会分配相同的时间戳。
默认使用CreateTime
。要更改此设置,请为经纪人设置 log.message.timestamp.type
或为特定主题设置 message.timestamp.type
。
我们的消息队列使用kafka,我们的业务要求消息时间戳必须与偏移量顺序相同,也就是说:如果有消息m1和消息m2,并且(m1.timestamp
这取决于使用的时间戳类型,有两种类型:
CreateTime
- 在创建生产者记录时分配时间戳,因此在发送之前分配。可以重试,因此不能保证保留顺序。LogAppendTime
- 当记录附加到代理上的日志时分配时间戳。在这种情况下,每个分区的顺序将被保留。多封邮件可能会分配相同的时间戳。
默认使用CreateTime
。要更改此设置,请为经纪人设置 log.message.timestamp.type
或为特定主题设置 message.timestamp.type
。