我有一个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-格式