Kafka Streams GlobalKTable 和访问记录 headers
Kafka Streams GlobalKTable and accessing the record headers
以同样的方式 KStream 和 KTable#toStream() 允许调用 process 或 transform 从而启用检查记录 headers, 有没有办法使用 GlobalKTable 实现相同的效果。基本上，我正在寻找一种方法来检查 Kafka 主题中的记录 headers 并将其作为 GlobalKTable 使用。谢谢！
或许，您可以改用 #addGlobalStore？
请注意，“全局处理器”永远不应修改数据，但 put() 键值对（可能还有时间戳）未修改到 (Timestamped)KeyValue 存储中（参见 https://issues.apache.org/jira/browse/KAFKA-8037)
以同样的方式 KStream 和 KTable#toStream() 允许调用 process 或 transform 从而启用检查记录 headers, 有没有办法使用 GlobalKTable 实现相同的效果。基本上，我正在寻找一种方法来检查 Kafka 主题中的记录 headers 并将其作为 GlobalKTable 使用。谢谢！
或许，您可以改用 #addGlobalStore？
请注意，“全局处理器”永远不应修改数据，但 put() 键值对（可能还有时间戳）未修改到 (Timestamped)KeyValue 存储中（参见 https://issues.apache.org/jira/browse/KAFKA-8037)