我们使用kafka作为我们的消息队列,我们的业务要求消息时间戳必须与偏移量具有相同的顺序,这意味着:如果有消息m1和消息m2,并且(m1.timestamp
最佳答案
这取决于使用的时间戳类型,有两种类型:
CreateTime
- 创建生产者记录时分配时间戳,因此在发送之前。可以重试,因此不能保证保留顺序。 LogAppendTime
- 将记录附加到代理上的日志时分配时间戳。在这种情况下,每个分区的排序将被保留。多条消息可能会分配相同的时间戳。 默认情况下,
CreateTime
用来。要更改此设置,请设置 log.message.timestamp.type
经纪人或 message.timestamp.type
对于特定主题。
关于apache-kafka - Kafka时间戳顺序是否与偏移量相对应?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55258690/