Kafka流/表连接和消息头

kmb7vmvb 于 2023-03-01 发布在 Apache

关注(0)|答案(1)|浏览(112)

我花了一整天的时间在谷歌上搜索和尝试，我相信目前的状态是消息头可以从处理器API访问。
我想从DSL访问Process API，所以我实现了一个ValueTransformSupplier，从那里我可以访问处理器上下文，这使我可以访问流的头部。
但问题是。
我正在执行流/表连接，要访问的头来自表记录，而不是ProcessContext保存的流消息头。
那么，是否有一种方法可以从流/表连接访问KTable中表示的消息头呢？

apache-kafka

来源：https://stackoverflow.com/questions/75078836/kafka-stream-table-join-and-message-headers

1条答案

按热度按时间

oxcyiej71#

当你将数据读入KTable时，记录头不会被存储。你需要将头复制到 value 中来保存它们。

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

赞(0）回复(0）举报 2023-03-01

我来回答

Kafka流/表连接和消息头

1条答案

相关问题

热门标签

最新问答