可以使用Kafka Streams访问消息头吗？

Question

由于增加了头的记录（ProducerRecord＆ConsumerRecord）在卡夫卡0.11，是有可能处理与卡夫卡流的话题时，得到这些标题？当调用类似mapon的方法时，KStream它提供记录的key和的参数，value但是我看不到访问的方法headers。如果我们可以刚好map超过ConsumerRecords
，那就太好了。

例如

KStreamBuilder kStreamBuilder = new KStreamBuilder();
KStream<String, String> stream = kStreamBuilder.stream("some-topic");
stream
    .map((key, value) ->  ... ) // can I get access to headers in methods like map, filter, aggregate, etc?
    ...

这样的事情会工作：

KStreamBuilder kStreamBuilder = new KStreamBuilder();
KStream<String, String> stream = kStreamBuilder.stream("some-topic");
stream
    .map((record) -> {
        record.headers();
        record.key();
        record.value();
    })
    ...

Answer 1

自Streams API
2.0版以来，可以访问记录头。（有关详细信息，请参见KIP-244。）

可以通过处理器API访问记录的元数据（即，通过transform()，transformValues()或process()），通过给定的“上下文”对象（参见https://docs.confluent.io/current/streams/developer-
guide/processor-api.html ＃accessing-processor-
context
）。

在2.0之前的版本中，上下文仅公开主题，分区，偏移量和时间戳-而不公开那些旧版本中Streams在读取时实际上丢弃的标头。

但是，元数据在DSL级别上不可用。但是，也正在进行扩展DSL的工作：https
:
//cwiki.apache.org/confluence/display/KAFKA/KIP-159%3A+Introducing+Rich+functions+to+Streams