kafka集群消费之ConsumerRecord类

时间:2024-10-19 12:14:36
参数:
topic - 收到此记录的主题
partition - 收到此记录的主题分区
offset - 此记录在相应Kafka分区中的偏移量
timestamp - 记录的时间戳。
timestampType - 时间戳类型
checksum - 完整记录的校验和(CRC32)
serializedKeySize - 序列化密钥的长度
serializedValueSize - 序列化值的长度
key - 记录的密钥(如果存在)(允许为null)
value - 记录内容