我有 2 个服务:生产者和消费者。
据我了解,message.ts
是生产者产生消息的时间(而不是kafka-broker 收到消息的时间)。
问题
当消费者消费消息时,我怎么知道它在 kafka-broker 内的时间(没有网络延迟:从生产者到 kafka-broker 以及从 kafka-broker 到消费者)?
我从我的消费者 vm 到 kafka 代理执行了 ping 操作。ping 结果为 0.7ms(毫秒)。从每一方到kafka broker的网络延迟是0.3ms吗?我假设 kafka 传输是
TCP
这样的,所以所有东西都有一个“ACK”消息。而且我假设没有“ACK”,每一方都不会做任何事情,所以我得出结论,每个大小的网络延迟与 ping 结果相同:0.7ms(毫秒)。我对么?