在ApacheKafka中,为什么通过主题1传递到主题2的消息可以比主题1具有更早的代理时间戳?

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

我们的storm拓扑正在处理来自主题1的消息并将其发送到主题2,并且该消息具有唯一密钥,这在bot主题1和主题2中是相同的。我们试图通过测量主题2的代理时间戳和基于唯一密钥的主题1的代理时间戳之间的差异来测量实际延迟。奇怪的是,有些时候很少有消息显示负数,但并不总是如此。为什么通过主题1传递到主题2的消息可以比主题1具有更早的代理时间戳。我已经验证了集群中所有代理之间的ntp,并且它是同步的。
有谁知道和面对这样的问题。我们使用的是hdp2.6.5vesrion。

暂无答案!

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

相关问题