第 5 章 开发者预览


Apache Kafka 2.7 的 Streams 中包含的开发人员预览功能。

作为 Kafka 集群管理员,您可以使用 Cluster Operator 部署配置中的功能门切换和关闭功能子集。作为开发人员预览的功能门处于 alpha 程度,默认是禁用的。

重要

开发者预览功能不被红帽产品服务级别协议(SLA)支持,且可能无法完成。因此,红帽不推荐在生产环境中实施任何技术预览功能。此开发者预览功能为您提供对即将推出的产品创新的早期访问,允许您在开发过程中测试并提供反馈。如需有关支持范围的更多信息,请参阅开发者预览支持范围

5.1. Kafka 代理的分层存储

Apache Kafka 的流现在支持 Kafka 代理的分层存储作为开发者预览,允许您引入自定义远程存储解决方案和本地存储。由于其 当前限制,不建议在生产环境中使用。

远程存储配置使用 Kafka 资源中的 kafka.layerStorage 属性来指定。您可以指定一个自定义远程存储管理器来管理分层存储。

自定义分层存储配置示例

kafka:
  tieredStorage:
    type: custom
    remoteStorageManager:
      className: com.example.kafka.tiered.storage.s3.S3RemoteStorageManager
      classPath: /opt/kafka/plugins/tiered-storage-s3/*
      config:
        # remote storage manager configuration 
1

        storage.bucket.name: my-bucket
  config:
    ...
    rlmm.config.remote.log.metadata.topic.replication.factor: 1 
2
Copy to Clipboard Toggle word wrap

1
使用必要的设置配置自定义远程存储管理器。密钥自动作为 rsm.config 前缀,并附加到 Kafka 代理配置中。
2
Apache Kafka 的 Streams 使用 TopicBasedRemoteLogMetadataManager for Remote Log Metadata Management (RLMM)。使用 rlmm.config. 前缀添加 RLMM 配置。
注意

如果要使用自定义分层存储,您必须首先通过构建自定义容器镜像将分层存储插件添加到 Apache Kafka 镜像的 Streams 中。

请参阅分层存储(早期访问)。

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2025 Red Hat