当前位置: 首页 > news >正文

查看 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 
http://www.lryc.cn/news/289551.html

相关文章:

  • QT+VS实现Kmeans聚类算法
  • openssl3.2 - 测试程序的学习 - test\acvp_test.c
  • Qt Quick 项目(第二集Qt Quick Application创建)
  • 深度强化学习(王树森)笔记03
  • Cesium材质特效
  • 华为产业链之车载激光雷达
  • java的Object类的hasCode()和ToString()
  • php数组算法(1)判断一维数组和多元数组中的元素是否相等并输出键值key
  • 已解决Error:AttributeError: module ‘numpy‘ has no attribute ‘float‘.
  • WordPress块编辑器(Gutenberg古腾堡)中如何添加脚注?
  • burpsuite怎么进行本地抓包?ctfer测试自搭建靶场必须学会!
  • VSCode Python调试运行:json编写
  • 自动化Web页面性能测试介绍
  • 可视化 | 【d3】力导向关系图优化(搜索+刷新)
  • 2024.1.26力扣每日一题——计算 K 置位下标对应元素的和
  • R语言【taxlist】——levels():获取或设置分类等级列表
  • 单元测试——题目十三
  • 使用Linux SDK客户端向AWS Iot发送数据
  • 1.27学习总结
  • 【算法专题】二分查找(进阶)
  • 开源项目对于新用户和初学者适合哪些工作
  • linux中配置文件目录为什么用etc来命名
  • 06.领域驱动设计:使用DDD分层架构,可以有效降低层与层之间的依赖
  • HCIA-Datacom实验指导手册:3.2 实验二:生成树基础实验
  • WPF的ViewBox控件
  • 论文精读--BERT
  • LeetCode第468题 - 验证IP地址
  • 淘宝API接口调用:案例分析与最佳实践
  • 中仕教育:事业单位考试考什么?
  • python-自动化篇-运维-监控-简单实例-道出如何使⽤Python进⾏系统监控?