我没有看到任何提及消息键(org.apache.kafka.clients.producer.ProducerRecord.key
)除了它们可以用于主题分区。
我可以自由地将我喜欢的任何数据放入密钥中,还是有一些我应该遵守的特殊语义?
该密钥似乎是一个方便的标头,可以放置少量元数据。这是一个坏主意吗?
我没有看到任何提及消息键(org.apache.kafka.clients. Producer.ProducerRecord.key),除了它们可以用于主题分区。
Kafka中key的使用:
1. 分区
2.保证分区内的排序
3. 在日志压缩期间用于创建偏移映射
可能还有更多我还没学到的东西..:-)
我可以自由地将我喜欢的任何数据放入密钥中,还是有一些我应该遵守的特殊语义?
Key 可以是任何类型 Null、字符串或具有有效序列化机制的任何其他形式。
你知道密钥的大小是否重要吗(例如 64 字节与 200 字节)
密钥的大小很重要,因为它会改变您的整体有效负载大小。因此,缓冲区上的每个消息的利用率都会改变。我想不出还有什么其他影响。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)