如何获取Kafka主题的序列化格式?
How to get the serialization format of a Kafka topic?
除了使用 Confluent Schema Registry,有没有办法(通过内置的 CLI 工具)查看主题键和值的序列化格式?
Kafka(我指的是代理)完全不知道任何东西的 "format" 是什么。对于经纪人来说,一切都是字节。
Kafka 有线格式也没有专门的地方来指定编码方案——无论是键还是值,或者键控方案,或者分区方案,或者其他任何东西。 Kafka 记录有 headers,但就像有效载荷一样,代理不会查看它们。
有效载荷格式(对于键和值)只是生产者和消费者之间的一种 agreed-upon 约定。一些生产者和消费者可以配置为与 avro 模式注册表(如 confluent 注册表)进行操作,但绝对没有什么可以阻止某人启动 <byte[], byte[]>
生产者并将猫照片发送到此类主题。
也没有说有效载荷需要是单一(多态)类型——你可以做任何你想做的事,只要你所有的生产者和消费者"agree"了解如何read/write数据.
除了使用 Confluent Schema Registry,有没有办法(通过内置的 CLI 工具)查看主题键和值的序列化格式?
Kafka(我指的是代理)完全不知道任何东西的 "format" 是什么。对于经纪人来说,一切都是字节。
Kafka 有线格式也没有专门的地方来指定编码方案——无论是键还是值,或者键控方案,或者分区方案,或者其他任何东西。 Kafka 记录有 headers,但就像有效载荷一样,代理不会查看它们。
有效载荷格式(对于键和值)只是生产者和消费者之间的一种 agreed-upon 约定。一些生产者和消费者可以配置为与 avro 模式注册表(如 confluent 注册表)进行操作,但绝对没有什么可以阻止某人启动 <byte[], byte[]>
生产者并将猫照片发送到此类主题。
也没有说有效载荷需要是单一(多态)类型——你可以做任何你想做的事,只要你所有的生产者和消费者"agree"了解如何read/write数据.