如何解析卡夫卡流中的卡夫卡头?

加上 Headers 记录在案( ProducerRecord & ConsumerRecord )在卡夫卡0.11中,在处理带有卡夫卡流的主题时,是否可以获取这些标题?当调用诸如 map 在 KStream 它提供了 key 还有 value 但我看不到进入 headers .如果我们能 地图 过去 ConsumerRecord s

前任。

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