我有一个Kafka主题的消费者，但我想知道正在阅读的消息的版本/id。这个属性在comsumeresult中是否可用？或者是否有其他方法可以知道生成的记录的版本。我问这个问题的原因是制作者一直在更改版本，我想从消耗的消息中跟踪它的版本。
ukqbszuj1#
因此，默认情况下，Kafka没有模式。我假设您使用的是合流模式注册表？也就是说，在反序列化之后，没有。您需要以字节的形式使用数据，然后将字节1-4看作整数https://docs.confluent.io/current/schema-registry/serdes-develop/index.html#wire-格式
1条答案
按热度按时间ukqbszuj1#
因此，默认情况下，Kafka没有模式。我假设您使用的是合流模式注册表？
也就是说，在反序列化之后，没有。
您需要以字节的形式使用数据，然后将字节1-4看作整数
https://docs.confluent.io/current/schema-registry/serdes-develop/index.html#wire-格式