云原生 Kafka AutoMQ 1.1.0-rc1 正式发布
AutoMQ 介绍
与其他流系统的对比
特性 | AutoMQ | Apache Kafka | Confluent | Apache Pulsar | Redpanda | Warpstream |
Apache Kafka 兼容性[1] | 原生 Kafka | 原生 Kafka | 原生 Kafka | 非 Kafka | Kafka 协议兼容 | Kafka 协议兼容 |
是否开源 | 是 | 是 | 否 | 是 | 是 | 否 |
无状态 Broker | 是 | 否 | 否 | 是 | 否 | 是 |
P99 延迟 | 单位数毫秒延迟 | 单位数毫秒延迟 | 单位数毫秒延迟 | 单位数毫秒延迟 | 单位数毫秒延迟 | |
持续自平衡 | 是 | 否 | 是 | 是 | 是 | 是 |
扩展/缩减效率 | 以秒计 | 以小时/天计 | 以小时计 | 以小时计<br>(缩减);<br> 以秒计<br>(扩展) | 以小时计<br>以秒计 (仅限企业版) | 以秒计 |
Spot 实例支持 | 是 | 否 | 否 | 否 | 否 | 是 |
分区重新分配 | 以秒计 | 以小时/天计 | 以小时计 | 以秒计 | 以小时计<br>以秒计 (仅限企业版) | 以秒计 |
组件 | 代理 | 代理<br>ZooKeeper<br>(非 KRaft) | 代理<br>ZooKeeper<br>(非 KRaft) | 代理<br>ZooKeeper<br>BookKeeper<br>代理(可选) | 代理 | 代理<br>元数据服务器 |
持久性 | 由 S3/EBS 保证[2] | 由 ISR 保证 | 由 ISR 保证 | 由 BookKeeper 保证 | 由 Raft 保证 | 由 S3 保证 |
跨可用区网络费用 | 否 | 是 | 是 | 是 | 是 | 否 |
[1] Apache Kafka 兼容性的定义来自这篇 博客。
[2] EBS 持久性:在 Azure、GCP 和阿里云上,区域 EBS 副本跨多个可用区。在 AWS 上,通过在不同可用区的 EBS 和 S3 Express One Zone 进行双写来确保持久性。
创新的存储架构
更新内容
- feat(auto_balancer): 支持 AutoBalancer 的动态配置 ,作者@SCNieh,PR# 1076
- 修复(issues1078):修复 RequestChannel 关闭阻塞问题 ,作者@superhx,PR# 1080
- feat(auto_balancer): 优化分配目标动作得分计算 ,作者@SCNieh,PR# 1083
- docs(config): 添加配置使用建议 ,作者@superhx,PR# 1084
- 修复(auto_balancer):避免排除主题影响代理负载 ,作者@SCNieh,PR# 1086
- 修复(maven):通过以下方式更正 s3stream 的 maven 构建系统 ,作者@daniel-y,PR# 1089
- 修复(auto_balancer):通过添加缺失的变量初始化 ,作者@SCNieh,PR# 1090
- feat(auto_balancer):通过节流优先级记录网络指标 ,作者@SCNieh,PR# 1093
- feat(MM2):允许通过以下方式轻松定制 MM2 偏移同步/检查点/心跳主题 ,作者@aaron-ai,PR# 1095
- 构建(issues1033):将日志附加器从 DailyRollingFileAppender 切换到 RollingFileAppender ,作者@warr99,PR# 1092
- feat(issues1097):增加超时后的 api 调用超时时间 ,作者@superhx,PR# 1098
- fix(gradle): 通过以下方式指定 netty-tcnative 的分类器 ,作者@Chillax-0v0,PR# 1103
- 修复(s3stream):如果 openssl 不可用,则快速失败 ,作者@Chillax-0v0,PR# 1105
- feat(issues1087):通过添加数据块缓存 ,作者@superhx,PR# 1107
- 修复(docker):使用特定的 localstack 版本;通过以下方式更新 aws-cli 版本 ,作者@mooc9988,PR# 1108
- feat(auto_balancer): 拆分和合并交换操作 ,作者@SCNieh,PR# 1109
- chore(util):在调用带有“--version”的脚本时打印提交 ID,就像以前一样 ,作者@Chillax-0v0,PR# 1110
- fix(bin): 支持在Windows下运行 ,作者@Chillax-0v0,PR# 1112
- feat(issues1087):添加流阅读器 ,作者@superhx,PR# 1114
- feat(auto_balancer): 支持集群模型中的 broker rack ,作者@SCNieh,PR# 1115
- feat(issues1087):添加流阅读器 ,作者@superhx,PR# 1116
- 修复(issues1087):任务失败后事件循环拒绝任务 ,作者@superhx,PR# 1117
- 修复(issues1087):修复长期运行的问题 ,作者@superhx,PR# 1118
- 修复(issues1087):修复对象不存在句柄 ,作者@superhx,PR# 1119
- 修复(核心):修复交易验证中的竞争问题 ,作者@ShadowySpirits,PR# 1121
- feat(issues1087):添加冷停机时间以重置预读 ,作者@superhx,PR# 1123
- feat(issue1120):支持在控制器中检测慢速代理 ,作者@SCNieh,PR# 1122
- docs(config):通过以下方式完善与指标相关的配置文档 ,作者@SCNieh,PR# 1125
- feat(issue1120):支持在 AutoBalancerMetricsReporter 中报告代理指标 ,作者@SCNieh,PR# 1124
- feat(issues1087):当缓存可用时允许预读 ,作者@superhx,PR# 1126
- fix(metrics): 修复方法名称 ,作者@SCNieh,PR# 1129
- feat(issues1087):将 s3.object.block.size 默认值从 1MB 设置为 512KB ,作者@superhx,PR# 1130
- 琐事:更新 README.md ,作者@KaimingWan,PR# 1131
- feat(metrics): 使用增量值来报告百分位指标 ,作者@SCNieh,PR# 1132
- feat(issues1087):当缓存未命中时增加预读大小 ,作者@superhx,PR# 1133
- 修复(issues1127):修复 1.0 至 1.1-rc0 启动失败 ,作者@superhx,PR# 1128
- 修复(指标):删除冗余错误日志 ,作者@SCNieh,PR# 1135
- chore(grafana): 修复损坏的面板 ,作者@SCNieh,PR# 1136
- 修复(issues1142):当对象不存在时重试获取索引 ,作者@superhx,PR# 1143
- feat(auto_balancer): 支持客户端 ACL 配置 ,作者@SCNieh,PR# 1146
- 修复(核心):通过以下方式写入流对象时组合未来结果 ,作者@SCNieh,PR# 1147
- feat(issue1144):在需要时提前启动下一次压缩 ,作者@SCNieh,PR# 1148
- 修复(issues1097):指定清理/次要/主要流对象压缩…通过 ,作者@superhx,PR# 1149
- 修复(issues1140):修复 S3ObjectControlManager NPE ,作者@superhx,PR# 1151
- 修复(auto_balancer):通过以下方式抑制 OutOfOrderSequenceException 的错误日志 ,作者@SCNieh,PR# 1154
- 恢复“修复(issues1140):修复 S3ObjectControlManager NPE” ,作者@superhx,PR# 1157
- feat(s3stream):将校验和算法更改为 crc32c ,作者@ShadowySpirits,PR# 1155
- 琐事:更新自述文件并添加比较 ,作者@KaimingWan,PR# 1141
- 修复(issues1140):修复 S3ObjectControlManager NPE ,作者@superhx,PR# 1158
- 杂务:调整表格和云支持的徽章 ,作者@KaimingWan,PR# 1162
- feat(s3stream):减少流对象压缩写入放大 ,作者@superhx,PR# 1159
- feat(throttle): 从总可用令牌中减去额外的令牌 ,作者@SCNieh,PR# 1163
- feat(throttle):添加构造函数以实现兼容性 ,作者@SCNieh,PR# 1164
- 修复(issues1072):修复 MultiPartWriterTest 不稳定测试 ,作者@warr99,PR# 1165
- 修复(s3stream):通过精确记录获取对象指标 ,作者@superhx,PR# 1170
- chore: 支持一行快速启动 ,作者@KaimingWan,PR# 1168
- feat(issues1171):通过以下方式提高对象删除性能 ,作者@superhx,PR# 1172
- feat(s3stream): 通过以下方式加速块缓存获取对象 ,作者@superhx,PR# 1167
- feat(auto_balancer): 通过以下方式减少调度过程中大量小对象的复制 ,作者@SCNieh,PR# 1176
- 修复(auto_balancer):添加客户端 ACL 以加载检索器消费者 ,作者@SCNieh,PR# 1182
- feat(issue1179):通过以下方式加速负载平衡中的分区重新分配 ,作者@SCNieh,PR# 1181
- 琐事:更新自述文件 ,作者@KaimingWan,PR# 1183
- chore:更新 README.md 以获得更准确的描述 ,作者@daniel-y,PR# 1185
- feat(issues1169):优化分区重新分配逻辑,避免出现 NotLeaderOrFollowerException ,作者@superhx,PR# 1180
- feat(s3stream): 主动驱逐过期数据 ,作者@superhx,PR# 1186
- feat(auto_balancer):当 sendi 失败时将日志级别更改为警告…通过 ,作者@SCNieh,PR# 1188
- style(auto_balancer): 删除未使用的导入 ,作者@SCNieh,PR# 1189
- feat(issue668):暂时禁用交换操作 ,作者@SCNieh,PR# 1190
- feat(auto_balancer):添加缺少的操作日志 ,作者@SCNieh,PR# 1194
- chore(readme):从比较表中删除控制器,并将 Pulsar 的代理标记为可选 ,作者@daniel-y,PR# 1197
- feat(issue1195):通过以下方式引入进球组来计算不同规模的进球得分 ,作者@SCNieh,PR# 1196
- 修复(issue1198):使用时间线结构来避免不正确的 s3 对象大小 ,作者@SCNieh,PR# 1199
- feat(s3stream): 通过以下方式将标签添加到流中 ,作者@superhx,PR# 1200
- 琐事(控制器):更多日志 ,作者@Chillax-0v0,PR# 1201
- feat(test): 为 s3stream 添加 e2e 测试 ,作者@ShadowySpirits,PR# 1204
- feat(auto_balancer):优化资源类型,提高可扩展性 ,作者@SCNieh,PR# 1206
- chore(cicd):删除 GitHub 发布工作流中的 site-docs 文件 ,作者@Gezi-lzq,PR# 1207
- feat(issues1169):当代理关闭时,防止重新打开分区 ,作者@superhx,PR# 1210
- feat:在 GitHub 中更新 AWS S3 bucket 和目标目录发布… by ,作者@Gezi-lzq,PR# 1211
- 修复(s3stream):修复元数据重放延迟时流读取器忙循环 ,作者@superhx,PR# 1215
- feat(issues1174):清理控制器删除的主题 ,作者@superhx,PR# 1213
- chore(log): 通过以下方式将 stream_id 重命名为 streamId ,作者@superhx,PR# 1216
- feat(metrics): 支持记录慢速读取吞吐量 ,作者@SCNieh,PR# 1217
- 重构:重命名 dockerhub repo 和 docker 路径 ,作者@Gezi-lzq,PR# 1218
- feat(cicd):将确定图像标签步骤添加到 Docker 发布工作流程中 ,作者@Gezi-lzq,PR# 1208
- feat(auto_balancer):重构集群模型,提高可扩展性 ,作者@SCNieh,PR# 1220
- chore(log):将流隔离日志转换为警告级别 ,作者@superhx,PR# 1219
- 修复(issues1222):修复 #openStream resp nextOffset ,作者@superhx,PR# 1224
- feat(s3stream):通过以下方式添加超时读取请求完成时的日志 ,作者@SCNieh,PR# 1227
- 琐事:完善 readme 中的大量徽章 ,作者@daniel-y,PR# 1228
- 修复(s3stream/wal):通过以下方式检查恢复过程中记录的周期 ,作者@Chillax-0v0,PR# 1229
- 琐事:使用 AutoMQ 的新架构 gif 完善自述文件 ,作者@daniel-y,PR# 1233
- feat(issue1231):支持 AutoBalancer 中的历史指标测量 ,作者@SCNieh,PR# 1232
- fix(log): 修复打开流检查器 ,作者@superhx,PR# 1235
- feat(s3stream/wal): 到达窗口后恢复更多记录 ,作者@Chillax-0v0,PR# 1234
- feat(s3stream/wal): 在恢复工具中打印更多信息 ,作者@Chillax-0v0,PR# 1236
- 修复(s3stream):避免在故障转移期间启动 wal 两次 ,作者@Chillax-0v0,PR# 1237
- chore(log):通过以下方式将 kafka.log 日志从 stdout 中隔离出来 ,作者@superhx,PR# 1239
- feat(metadata): 通过以下方式添加分区流关系 ,作者@superhx,PR# 1241
- feat(issues1153):分区状态自检 ,作者@superhx,PR# 1238
- 杂务:指示如何在贡献指南中挑选问题 ,作者@KaimingWan,PR# 1242
- chore:在如何贡献中添加帮助信息 ,作者@KaimingWan,PR# 1243
- feat(issues1225):通过以下方式增强 s3 api 测试 ,作者@warr99,PR# 1240
- feat(issues1153):添加分区状态统计指标 ,作者@superhx,PR# 1245
- feat(metadata):修复关闭并重新打开协调器分区时的数据竞争问题 ,作者@ShadowySpirits,PR# 1246
- 修复(issues1248):修复分区重新分配死锁 ,作者@superhx,PR# 1249
- feat(cli): 通过以下方式初始化 cli 模块 ,作者@ShadowySpirits,PR# 1252
- 修复(issues1253):修复重复的 Tracker#close 失败 ,作者@superhx,PR# 1254
- fix(metadata): 修复潜在的数据竞争 ,作者@ShadowySpirits,PR# 1257
- feat(cli): 通过以下方式引入 stream 命令 ,作者@ShadowySpirits,PR# 1256
- 修复(元数据):合并 cli 模块和 kshell-sdk 模块 ,作者@ShadowySpirits,PR# 1258
- feat(s3stream):增强增量直方图 ,作者@superhx,PR# 1261
- fix(metadata):确保消费者偏移量随着主题的删除而被删除 ,作者@ShadowySpirits,PR# 1262
- fix(metadata):清理已删除分区的消耗偏移量 ,作者@ShadowySpirits,PR# 1264
- feat(auto_balancer): 使 AbstractTimeWindowSamples 可扩展 ,作者@SCNieh,PR# 1266
- 修复(s3stream):添加缺失的指标记录 ,作者@SCNieh,PR# 1268
- 杂务:优化文档 ,作者@KaimingWan,PR# 1267
- feat(s3stream): 优化网络速率限制器以提高精度 ,作者@SCNieh,PR# 1269
- feat(tools): 运行性能测试的工具 ,作者@Chillax-0v0,PR# 1270
- 修复(issues1276):按 nodeId 和 apiKey 对批量请求进行分组 ,作者@superhx,PR# 1277
- 修复(auto_balancer):重新分配时重置分区模型 ,作者@SCNieh,PR# 1279
- 修复(auto_balancer):通过以下方式防止报告封闭分区的指标 ,作者@SCNieh,PR# 1281
- feat(tools/perf): 追赶读取基准测试 ,作者@Chillax-0v0,PR# 1283
- feat(issues1273):优化自述文件以包含更多部署选项 ,作者@amos201600,PR# 1275
- 修复(核心):定期清理潜在泄漏的分区级指标 ,作者@SCNieh,PR# 1284
- fix(s3stream): 修复流缺少标签的问题 ,作者@superhx,PR# 1285
- feat(cli): 添加强制关闭流命令 ,作者@ShadowySpirits,PR# 1260
- feat(auto_balancer):引入公制版本以实现向后兼容 ,作者@SCNieh,PR# 1288
- feat(core): 添加分区级别生产/获取请求计数指标 ,作者@SCNieh,PR# 1291
- feat(tools/perf): 通过以下方式优化用户体验 ,作者@Chillax-0v0,PR# 1292
- feat(shell): 添加 s3 日志附加器 ,作者@ShadowySpirits,PR# 1293
- 琐事:删除误导性贡献文件 ,作者@KaimingWan,PR# 1295
- fix(log): 回滚日志配置 ,作者@superhx,PR# 1297
- 修复(issues1296):修复潜在的 stackoverflow ,作者@superhx,PR# 1298
- 修复(issues1300):修复流读取器空块 ,作者@superhx,PR# 1301
- fix(auto_balancer):通过以下方式修复竞争条件 ,作者@SCNieh,PR# 1299
- 修复(issues1302):阻止 bytebuf 泄漏 ,作者@superhx,PR# 1303
- 修复(日志):预读错误 ,作者@superhx,PR# 1304
- feat(shell): 添加 s3 指标导出器 ,作者@ShadowySpirits,PR# 1294
- 修复(issues1222):修复流提前检查 ,作者@superhx,PR# 1306
- 修复(auto_balancer):避免计算不支持的目标的动作分数 ,作者@SCNieh,PR# 1305
- feat: 在恢复过程中遇到无效流时,首先关闭有效流 ,作者@Chillax-0v0,PR# 1308
- 修复(issues1302):修复 StreamReader buf LEAK ,作者@superhx,PR# 1311
- chore(log):更改静音取消静音日志级别 ,作者@superhx,PR# 1312
- feat: 支持更多自定义 SASL 处理程序 ,作者@mooc9988,PR# 1313
- feat(核心):在代理围栏上使用负载感知分区选择器 ,作者@SCNieh,PR# 1314
- chore:启用 join slack ,作者@KaimingWan,PR# 1309
- feat(auto_balancer): 支持为 AutoBalancer 客户端指定 broker 监听器名称 ,作者@SCNieh,PR# 1316
- docs(telemetry):删除未使用的配置 ,作者@SCNieh,PR# 1318
- feat(shell): 添加 s3 日志上传器 ,作者@ShadowySpirits,PR# 1317
- chore(log): 抑制由流围栏引起的打开失败错误 ,作者@superhx,PR# 1319
- feat(shell): 添加 LogRecorder 接口以适应其他日志框架 ,作者@ShadowySpirits,PR# 1320
- chore(s3stream):记录上传 WAL 的阶段性持续时间 ,作者@Chillax-0v0,PR# 1321
- 修复(s3stream):通过以下方式压缩流对象时发生异常并释放缓冲区 ,作者@SCNieh,PR# 1322
- feat(shell): 为日志和指标报告添加抖动 ,作者@ShadowySpirits,PR# 1323
- feat(server): 使 kafka 更具可扩展性 ,作者@Chillax-0v0,PR# 1329
- feat(shell): 通过添加重新创建命令 ,作者@ShadowySpirits,PR# 1327
- feat(shell): 通过以下方式优化关闭钩子 ,作者@ShadowySpirits,PR# 1330
- 修复(指标):避免使用未初始化的计数器指标 ,作者@SCNieh,PR# 1331
- feat(shell): 清理一些代码 ,作者@ShadowySpirits,PR# 1332
- 修复(性能):增加管理客户端的请求超时时间 ,作者@Chillax-0v0,PR# 1337
- feat(core): 转发流 apis ,作者@ShadowySpirits,PR# 1341
- feat(core): 添加命令配置 ,作者@ShadowySpirits,PR# 1343
- fix(auto_balancer): 修复 broker 状态改变 ,作者@SCNieh,PR# 1345
- feat(metadata):为旧流添加缺失的标签 ,作者@superhx,PR# 1347
- feat(shell): 删除 automq cli ,作者@ShadowySpirits,PR# 1356
- perf(s3stream/allocator):增加 netty 分配器的主干大小 ,作者@Chillax-0v0,PR# 1363
- 修复(issues1357):修复从快照加载时丢失的删除问题 ,作者@superhx,PR# 1359
- chore(log): 修复日志 ,作者@superhx,PR# 1366
- feat(shell): 为 automq cli 添加基本命令 ,作者@ShadowySpirits,PR# 1371
- 修复(issues1367):流读取器阻止添加无效块 ,作者@superhx,PR# 1373
- 修复(核心):当附加非零序列号且生产者快照为空时,增加容忍延迟 ,作者@SCNieh,PR# 1377
- 修复(缓存):修复当用户读取速度快于预读时读头失败的问题 ,作者@superhx,PR# 1383
- 修复(issues604):修复响应大小不匹配的问题 ,作者@superhx,PR# 1393
- feat(tools/perf):在预热和追赶过程中调整发送速率 ,作者@Chillax-0v0,PR# 1394
- chore(gradle):将 kafka 版本更改为 3.7.0 ,作者@superhx,PR# 1397
- fix(action): 修复发布操作 ,作者@superhx,PR# 1398
关于我们

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
🔥🔥🔥version-manager 最好用的 SDK 版本管理器,v0.6.2 发布
项目地址:https://github.com/gvcgo/version-manager 中文文档:https://gvcgo.github.io/vdocs/#/zh-cn/introduction 功能特点: 跨平台,支持Windows,Linux,MacOS 支持多种语言和工具,省心 受到lazygit的启发,拥有更友好的TUI,更符合直觉,且无需记忆任何命令 支持针对项目锁定SDK版本,使用cd命令切换到项目目录时,自动切换到锁定的SDK版本 支持反向代理/本地代理设置,提高国内用户下载体验 相比于其他SDK管理器,拥有更优秀的架构设计,响应更快,稳定性更高 无需麻烦的插件,开箱即用 无需docker,纯本地安装,效率更高 更高的可扩展性,甚至可以通过使用conda来支持数以千计的应用 竞品对比: fnm, nvm, gvm, pyenv, phpenv等,只支持单一语言,界面简陋,命令复杂。 asdf-vm, mise, sdkman等,虽然支持多种语言,但要么对windows支持不够好,要么支持的语言有限,而且命令和概念复杂。 vfox, 模仿asdf-vm,采用go+l...
- 下一篇
🎉 领域驱动设计 - 模型即服务 | Wow 3.8.1 发布
领域驱动|事件驱动|测试驱动|声明式设计|响应式编程|命令查询职责分离|事件溯源 官方文档:https://wow.ahoo.me/ 更新内容 提升重写查询过滤器、查询结果的便捷性! 特性(query): 添加RewritableCondition以提升重写查询过滤器的便捷性。 特性(query): 为SnapshotQueryContext添加rewriteQuery、rewriteResult以提升重写查询过滤器的便捷性。 依赖(dashboard): 更新zone.js到v0.14.7 重写查询请求( rewriteQuery) 主要用于数据权限场景 context.rewriteQuery { query -> val warehouseIdCondition = condition { nestedState() WarehouseIdCapable::warehouseId.name eq warehouseId } query.appendCondition(warehouseIdCondition) } 重写查询结果(rewriteResult) ...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- Linux系统CentOS6、CentOS7手动修改IP地址
- 2048小游戏-低调大师作品
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- CentOS8安装MyCat,轻松搞定数据库的读写分离、垂直分库、水平分库
- CentOS8编译安装MySQL8.0.19
- CentOS6,CentOS7官方镜像安装Oracle11G
- CentOS7,8上快速安装Gitea,搭建Git服务器
- SpringBoot2整合Thymeleaf,官方推荐html解决方案
- MySQL8.0.19开启GTID主从同步CentOS8
- SpringBoot2更换Tomcat为Jetty,小型站点的福音