Kafka流/表连接和消息头

Question

我花了一整天的时间搜索和尝试，我认为当前的状态是消息头可以从处理器api访问。

我想从DSL访问进程API，所以我实现了一个ValueTransformSupplier，从那里我可以访问处理器上下文，这使我可以访问流的头。

但关键是…

我正在做一个流/表连接，我要访问的头是来自表记录，而不是来自流的消息头，这是ProcessContext持有的。

那么，是否有一种方法可以从流/表连接访问KTable中表示的消息的头?

Answer 1

当您读取数据到KTable时，记录头不存储。您需要将标题复制到值中以保存它们。

KTable t = builder.stream("table-topic")
.transformValues(/* access headers and copy into value */)
.toTable();