是否可以使用 Kafka Streams 访问消息标头？

通过在 Kafka 0.11 中的记录（ProducerRecord 和 ConsumerRecord）中添加 Headers，在使用 Kafka Streams 处理主题时，是否可以获取这些标头？当调用像 on a 这样的方法时，它会提供 记录的 和 的参数，但我无法看到访问 .如果我们能越过s就好了。mapKStreamkeyvalueheadersmapConsumerRecord

前任。

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();
    })
    ...