我们的需求是想得到每天消息的Offset,同同把消息Payload的关键字段信息提取出来,运维用来做关键字段信息和Kafka消息的匹配。Ksql可以很容易获取Payload的里边的字段,但好像没有找到如何获取消息的Offset等元数据信息
你的答案