apache-kafka - Kafka Processor API 中的 Header 有什么用？

Question

我正在学习 Kafka Processor API 并在 ProcessorContext 中找到一个方法 header 。

headers​()

Returns the headers of the current input record; could be null if it is not available

这个方法有什么用？

在docs只写了一行:

Returns the headers of the current input record; could be null if it is not available

我可以对此执行一些操作，例如添加吗？

Answer 1

header 是可以附加到每条消息的某种元数据。 header 可用于各种场景，例如附加可在过滤记录时使用的信息等。

---

您可以通过 Processor API 访问消息的元数据，更准确地说是 process()、transform() 和 transformValues()。对于 example , 为了向记录添加标题，以下将达到目的:

public void process(String key, String value) {

    // add a header to the elements
    context().headers().add.("key", "value")
}