使用Kafka RecordMetadata获取主题、分区等信息的优势探讨

首先明确：从性能上来说，两者没有任何明显差异。

为什么性能没差异？ #

ConsumerRecord内部已经缓存了RecordMetadata中的核心元数据（主题、分区、偏移量等），不管你调用consumerRecord.topic()还是consumerRecord.recordMetadata().topic()，都是直接读取内存里的字段值，没有任何额外的IO开销，速度完全一样。

RecordMetadata的微小优势（几乎用不上） #

RecordMetadata是Kafka Broker返回的权威元数据来源，ConsumerRecord里的元数据其实是从它这里复制过去的。只有在极端异常场景下（比如你自定义了ConsumerRecord的实现，不小心修改了元数据字段），RecordMetadata能给你提供最原始的、未被篡改的元数据——但这种情况在常规的Kafka使用中基本不会遇到。

什么时候该用哪个？ #

• 消费者端：直接用ConsumerRecord的方法（topic()、partition()）就够了，代码更简洁直观，没必要多此一举去调用RecordMetadata。
• 生产者端：RecordMetadata是发送消息后的返回结果，用来确认消息是否成功写入、获取偏移量等，这才是它的主要使用场景。

内容的提问来源于stack exchange，提问作者Pauls Baby