查看 Avro 格式的 Kafka 消息(启用了 Confluent Schema Registry )

使用 Avro 格式传递 Kafka 消息要比 Json 更加高效,因为它是二进制格式,在启用了 Confluent Schema Registry 的情况下,会进一步地提升传输效率,因为 Avro 中的 Schema 信息将不再出现在消息中,消息体积会进一步压缩,同时,还可以利用到 Schema Registry 的其他好处,例如 Schema Evolution 管理。

但是,由于 Avro 是二进制格式,且使用了 Confluent Schema Registry 后 Schema 信息也被剥离,使用 kafka-console-consumer.sh 输出的消息都是乱码,无法阅读,这会给开发和调试带来一些麻烦。正确查看 Avro 消息的方法是使用 Confluent Schema Registry 提供的一个命令行工具: kafka-avro-console-consumer,这个工具是内置在 cp-schema-registry 这个组件中的,不管是手动安装还是使用 Docker 启动 cp-schema-registry 后,都可以直接使用该命令输出 Kafka 的 Avro 消息,类似于 kafka-console-consumer。以下是以 docker 形式登录 cp-schema-registry 后输出 Avro 消息的一个示例:

# connect to a confluentinc/cp-schema-registry container, open bash for input commands.
docker run -it --rm confluentinc/cp-schema-registry 

最近更新

  1. docker php8.1+nginx base 镜像 dockerfile 配置

    2024-01-25 12:56:04       94 阅读
  2. Could not load dynamic library ‘cudart64_100.dll‘

    2024-01-25 12:56:04       101 阅读
  3. 在Django里面运行非项目文件

    2024-01-25 12:56:04       82 阅读
  4. Python语言-面向对象

    2024-01-25 12:56:04       91 阅读

热门阅读

  1. Git搭建

    Git搭建

    2024-01-25 12:56:04      52 阅读
  2. 《设计模式的艺术》笔记 - 状态模式

    2024-01-25 12:56:04       45 阅读
  3. C++高级编程——STL:list容器、set容器和map容器

    2024-01-25 12:56:04       43 阅读
  4. SpringMVC知识点简单规整

    2024-01-25 12:56:04       52 阅读
  5. Swiper轮播图后端接口实现

    2024-01-25 12:56:04       46 阅读
  6. LFU算法

    LFU算法

    2024-01-25 12:56:04      54 阅读
  7. 聊聊PowerJob的MapProcessor

    2024-01-25 12:56:04       40 阅读
  8. 设计模式三(原型模式)

    2024-01-25 12:56:04       61 阅读
  9. Android studio 之 对话框

    2024-01-25 12:56:04       54 阅读
  10. Qt对话框上

    2024-01-25 12:56:04       61 阅读