Kafka Streams GlobalKTable 并访问记录头

Question

以同样的方式，

KStream

和

KTable#toStream()

允许调用

process

或

transform

，从而启用检查记录标题，有没有办法与

GlobalKTable

实现相同的效果。基本上，我正在寻找一种在将 Kafka 主题作为

GlobalKTable

使用时检查记录标头的方法。谢谢！

Answer 1

也许你可以用

#addGlobalStore

代替？

请注意，“全局处理器”永远不应该修改数据，但

put()

键值对（可能还有时间戳）未修改到

(Timestamped)KeyValue

存储中（参见 https://issues.apache.org /jira/浏览/KAFKA-8037）

Answer 2

当我使用kafka主题来创建globalKtable时，我需要访问标头。我在这里问了我的问题：How to Access Headers in a GlobalKTable in Kafka Streams 你能帮我解决这个问题吗？