apache-kafka - Kafka时间戳顺序是否与偏移量相对应?

标签 apache-kafka timestamp offset

我们使用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/

    相关文章:

    docker - Gradle 中的 Kafka 集成测试运行到 GitHub Actions

    java - 如何使用 JUnit 5 测试 Kafka 消息消费者的 PACT

    java - 当存在 JsonSerializer<Timestamp>() 时,JsonSerializer<Date>() 不适用于 java.util.Date 字段

    excel - 将值单元格工作表复制到列中的另一个第一个空单元格,没有公式复制,但只显示

    python - 为什么 offsets.QuarterBegin 日期是 12-01、03-01、06-01、09-01?

    jquery - 偏移 scrollTop

    apache-kafka - 如何阻止 Kafka Producer 传输数据?

    javascript - kafka-node 设置生产者选项

    where 子句中的时间戳

    php - 试图理解 PHP 中的时间戳和时区