跳转至

下载

3.5.1 是最新版本。当前稳定版本是3.5.1

您可以按照这些过程并使用这些密钥来验证您的下载。

3.5.1

Kafka 3.5.1是一个安全补丁版本。它包含安全修复和回归修复。有关更多信息，请阅读我们的博客文章 和详细的发行说明。

3.5.0

Kafka 3.5.0 包含大量新功能和修复。有关更多信息，请阅读我们的博客文章 和详细的发行说明。

3.4.1

自 3.4.0 发布以来，Kafka 3.4.1 修复了 58 个问题。欲了解更多信息，请阅读详细的发行说明

3.4.0

Kafka 3.4.0 包含大量新功能和修复。有关更多信息，请阅读我们的博客文章 和详细的发行说明。

3.3.2

自 3.3.1 发布以来，Kafka 3.3.2 修复了 20 个问题。欲了解更多信息，请阅读详细的发行说明

3.3.1

Kafka 3.3.1 包含许多重要的新功能。以下是一些显着变化的摘要：

  • KIP-833：将 KRaft 标记为生产就绪
  • KIP-778：KRaft 到 KRaft 的升级
  • KIP-835：监控 KRaft 控制器仲裁健康状况
  • KIP-794：严格统一的粘性分区器
  • KIP-834：暂停/恢复 KafkaStreams 拓扑
  • KIP-618：对源连接器的 Exactly-Once 支持

有关更多信息，请阅读详细的3.3.1和3.3.0发行说明。

3.3.0

在将工件推送到 Apache 和 Maven 中心之后但在发布公告之前，在 3.3.0 版本中发现了一个重大错误。因此，我们决定不发布 3.3.0，而是发布包含修复程序的 3.3.1。建议不要使用3.3.0。

3.2.3

Kafka 3.2.3 修复了CVE-2022-34917以及自 3.2.1 版本以来的其他 7 个问题。欲了解更多信息，请阅读详细的发行说明。

3.2.2

在将工件推送到 Maven 中心之后但在发布公告之前，在 3.2.2 版本中发现了一个重大错误。因此，我们决定不发布 3.2.2，并发布包含修复程序的 3.2.3。建议不要使用3.2.2。

3.2.1

自 3.2.0 发布以来，Kafka 3.2.1 修复了 13 个问题。欲了解更多信息，请阅读详细的发行说明。

3.2.0

Kafka 3.2.0 包含许多重要的新功能。以下是一些显着变化的摘要：

  • log4j 1.x 替换为 reload4j
  • KRaft 标准授权器 (KIP-801)
  • 向分区领导者发送提示以恢复分区（KIP-704）
  • DescribeLogDirsResponse 中的顶级错误代码字段 (KIP-784)
  • kafka-console- Producer写入标头和空值（KIP-798和KIP-810）
  • JoinGroupRequest 和 LeaveGroupRequest 附加了原因 (KIP-800)
  • 静态成员协议让领导者跳过分配（KIP-814）
  • Kafka Streams 中的机架感知备用任务分配 (KIP-708)
  • 交互式查询 v2（KIP-796、KIP-805 和 KIP-806）
  • Connect API 列出所有连接器插件并检索其配置 (KIP-769)
  • TimestampConverter SMT 支持不同的 Unix 时间精度 (KIP-808)
  • 连接源任务处理生产者异常 (KIP-779)

欲了解更多信息，请阅读详细的发行说明。

3.1.2

Kafka 3.1.2 修复了自 3.1.1 版本以来的CVE-2022-34917和其他 4 个问题。欲了解更多信息，请阅读详细的发行说明。

3.1.1

自 3.1.0 发布以来，Kafka 3.1.1 修复了 29 个问题。欲了解更多信息，请阅读详细的发行说明。

3.1.0

Kafka 3.1.0 包含许多重要的新功能。以下是一些显着变化的摘要：

  • Apache Kafka 支持 Java 17
  • FetchRequest 支持主题 ID (KIP-516)
  • 通过支持 OIDC (KIP-768) 扩展 SASL/OAUTHBEARER
  • 添加代理计数指标 (KIP-748)
  • 区分以毫秒和纳秒为单位测量的一致公制延迟 (KIP-773)
  • 不推荐使用急切的重新平衡协议 (KAFKA-13439)
  • 将 TaskId 字段添加到 StreamsException (KIP-783)
  • 外键连接中的自定义分区器 (KIP-775)
  • 使用 SessionStore/WindowStore 的开放端点获取/findSessions 查询 (KIP-766)
  • 具有开放端点的范围查询（KIP-763）
  • 将总阻塞时间指标添加到 Streams (KIP-761)
  • 添加额外的配置来控制 MirrorMaker2 内部主题命名约定 (KIP-690)

欲了解更多信息，请阅读详细的发行说明。

3.0.2

Kafka 3.0.2 修复了CVE-2022-34917以及自 3.0.1 版本以来的其他 10 个问题。欲了解更多信息，请阅读详细的发行说明。

3.0.1

自 3.0.0 发布以来，Kafka 3.0.1 修复了 29 个问题。欲了解更多信息，请阅读详细的发行说明。

3.0.0

Kafka 3.0.0 包含许多重要的新功能。以下是一些显着变化的摘要：

  • 不再支持 Java 8 和 Scala 2.12
  • Kafka Raft 对元数据主题快照的支持以及自我管理仲裁的其他改进
  • 默认情况下为 Kafka 生产者提供更强的交付保证
  • 弃用消息格式 v0 和 v1
  • OffsetFetch 和 FindCoordinator 请求的优化
  • 更灵活的 Mirror Maker 2 配置和弃用 Mirror Maker 1
  • 能够在 Kafka Connect 中的单个调用中重新启动连接器的任务
  • 现在默认启用连接器日志上下文和连接器客户端覆盖
  • Kafka Streams 中时间戳同步的增强语义
  • 改进了 Stream 的 TaskId 的公共 API
  • Kafka 中默认 serde 变为 null

欲了解更多信息，请阅读详细的发行说明。

2.8.2

Kafka 2.8.2 修复了CVE-2022-34917以及自 2.8.1 版本以来的其他 11 个问题。欲了解更多信息，请阅读详细的发行说明。

2.8.1

自 2.8.0 发布以来，Kafka 2.8.1 修复了 49 个问题。欲了解更多信息，请阅读详细的发行说明。

2.8.0

Kafka 2.8.0 包含许多重要的新功能。以下是一些显着变化的摘要：

  • 使用自我管理的法定人数替换 ZooKeeper 的早期访问
  • 添加描述集群API
  • 支持 SASL_SSL 侦听器上的相互 TLS 身份验证
  • JSON 请求/响应调试日志
  • 限制代理连接创建速率
  • 主题标识符
  • 在 Connect REST API 中公开任务配置
  • 更新 Streams FSM 以阐明 ERROR 状态含义
  • 扩展 StreamJoined 以允许更多存储配置
  • 更方便的 TopologyTestDriver 构造器
  • 引入 Kafka-Streams 特定的未捕获异常处理程序
  • 用于启动和关闭 Streams 线程的 API
  • 改进 TimeWindowedDeserializer 和 TimeWindowedSerde 以处理窗口大小
  • 改进 Kafka Streams 中的超时和重试

欲了解更多信息，请阅读详细的发行说明。

2.7.2

自 2.7.1 版本以来，Kafka 2.7.2 修复了 26 个问题。欲了解更多信息，请阅读详细的发行说明。

2.7.1

自 2.7.0 发布以来，Kafka 2.7.1 修复了 45 个问题。欲了解更多信息，请阅读详细的发行说明。

2.7.0

Kafka 2.7.0 包含许多重要的新功能。以下是一些显着变化的摘要：

  • 可配置的 TCP 连接超时并改进初始元数据获取
  • 强制代理范围内和每个侦听器的连接创建率（KIP-612，第 1 部分）
  • 限制创建主题、创建分区和删除主题操作
  • 将 TRACE 级端到端延迟指标添加到 Streams
  • 添加代理端SCRAM配置API
  • 支持PEM格式的SSL证书和私钥
  • 将 RocksDB 内存消耗添加到 RocksDB 指标中
  • 添加对聚合的滑动窗口支持

欲了解更多信息，请阅读详细的发行说明。

2.6.3

自 2.6.2 版本以来，Kafka 2.6.3 修复了 11 个问题。欲了解更多信息，请阅读详细的发行说明。

2.6.2

自 2.6.1 发布以来，Kafka 2.6.2 修复了 35 个问题。欲了解更多信息，请阅读详细的发行说明。

2.6.1

自 2.6.0 发布以来，Kafka 2.6.1 修复了 41 个问题。欲了解更多信息，请阅读详细的发行说明。

2.6.0

Kafka 2.6.0 包含许多重要的新功能。以下是一些显着变化的摘要：

  • Java 11 或更高版本默认启用 TLSv1.3
  • 显着的性能改进，尤其是当代理有大量分区时
  • 平滑扩展 Kafka Streams 应用程序
  • Kafka Streams 支持更改时发出
  • 新指标可提供更好的运营洞察力
  • Kafka Connect 可以在配置时自动为源连接器创建主题
  • 改进了 Kafka Connect 中接收器连接器的错误报告选项
  • Kafka Connect 中的新过滤器和条件 SMT
  • `client.dns.lookup` 配置的默认值现在是 `use_all_dns_ips`
  • 将Zookeeper升级到3.5.8

欲了解更多信息，请阅读详细的发行说明。

2.5.1

自 2.5.0 发布以来，Kafka 2.5.1 修复了 72 个问题。欲了解更多信息，请阅读详细的发行说明。

2.5.0

Kafka 2.5.0 包含许多重要的新功能。以下是一些显着变化的摘要：

  • TLS 1.3 支持（1.2 现在是默认值）
  • Kafka Streams 的联合组
  • Kafka Consumer 的增量再平衡
  • 新指标可提供更好的运营洞察力
  • 将Zookeeper升级到3.5.7
  • 弃用对 Scala 2.11 的支持

欲了解更多信息，请阅读详细的发行说明。

2.4.1

欲了解更多信息，请阅读详细的发行说明。

2.4.0

Kafka 2.4.0 包含许多重要的新功能。以下是一些显着变化的摘要：

  • 允许消费者从最近的副本获取数据。
  • 支持消费者再平衡协议的增量合作再平衡。
  • MirrorMaker 2.0 (MM2)，一种新的多集群、跨数据中心复制引擎。
  • 新的 Java 授权者接口。
  • 支持 KTable 中的非键连接。
  • 用于副本重新分配的管理 API。

欲了解更多信息，请阅读详细的发行说明。

2.3.1

欲了解更多信息，请阅读详细的发行说明。

2.3.0

Kafka 2.3.0 包含许多重要的新功能。以下是一些显着变化的摘要：

  • Kafka Connect REST API 进行了多项改进。
  • Kafka Connect 现在支持增量协作再平衡。
  • Kafka Streams 现在支持内存中会话存储和窗口存储。
  • AdminClient 现在允许用户确定他们有权对主题执行哪些操作。
  • 有一个新的代理启动时间指标。
  • JMXTool 现在可以连接到安全的 RMI 端口。
  • 添加了增量 AlterConfigs API。旧的 AlterConfigs API 已被弃用。
  • 我们现在跟踪低于其最小 ISR 计数的分区。
  • 即使在代理上启用了自动主题创建，消费者现在也可以选择退出。
  • Kafka 组件现在可以使用外部配置存储（KIP-421）。
  • 我们改进了遇到错误时的副本获取器行为。

欲了解更多信息，请阅读详细的发行说明。

2.2.2

2.2.1

2.2.0

Kafka 2.2.0 包含许多重要的新功能。以下是一些显着变化的摘要：

  • 添加了对自定义主体名称的 SSL 支持
  • 允许 SASL 连接定期重新验证
  • 命令行工具bin/kafka-topics.sh添加了 AdminClient 支持
  • 改进的消费者组管理：默认值group.id而null不是空字符串
  • API改进：
    • 制作人：介绍close(Duration)
    • 管理客户端：介绍close(Duration)
    • Kafka Streams：flatTransform()Streams DSL 中的新运算符
    • KafkaStreams（和其他类别）现在实现AutoClosable支持 try-with-resource
    • 新的 Serdes 和默认方法实现
  • Kafka Streams 暴露内部client.id通过ThreadMetadata
  • 指标改进：所有-min,-avg和-max指标现在将输出NaN为默认值

欲了解更多信息，请阅读详细的发行说明。

2.1.1

2.1.0

Kafka 2.1.0 包含许多重要的新功能。以下是一些显着变化的摘要：

  • Java 11 支持
  • 支持 Zstandard，可实现与 gzip 相当的压缩，并具有更高的压缩速度，尤其是解压缩速度 (KIP-110)
  • 避免活跃消费者组的承诺抵消过期 (KIP-211)
  • 在 Producer 中提供直观的用户超时 (KIP-91)
  • Kafka 的复制协议现在支持改进的僵尸防护。以前，在某些罕见的情况下，如果代理从 Zookeeper 分区，但不从集群的其余部分分区，那么复制分区的日志可能会出现分歧，并在最坏的情况下导致数据丢失 (KIP-320)。
  • Streams API 改进（KIP-319、KIP-321、KIP-330、KIP-353、KIP-356）
  • 管理脚本和管理客户端 API 改进，以简化管理操作（KIP-231、KIP-308、KIP-322、KIP-324、KIP-338、KIP-340）
  • DNS 处理改进（KIP-235、KIP-302）

欲了解更多信息，请阅读详细的发行说明。

2.0.1

2.0.0

Kafka 2.0.0 包含许多重要的新功能。以下是一些显着变化的摘要：

  • KIP-290 增加了对前缀 ACL 的支持，简化了大型安全部署中的访问控制管理。现在可以使用单个规则授予对带有前缀的主题、消费者组或事务 ID 的批量访问权限。主题创建的访问控制也得到了改进，可以授予创建特定主题或带有前缀的主题的访问权限。
  • KIP-255 添加了一个使用 OAuth2 不记名令牌对 Kafka 代理进行身份验证的框架。SASL/OAUTHBEARER 实现可使用用于令牌检索和验证的回调进行自定义。
  • 现在默认为 SSL 连接启用主机名验证，以确保默认 SSL 配置不易受到中间人攻击。如果需要，您可以禁用此验证。
  • 您现在可以动态更新 SSL 信任库，而无需重新启动代理。您还可以在启动代理之前在 ZooKeeper 中配置代理侦听器的安全性，包括 SSL 密钥库和信任库密码以及 SASL 的 JAAS 配置。借助此新功能，您可以将敏感密码配置以加密形式存储在 ZooKeeper 中，而不是以明文形式存储在代理属性文件中。
  • 复制协议已得到改进，以避免在快速领导者故障转移期间领导者和追随者之间的日志分歧。我们还通过减少消息下转换的内存占用来提高代理的弹性。通过使用消息分块，内存使用量和内存引用时间均已减少，以避免代理中出现 OutOfMemory 错误。
  • 现在，启用配额后，在应用任何限制之前，Kafka 客户端都会收到有关限制的通知。这使客户端能够在超出配额时区分网络错误和大节流时间。
  • 我们为 Kafka 消费者添加了一个配置选项，以避免消费者无限期阻塞。
  • 我们放弃了对 Java 7 的支持，并删除了之前弃用的 Scala 生产者和消费者。
  • Kafka Connect 包含许多改进和功能。KIP-298 使您能够通过启用自动重试并控制连接器停止之前允许的错误数量来控制如何处理连接器、转换和转换器中的错误。日志中可以包含更多上下文信息，以帮助诊断问题，并且接收器连接器消耗的有问题的消息可以发送到死信队列，而不是强制连接器停止。
  • KIP-297 添加了一个新的扩展点，可将机密移出连接器配置并与任何外部密钥管理系统集成。连接器配置中的占位符仅在将配置发送到连接器之前解析，确保机密在您的首选密钥管理系统中安全地存储和管理，并且不会通过 REST API 或日志文件公开。
  • 我们为 Kafka Streams DSL 添加了一个精简的 Scala 包装器 API，它在编译时提供更好的类型推断和更好的类型安全性。Scala 用户可以在代码中使用更少的样板文件，尤其是使用新的隐式 Serdes 的 Serdes。
  • Kafka Streams Processor API 现在支持消息标头，允许用户添加和操作从源主题读取的标头并将其传播到接收器主题。
  • 由于新的单键获取 API，Kafka Streams 中的窗口聚合性能得到了很大的改善（有时是一个数量级）。
  • 我们使用 kafka-streams-testutil 工件进一步改进了 Kafka Streams 的单元可测试性。

欲了解更多信息，请阅读详细的发行说明。

1.1.1

1.1.0

Kafka 1.1.0 包含许多重要的新功能。以下是一些显着变化的摘要：

  • Kafka 1.1.0 对 Kafka 控制器进行了重大改进，可加快受控关闭速度。作为这项工作的一部分，ZooKeeper 会话过期边缘情况也已得到修复。
  • 控制器的改进还使得单个集群能够支持更多分区。KIP-227 引入了增量获取请求，在分区数量较大时提供更高效的复制。
  • KIP-113 添加了对日志目录之间副本移动的支持，以实现与 JBOD 的数据平衡。
  • 现在可以动态更新某些代理配置选项（例如 SSL 密钥库），而无需重新启动代理。有关详细信息和动态配置的完整列表，请参阅 KIP-226。
  • Kafka 代理中添加了基于委托令牌的身份验证 (KIP-48)，以支持大量客户端，而不会导致 Kerberos KDC 或其他身份验证服务器过载。
  • Kafka Connect 添加了多项新功能，包括标头支持 (KIP-145)、Connect REST 接口中的 SSL 和 Kafka 集群标识符（KIP-208 和 KIP-238）、连接器名称验证 (KIP-212) 和支持适用于接收器连接器中的主题正则表达式 (KIP-215)。此外，Connect 工作线程的默认最大堆大小已增加至 2GB。
  • Kafka Streams API 中添加了多项改进，包括减少重新分区主题分区占用空间、针对生产故障的可定制错误处理以及增强对代理不可用的恢复能力。详情请参阅 KIP 205、210、220、224 和 239。

欲了解更多信息，请阅读详细的发行说明。

1.0.2

1.0.1

1.0.0

Kafka 1.0.0 不仅仅是版本号的提升。Apache Kafka 项目管理委员会在该版本中包含了许多有价值的增强功能。以下是其中一些的摘要：

  • 自 0.10 版本推出以来，Streams API 已在 Kafka 用户中广受欢迎，包括 Pinterest、Rabobank、Zalando 和 The New York Times 等。在 1.0 中，API 继续以健康的速度发展。首先，构建器 API 已得到改进 (KIP-120)。添加了一个新的 API 以公开运行时活动任务的状态 (KIP-130)。新的 cogroup API 使处理分区聚合变得更加容易，代码中的 StateStore 和移动部件更少 (KIP-150)。通过增强 print() 和 writeAsText() 方法 (KIP-160)，可调试性变得更加容易。如果这还不够，还可以查看 KIP-138 和 KIP-161。有关流的更多信息，请查看Apache Kafka Streams文档，包括一些有用的新教程视频。
  • 大规模操作 Kafka 要求系统保持可观察性，为了使这一点变得更容易，我们对指标进行了许多改进。这些内容太多，无法在不变得乏味的情况下进行总结，但 Connect 指标已得到显着改进 (KIP-196)，现在公开了一系列新的运行状况检查指标 (KIP-188)，而且我们现在有了全局主题和分区计数 ( KIP-168）。查看 KIP-164 和 KIP-187 了解更多信息。
  • 我们现在支持 Java 9，除其他外，还可以显着加快 TLS 和 CRC32C 的实现速度。现在，在线加密速度将会更快，这将使 Kafka 保持快速，并在启用加密时降低计算成本。
  • 为了与安全主题保持一致，KIP-152 清理了简单身份验证安全层 (SASL) 身份验证尝试的错误处理。以前，一些身份验证错误条件与代理故障无法区分，并且没有以明确的方式记录。现在更干净了。
  • Kafka 现在可以更好地容忍磁盘故障。从历史上看，JBOD 存储配置并未被推荐，但该架构仍然很诱人：毕竟，为什么不依靠 Kafka 自己的复制机制来防止存储故障，而不是使用 RAID？借助 KIP-112，Kafka 现在可以更优雅地处理磁盘故障。JBOD 代理中的单个磁盘故障不会导致整个代理瘫痪；相反，代理将继续提供功能磁盘上保留的任何日志文件。
  • 从版本 0.11.0 开始，幂等生产者（即存在事务时使用的生产者，当然也是我们用于一次性处理的生产者）要求 max.in.flight.requests.per.connection 为等于一。任何编写或测试过有线协议的人都可以证明，这对吞吐量设置了上限。感谢 KAFKA-5949，现在可以达到 5 个大小，从而大大放松了吞吐量限制。

欲了解更多信息，请阅读详细的发行说明。

0.11.0.3

0.11.0.2

0.11.0.1

0.11.0.0

0.10.2.2

0.10.2.1

0.10.2.0

0.10.1.1

0.10.1.0

0.10.0.1

0.10.0.0

0.9.0.1

0.9.0.0

0.8.2.2

0.8.2.1

0.8.2.0

0.8.2-测试版

0.8.1.1 发布

0.8.1 发布

0.8.0 发布

0.8.0 Beta1 版本

0.7.2 发布

0.7.1 发布

0.7.0 发布

您可以在此处 下载 0.7.0-incubating 之前的版本。

回到顶部