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

Question

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

标签： apache-kafka

Answer 1

apache-kafka从 0.11.0.0 版本到KIP-82 - Add Record Headers包括对自定义标头的支持。

例如，您可以使用此方法：

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

另请参阅相关问题：

1. 在 Kafka 消息中添加自定义标头
2. kafka生产者API中的头信息