RHEL 上的 AMQ Streams 2.5 发行注记

AMQ Streams 2.5.x 是 AMQ Streams 的 Long Term Support (LTS)产品。

最新的补丁版本是 AMQ Streams 2.5.2。AMQ Streams 二进制文件已改为 2.5.2 版本。虽然支持的 Kafka 版本被列为 3.5.0，但它包含了 Kafka 3.5.2 的更新和改进。

有关 LTS 术语和日期的详情，请查看 AMQ Streams LTS 支持策略。

AMQ Streams 支持并使用 Apache Kafka 版本 3.5.0。Kafka 3.5.2 的更新会包括在 2.5.2 补丁版本中。仅支持由红帽构建的 Kafka 发行版本。

有关升级说明，请参阅 AMQ Streams 和 Kafka 升级。

如需了解更多信息，请参阅 Kafka 3.5.0、Kafka 3.5.1 和 Kafka 3.5.2 发行注记。

Kafka 3.4.x 仅支持升级到 AMQ Streams 2.5。

Kafka 3.5.x 使用 ZooKeeper 版本 3.6.4，它是 Kafka 3.4.x 的不同版本。建议您执行滚动更新以使用新的二进制文件。

OpenTelemetry 用于分布式追踪已变为 GA。您可以在指定的追踪系统中使用 OpenTelemetry。OpenTelemetry 已经替换了 OpenTracing 以进行分布式追踪。对 OpenTracing 的支持已弃用。

默认情况下，OpenTelemetry 使用 OTLP (OpenTelemetry 协议) exporter 进行追踪。带有 OpenTelemetry 的 AMQ Streams 与 Jaeger exporter 一起使用，但您可以指定 OpenTelemetry 支持的其他追踪系统。AMQ Streams 计划默认迁移到使用 OTLP exporter 的 OpenTelemetry，它支持 Jaeger exporter。

请参阅分布式追踪简介。

AMQ Streams 2.5.x 发行版本支持 Kafka 3.5.0。升级到 2.5.2 补丁版本包含来自 Kafka 3.5.2 的更新和改进。

有关 Kafka 3.5.x 中引入的增强功能概述，请参阅 Kafka 3.5.0、Kafka 3.5.1 和 Kafka 3.5.2 发行注记。

由 AMQ Streams 提供的 Red Hat Single Sign-On 授权器的 KeycloakRBACAuthorizer 已被 KeycloakAuthorizer 替代。新的授权器与 ZooKeeper 集群管理或 KRaft 模式使用 AMQ Streams 兼容。与前面的授权器一样，您可以使用 Red Hat Single Sign-On 提供的 Authorization Services 的 Red Hat Single Sign-On REST 端点，您可以在 Kafka 代理上配置 KeycloakAuthorizer。使用带有 ZooKeeper 集群管理的 AMQ Streams 时仍可使用 KeycloakRBACAuthorizer，但您应该迁移到新的授权器。

现在，您可以使用其他配置从授权服务器管理 OAuth 2.0 授予。

如果您使用 Red Hat Single Sign-On 进行 OAuth 2.0 授权，您可以在 Kafka 代理的授权配置中添加以下属性：

strimzi.authorization.grants.max.idle.time.seconds="300"
strimzi.authorization.grants.gc.period.seconds="300"
strimzi.authorization.reuse.grants="false"

请参阅配置 OAuth 2.0 授权支持。

要在 Kafka 集群中使用 OAuth 2.0 身份验证，您可以使用 OAUTH 身份验证机制指定监听程序配置。在配置侦听器属性时，现在可以使用 JsonPath 查询从正在使用的授权服务器中提取用户名。您可以使用 JsonPath 查询来为 oauth.username.claim 和 oauth.fallback.username.claim 属性在监听器中指定 username extraction 选项。这可让您通过访问嵌套数据结构中的特定值从令牌中提取用户名。例如，您可能有一个包含在 JSON 令牌数据结构中的 user info 数据结构的用户名。

下例演示了如何在使用内省端点配置令牌验证时为属性指定 JsonPath 查询。

# ...
listener.name.client.oauthbearer.sasl.jaas.config=org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required ;
  # ...
  oauth.username.claim="['user.info'].['user.id']" \ 1
  oauth.fallback.username.claim="['client.info'].['client.id']" \ 2
  # ...

请参阅 为 Kafka 代理配置 OAuth 2.0 支持。

Kafka Bridge 的最新版本包括以下更改：

请参阅使用 AMQ Streams Kafka Bridge。

Apache Kafka 处于对 ZooKeeper 的需求。现在，您可以在没有 ZooKeeper 的情况下，以 KRaft (Kafka Raft metadata) 模式部署 Kafka 集群（技术预览）。

目前，AMQ Streams 中的 KRaft 模式有以下主要限制：

请参阅在 KRaft 模式中运行 Kafka。

使用 Kafka Static Quota 插件的技术预览，在 Kafka 集群中的代理上设置吞吐量和存储限制。您可以设置字节阈值和存储配额，以在与代理交互的客户端上放置限制。

client.quota.callback.class= io.strimzi.kafka.quotas.StaticQuotaCallback
client.quota.callback.static.produce= 1000000
client.quota.callback.static.fetch= 1000000
client.quota.callback.static.storage.soft= 400000000000
client.quota.callback.static.storage.hard= 500000000000
client.quota.callback.static.storage.check-interval= 5

请参阅使用 Kafka 静态配额插件设置代理设置限制。

AMQ Streams 2.5.x 中弃用了对 RHEL 7 的支持。AMQ Streams 2.5.x (LTS)是支持 RHEL 7 的最后一个 LTS 版本。

Kafka 3.0.0 和 AMQ Streams 2.0 中已弃用对 Java 8 的支持。AMQ Streams 2.4.0 中删除了对 Java 8 的支持。这适用于所有 AMQ Streams 组件，包括客户端。

AMQ Streams 支持 Java 11 和 Java 17。在开发新应用程序时使用 Java 11 或 17。计划将当前使用 Java 8 的任何应用程序迁移到 Java 11 或 17。

如果您要继续使用 Java 8 一段时间，AMQ Streams 2.2 提供了 Long Term Support (LTS)。有关 LTS 术语和日期的详情，请查看 AMQ Streams LTS 支持策略。

对 OpenTracing 的支持已弃用。

Jaeger 客户端现已停用，OpenTracing 项目存档。因此，我们不能保证其对将来的 Kafka 版本的支持。我们基于 OpenTelemetry 项目推出新的追踪实施。

身份复制策略是 MirrorMaker 2 的一个功能，用于覆盖远程主题的自动重命名。主题不会使用源集群的名称添加名称，而是保留其原始名称。此设置对主动/被动备份和数据迁移场景特别有用。

要实现身份复制策略，您必须在 MirrorMaker 2 配置中指定复制策略类(replication.policy.class)。在以前的版本中，您可以指定 AMQ Streams mirror-maker-2-extensions 组件中包含的 io.strimzi.kafka.connect.mirror.IdentityReplicationPolicy 类。但是，这个组件现已弃用，并将在以后的版本中删除。因此，建议您更新您的实现以使用 Kafka 自己的复制策略类(org.apache.kafka.connect.mirror.IdentityReplicationPolicy)。

请参阅使用带有 MirrorMaker 2 的 AMQ Streams。

Kafka MirrorMaker 在两个或更多活跃 Kafka 集群之间复制数据，并在数据中心之间复制数据。Kafka MirrorMaker 1 在 Kafka 3.0.0 中已弃用，并将在 Kafka 4.0.0 中删除。MirrorMaker 2 将是唯一可用的版本。MirrorMaker 2 基于 Kafka Connect 框架，连接器管理集群之间的数据传输。

因此，在 AMQ Streams 中也弃用了 MirrorMaker 1。如果您使用 MirrorMaker 1 （称为 AMQ Streams 文档中的 MirrorMaker ），请将 MirrorMaker 2 与 IdentityReplicationPolicy 类搭配使用。MirrorMaker 2 将复制的主题重命名为目标集群。IdentityReplicationPolicy 配置会覆盖自动重命名。使用它生成与 MirrorMaker 1 相同的主动/被动单向复制。

请参阅使用带有 MirrorMaker 2 的 AMQ Streams。

AMQ Streams 2.5.2 (Long Term Support)是最新的补丁版本。补丁版本包含 Kafka 3.5.2 更新。

有关 Kafka 3.5.1 和 3.5.2 中修复的问题的详情，请参考 Kafka 3.5.1 和 Kafka 3.5.2 发行注记。

有关 AMQ Streams 2.5.2 中解决问题的更多详细信息，请参阅 AMQ Streams 2.5.x 解决问题。

有关此问题的更多信息，请参阅 Kafka 3.5.2 发行注记。

有关 AMQ Streams 2.5.1 中解决问题的详情，请参阅 AMQ Streams 2.5.x 解决问题。

当在启用了 JMX 身份验证的 FIPS 模式下运行 AMQ Streams 时，客户端可能会失败。要临时解决这个问题，在以 FIPS 模式运行时不要启用 JMX 身份验证。我们正在调查此问题，并在以后进行解决。

以下平台针对在 Red Hat Enterprise Linux (RHEL)发布的版本中使用 Kafka 运行的 AMQ Streams 2.5 测试。

平台使用 Open JDK 11 和 17 测试。IBM JDK 被支持，但不在每个发行版本中定期测试。Open JDK 8、Oracle JDK 8 和 11 和 IBM JDK 8 不被支持。

在 AMQ Streams 中，只支持从 Apache Software Foundation 直接发布的以下组件：

另请参阅 第 11 章 支持的与红帽产品集成。

Kafka 需要块存储；NFS 等文件存储选项不兼容。

AMQ Streams 支持通过 Red Hat Single Sign-On Authorization Services 使用基于 OAuth 2.0 令牌的授权，它允许您集中管理安全策略和权限。

更新于 2024-09-10