【问题标题】:is Kafka stream KTable commit interval based on Wall-clock-time?Kafka 流 KTable 提交间隔是基于挂钟时间的吗?
【发布时间】:2020-03-31 09:43:21
【问题描述】:

我在 KTable 上找不到关于提交间隔所用时间的任何指示。是 Walk-Clock-Time 还是 Stream Time ,Producer Time ?

【问题讨论】:

    标签: apache-kafka-streams


    【解决方案1】:

    如果您参考commit.interval.ms 配置,则答案是挂钟时间。

    【讨论】:

    • 谢谢,这就是我所指的
    • 只是快速跟进。如果提交是您所说的挂钟,并且 kafka 流的默认值是流时间(默认时间戳提取器),那么就何时提交内容而言,这不会导致问题吗?还是因为提交是挂钟的事实,它只是忽略了记录的时间戳,来决定何时提交?
    • 忽略记录时间戳。
    • 感谢您的信息
    猜你喜欢
    • 2012-12-23
    • 1970-01-01
    • 1970-01-01
    • 2020-08-08
    • 2016-08-28
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2018-11-04
    相关资源
    最近更新 更多