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

Kafka 版本

kafka-2.11-2.1.1 :

  • Kafka 1.0.0 后,Kafka 版本命名规则从 4 位到 3 位
  • Kafka版本号是 2.1.1
  • 前 2 : 大版本号 (MajorVersion)
  • 中 1 : 小版本号或次版本号 (Minor Version)
  • 后 1 : 修订版本号 (Patch)

Kafka 0.7 最早开源版本 :

  • 只提供最基础的消息队列功能,扭头就跑

Kafka 0.8 :

  • 引入了副本机制, 成了分布式高可靠消息队列解决方案
  • 副本备份机制保障了消息无丢失
  • 生产/消费用老客户端 API,要指定 ZooKeeper 的地址 , 而非 Broker的地址
  • 生产者 API,默认用同步方式发送消息,吞吐量一般 (异步方式 : 有可能丢失消息)
  • 0.8.2.0 后 , 引入新 Producer API (Bug),即 : 指定 Broker 地址的 Producer
  • 升到 0.8.2.2 后 , 用老消费者 API (较稳定)

Kafka 0.9.0.0 后 :

  • 增加基础的安全认证 / 权限功能
  • 用 Java 重写了新消费者 API (Bug)
  • 引入了 Kafka Connect 组件 , 实现高性能的数据抽取
  • 新 Producer API 较稳定

Kafka 0.10.0.0 后 :

  • 引入了 Kafka Streams,正式成为分布式流处理平台
  • 自 0.10.2.2 后,新 Consumer API 较稳定

Kafka 0.11.0.0 后 :

  • 引入幂等性 Producer API 以事务 (Transaction) API (Bug)
  • 对 Kafka 消息格式做了重构
  • 建议用 0.11.0.3

不管用哪个版本,都要保持服务器端版本和客户端版本一致

  • 后果 : 损失 Kafka 的性能优化
http://www.lryc.cn/news/33654.html

相关文章:

  • ElasticSearch 在Java中的各种实现
  • SpringBoot整合Knife4j
  • MyISAM和InnoDB存储引擎的区别
  • SpringMVC自定义处理多种日期格式的格式转换器
  • NYUv2生成边界GT(1)
  • Spring基本概念与使用
  • 安恒信息java实习面经
  • 第八章:枚举类与注解
  • Ceph介绍
  • remove 和 erase 的区别
  • NFTScan:怎么使用 NFT API 开发一个 NFT 数据分析平台?
  • ECOLOY直接更换流程表单后导致历史流程中数据为空白的解决方案
  • mysql中的共享锁,排他锁,间隙锁,意向锁及死锁机制
  • SpringBoot整合MybatisPlus
  • 中电金信Gien享汇・大数据专题|金融行业数据架构及模型演进
  • Cadence Allegro 导出Design Cross Section报告详解
  • 【LeetCode】剑指 Offer 23. 链表中环的入口节点 p139 -- Java Version
  • LeetCode-96. 不同的二叉搜索树
  • JavaWeb基础
  • C++基础了解-03-C++变量类型
  • 树莓派4b——通过mjpg-streamer使用摄像头
  • MySQL运维篇之读写分离
  • windows程序最小化到托盘并显示提示信息
  • 使字符串平衡的最少删除次数(简单动态规划)
  • linux网络广播使用
  • Kubernetes源码学习
  • 筑基九层 —— 指针详解
  • 内存清理、动画制作、CPU检测等五款实用软件推荐
  • RocketMQ 5.0 学习笔记
  • 796.子矩阵的和