读取(使用)Kafka 主题时，是否可以确定生成消息时使用的架构版本/ID

Question

我有一个 Kafka 主题的 C# 使用者，但我想知道正在读取的消息的版本/ID。 此属性在 ComsumeResult 中是否以某种方式可用？或者有没有其他方法可以知道所制作记录的版本是什么。 我问的原因是生产者不断更改版本，我喜欢从消耗的消息中跟踪它产生的版本。

Answer 1

因此，默认情况下，Kafka 没有模式。我假设您使用的是 Confluent Schema Registry？

话虽如此，反序列化后，没有。

您需要将数据用作字节，然后将字节 1-4 作为整数观察

https://docs.confluent.io/current/schema-registry/serdes-develop/index.html#wire-format