kafka如何同步不同broker之间的数据时间戳以及kafka中时间戳是如何创建的
how does kafka synchronize data timestamps between different brokers and how is timestamp created in kafka
Apache Kafka如何管理集群中不同broker之间的同步时间戳,这个时间实际上被记录并转换为消息创建时间戳
以及 Kafka 如何验证它的时间精度
记录时间戳存储为记录字节的一部分。每条记录的字节在代理之间复制,包括时间戳。
默认情况下(取决于客户端),生产者客户端generates/sets记录的时间戳,而不是代理
否则您可能希望查看消息时间戳的代理属性
log.message.timestamp.difference.max.ms
The maximum difference allowed between the timestamp when a broker receives a message and the timestamp specified in the message. If log.message.timestamp.type=CreateTime, a message will be rejected if the difference in timestamp exceeds this threshold. This configuration is ignored if log.message.timestamp.type=LogAppendTime
Type: long
Default: 9223372036854775807
Apache Kafka如何管理集群中不同broker之间的同步时间戳,这个时间实际上被记录并转换为消息创建时间戳 以及 Kafka 如何验证它的时间精度
记录时间戳存储为记录字节的一部分。每条记录的字节在代理之间复制,包括时间戳。
默认情况下(取决于客户端),生产者客户端generates/sets记录的时间戳,而不是代理
否则您可能希望查看消息时间戳的代理属性
log.message.timestamp.difference.max.ms
The maximum difference allowed between the timestamp when a broker receives a message and the timestamp specified in the message. If log.message.timestamp.type=CreateTime, a message will be rejected if the difference in timestamp exceeds this threshold. This configuration is ignored if log.message.timestamp.type=LogAppendTime
Type: long
Default: 9223372036854775807