apache-kafka - Kafka - 添加自定义 header 以记录元数据

Question

kafka 是否允许添加自定义 header 来记录元数据。代码表明它没有。有人试过吗？

Answer 1

apache-kafka从 0.11.0.0 版本到 KIP-82 - Add Record Headers 已经包括对自定义 header 的支持.

例如，您可以使用这个 method :

public ProducerRecord(String topic,
                      Integer partition,
                      K key,
                      V value,
                      Iterable<Header> headers)

另见相关问题:

1. Adding Custom Headers in Kafka Message
2. Header information in kafka producer API