除了使用confluent schema registry之外,是否有方法(通过内置的cli工具)查看主题的键和值的序列化格式?
wi3ka0sx1#
Kafka(我指的是经纪人)完全不知道任何东西的“形式”是什么。对经纪人来说,一切都是字节。kafka wire格式也没有专门的地方来指定编码方案——键或值的编码方案,或者键控方案,或者分区方案,或者任何真正的编码方案。Kafka记录有头,但就像有效载荷一样,代理不看它们。有效负载格式(对于键和值)只是生产者和消费者之间达成一致的约定。一些生产者和消费者可以被配置为操作avro模式注册中心(比如合流注册中心),但是绝对没有什么可以阻止某人创建一个新的注册中心 <byte[], byte[]> 制片人和发送猫的照片这样一个主题。也没有什么规定负载必须是单一的(多态的)类型——只要您的所有生产者和消费者“同意”如何读/写数据,您就可以做任何您想做的事情。
<byte[], byte[]>
1条答案
按热度按时间wi3ka0sx1#
Kafka(我指的是经纪人)完全不知道任何东西的“形式”是什么。对经纪人来说,一切都是字节。
kafka wire格式也没有专门的地方来指定编码方案——键或值的编码方案,或者键控方案,或者分区方案,或者任何真正的编码方案。Kafka记录有头,但就像有效载荷一样,代理不看它们。
有效负载格式(对于键和值)只是生产者和消费者之间达成一致的约定。一些生产者和消费者可以被配置为操作avro模式注册中心(比如合流注册中心),但是绝对没有什么可以阻止某人创建一个新的注册中心
<byte[], byte[]>
制片人和发送猫的照片这样一个主题。也没有什么规定负载必须是单一的(多态的)类型——只要您的所有生产者和消费者“同意”如何读/写数据,您就可以做任何您想做的事情。