kstream/ktable连接中的kafka流时间戳同步

jm81lzqq  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(270)

具有具有具有以下消息序列的内部join kstream/ktable:
t1处的表\u evt\u-->t2处的流\u evt\u-->t3处的表\u evt\u-->t4处的流\u evt\u
连接触发器:
(流在t2处,表在t1处)+(流在t4处,表在t3处)
到目前为止,一切正常。当我重置流应用程序(使用kafka streams application reset.sh)并重放所有事件时,会出现意外结果:
(t2处的流,t3处的表)+(t4处的流,t3处的表)
在处理事件时,kafka流似乎没有考虑时间戳。它填充ktable,然后处理kstream,为两个kstream事件获取ktable的最后一个值(table_evt_at_t3)。
注意,我使用的是kafka streams 2.3.1,一个自定义的timestampextractor和属性 max.task.idle.ms = 10 * 1000L 正如[kip-353][1]所建议的那样
这是预期的行为吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题