我正在学习Kafka处理器API,并在ProcessorContext
中找到一个方法头。
headers()
返回当前输入记录的标头;如果不可用,则可能为空。
这种方法有什么用?
在文档中,只写了一行:
返回当前输入记录的标头;如果不可用,则可能为空。
我可以对此执行一些操作,如add吗?
发布于 2020-03-26 10:14:44
标题是可以附加到每条消息的某种元数据。报头可以在各种场景中使用,例如在筛选记录时可以使用的附加信息。
您可以通过处理器API,更准确地说,通过process()
、transform()
和transformValues()
访问消息的元数据。对于示例,为了向记录中添加一个标头,下面将执行以下操作:
public void process(String key, String value) {
// add a header to the elements
context().headers().add.("key", "value")
}
https://stackoverflow.com/questions/60873247
复制相似问题