Jump To Close Expand all Collapse all Table of contents 在 OpenShift 中使用 AMQ Streams 使开源包含更多 1. AMQ 流概述 Expand section "1. AMQ 流概述" Collapse section "1. AMQ 流概述" 1.1. Kafka 功能 1.2. Kafka 用例 1.3. AMQ 流如何支持 Kafka 1.4. AMQ Streams Operator Expand section "1.4. AMQ Streams Operator" Collapse section "1.4. AMQ Streams Operator" 1.4.1. Cluster Operator 1.4.2. 主题 Operator 1.4.3. User Operator 1.4.4. AMQ Streams Operator 中的功能门 1.5. AMQ Streams 自定义资源 Expand section "1.5. AMQ Streams 自定义资源" Collapse section "1.5. AMQ Streams 自定义资源" 1.5.1. AMQ Streams 自定义资源示例 1.6. 监听程序配置 1.7. 文档规范 2. 部署配置 Expand section "2. 部署配置" Collapse section "2. 部署配置" 2.1. Kafka 集群配置 Expand section "2.1. Kafka 集群配置" Collapse section "2.1. Kafka 集群配置" 2.1.1. 配置 Kafka 2.1.2. 配置实体 Operator Expand section "2.1.2. 配置实体 Operator" Collapse section "2.1.2. 配置实体 Operator" 2.1.2.1. 实体 Operator 配置属性 2.1.2.2. 主题 Operator 配置属性 2.1.2.3. 用户 Operator 配置属性 2.1.3. Kafka 和 ZooKeeper 存储类型 Expand section "2.1.3. Kafka 和 ZooKeeper 存储类型" Collapse section "2.1.3. Kafka 和 ZooKeeper 存储类型" 2.1.3.1. 数据存储注意事项 Expand section "2.1.3.1. 数据存储注意事项" Collapse section "2.1.3.1. 数据存储注意事项" 2.1.3.1.1. 文件系统 2.1.3.1.2. Apache Kafka 和 ZooKeeper 存储 2.1.3.2. 临时存储 Expand section "2.1.3.2. 临时存储" Collapse section "2.1.3.2. 临时存储" 2.1.3.2.1. 日志目录 2.1.3.3. 持久性存储 Expand section "2.1.3.3. 持久性存储" Collapse section "2.1.3.3. 持久性存储" 2.1.3.3.1. 存储类覆盖 2.1.3.3.2. 持久性卷声明命名 2.1.3.3.3. 日志目录 2.1.3.4. 重新定义持久性卷大小 2.1.3.5. JBOD 存储概述 Expand section "2.1.3.5. JBOD 存储概述" Collapse section "2.1.3.5. JBOD 存储概述" 2.1.3.5.1. JBOD 配置 2.1.3.5.2. JBOD 和持久性卷声明 2.1.3.5.3. 日志目录 2.1.3.6. 将卷添加到 JBOD 存储 2.1.3.7. 从 JBOD 存储中删除卷 2.1.4. 扩展集群 Expand section "2.1.4. 扩展集群" Collapse section "2.1.4. 扩展集群" 2.1.4.1. 扩展 Kafka 集群 Expand section "2.1.4.1. 扩展 Kafka 集群" Collapse section "2.1.4.1. 扩展 Kafka 集群" 2.1.4.1.1. 在集群中添加代理 2.1.4.1.2. 从集群中删除代理 2.1.4.2. 分区重新分配 Expand section "2.1.4.2. 分区重新分配" Collapse section "2.1.4.2. 分区重新分配" 2.1.4.2.1. 重新分配 JSON 文件 2.1.4.2.2. 在 JBOD 卷间重新分配分区 2.1.4.3. 生成重新分配 JSON 文件 2.1.4.4. 手动创建重新分配 JSON 文件 2.1.4.5. 重新分配节流 2.1.4.6. 扩展 Kafka 集群 2.1.4.7. 缩减 Kafka 集群 2.1.5. 用于滚动更新的维护时间窗 Expand section "2.1.5. 用于滚动更新的维护时间窗" Collapse section "2.1.5. 用于滚动更新的维护时间窗" 2.1.5.1. 维护时间窗概述 2.1.5.2. 维护时间窗定义 2.1.5.3. 配置维护时间窗 2.1.6. 从终端连接到 ZooKeeper 2.1.7. 手动删除 Kafka 节点 2.1.8. 手动删除 ZooKeeper 节点 2.1.9. Kafka 集群资源列表 2.2. Kafka Connect/S2I 集群配置 Expand section "2.2. Kafka Connect/S2I 集群配置" Collapse section "2.2. Kafka Connect/S2I 集群配置" 2.2.1. 配置 Kafka 连接 2.2.2. 多个实例的 Kafka Connect 配置 2.2.3. 配置 Kafka Connect 用户授权 2.2.4. 执行 Kafka 连接器重启 2.2.5. 执行 Kafka 连接器任务重启 2.2.6. 从使用 S2I 的 Kafka Connect 迁移到 Kafka Connect 2.2.7. Kafka Connect 集群资源列表 2.2.8. Kafka Connect(S2I)集群资源列表 2.2.9. 与 Debezium 集成以捕获更改数据 2.3. Kafka MirrorMaker 集群配置 Expand section "2.3. Kafka MirrorMaker 集群配置" Collapse section "2.3. Kafka MirrorMaker 集群配置" 2.3.1. Configuring Kafka MirrorMaker 2.3.2. Kafka MirrorMaker 集群资源列表 2.4. Kafka MirrorMaker 2.0 集群配置 Expand section "2.4. Kafka MirrorMaker 2.0 集群配置" Collapse section "2.4. Kafka MirrorMaker 2.0 集群配置" 2.4.1. MirrorMaker 2.0 数据复制 2.4.2. 集群配置 Expand section "2.4.2. 集群配置" Collapse section "2.4.2. 集群配置" 2.4.2.1. 双向复制(主动/主动) 2.4.2.2. 单向复制(主动/被动) 2.4.2.3. 主题配置同步 2.4.2.4. 数据完整性 2.4.2.5. 偏移跟踪 2.4.2.6. 同步消费者组偏移 2.4.2.7. 连接检查 2.4.3. ACL 规则同步 2.4.4. 使用 MirrorMaker 2.0 在 Kafka 集群间同步数据 2.4.5. 执行 Kafka MirrorMaker 2.0 连接器重启 2.4.6. 执行 Kafka MirrorMaker 2.0 连接器任务重启 2.5. Kafka Bridge 集群配置 Expand section "2.5. Kafka Bridge 集群配置" Collapse section "2.5. Kafka Bridge 集群配置" 2.5.1. 配置 Kafka 网桥 2.5.2. Kafka Bridge 集群资源列表 2.6. 自定义 OpenShift 资源 Expand section "2.6. 自定义 OpenShift 资源" Collapse section "2.6. 自定义 OpenShift 资源" 2.6.1. 自定义镜像拉取策略 2.7. 配置 pod 调度 Expand section "2.7. 配置 pod 调度" Collapse section "2.7. 配置 pod 调度" 2.7.1. 指定关联性、容限和拓扑分布约束 Expand section "2.7.1. 指定关联性、容限和拓扑分布约束" Collapse section "2.7.1. 指定关联性、容限和拓扑分布约束" 2.7.1.1. 使用 pod 反关联性以避免关键应用程序共享节点 2.7.1.2. 使用节点关联性将工作负载调度到特定的节点上 2.7.1.3. 对专用节点使用节点关联性和容限 2.7.2. 配置 pod 反关联性,以将每个 Kafka 代理调度到不同的 worker 节点上 2.7.3. 在 Kafka 组件中配置 pod 反关联性 2.7.4. 在 Kafka 组件中配置节点关联性 2.7.5. 设置专用节点并在节点上调度 pod 2.8. 日志记录配置 Expand section "2.8. 日志记录配置" Collapse section "2.8. 日志记录配置" 2.8.1. 为日志记录创建 ConfigMap 2.8.2. 在 Operator 中添加日志记录过滤器 2.9. 从外部源加载配置值 3. 配置外部监听程序 Expand section "3. 配置外部监听程序" Collapse section "3. 配置外部监听程序" 3.1. 使用节点端口访问 Kafka 3.2. 使用 loadbalancers 访问 Kafka 3.3. 使用 ingress 访问 Kafka 3.4. 使用 OpenShift 路由访问 Kafka 4. 管理对 Kafka 的安全访问 Expand section "4. 管理对 Kafka 的安全访问" Collapse section "4. 管理对 Kafka 的安全访问" 4.1. Kafka 的安全选项 Expand section "4.1. Kafka 的安全选项" Collapse section "4.1. Kafka 的安全选项" 4.1.1. 监听程序验证 Expand section "4.1.1. 监听程序验证" Collapse section "4.1.1. 监听程序验证" 4.1.1.1. 双向 TLS 身份验证 4.1.1.2. SCRAM-SHA-512 验证 4.1.1.3. 网络策略 4.1.1.4. 其他监听程序配置选项 4.1.2. kafka 授权 Expand section "4.1.2. kafka 授权" Collapse section "4.1.2. kafka 授权" 4.1.2.1. 超级用户 4.2. Kafka 客户端的安全选项 Expand section "4.2. Kafka 客户端的安全选项" Collapse section "4.2. Kafka 客户端的安全选项" 4.2.1. 为用户处理识别 Kafka 集群 4.2.2. 用户身份验证 Expand section "4.2.2. 用户身份验证" Collapse section "4.2.2. 用户身份验证" 4.2.2.1. TLS 客户端身份验证 4.2.2.2. SCRAM-SHA-512 Authentication 4.2.3. 用户授权 Expand section "4.2.3. 用户授权" Collapse section "4.2.3. 用户授权" 4.2.3.1. ACL 规则 4.2.3.2. 超级用户访问 Kafka 代理 4.2.3.3. 用户配额 4.3. 保护对 Kafka 代理的访问 Expand section "4.3. 保护对 Kafka 代理的访问" Collapse section "4.3. 保护对 Kafka 代理的访问" 4.3.1. 保护 Kafka 代理 4.3.2. 保护用户对 Kafka 的访问 4.3.3. 使用网络策略限制对 Kafka 侦听器的访问 4.4. 使用基于 OAuth 2.0 令牌的身份验证 Expand section "4.4. 使用基于 OAuth 2.0 令牌的身份验证" Collapse section "4.4. 使用基于 OAuth 2.0 令牌的身份验证" 4.4.1. OAuth 2.0 身份验证机制 4.4.2. OAuth 2.0 Kafka 代理配置 Expand section "4.4.2. OAuth 2.0 Kafka 代理配置" Collapse section "4.4.2. OAuth 2.0 Kafka 代理配置" 4.4.2.1. 授权服务器上的 OAuth 2.0 客户端配置 4.4.2.2. Kafka 集群中的 OAuth 2.0 身份验证配置 4.4.2.3. 快速本地 JWT 令牌验证配置 4.4.2.4. OAuth 2.0 内省端点配置 4.4.3. Kafka 代理的会话重新身份验证 4.4.4. OAuth 2.0 Kafka 客户端配置 4.4.5. OAuth 2.0 客户端身份验证流 Expand section "4.4.5. OAuth 2.0 客户端身份验证流" Collapse section "4.4.5. OAuth 2.0 客户端身份验证流" 4.4.5.1. 客户端身份验证流示例 4.4.6. 配置 OAuth 2.0 身份验证 Expand section "4.4.6. 配置 OAuth 2.0 身份验证" Collapse section "4.4.6. 配置 OAuth 2.0 身份验证" 4.4.6.1. 将红帽单点登录配置为 OAuth 2.0 授权服务器 4.4.6.2. 配置 Kafka 代理的 OAuth 2.0 支持 4.4.6.3. 将 Kafka Java 客户端配置为使用 OAuth 2.0 4.4.6.4. 为 Kafka 组件配置 OAuth 2.0 4.5. 使用基于 OAuth 2.0 令牌的授权 Expand section "4.5. 使用基于 OAuth 2.0 令牌的授权" Collapse section "4.5. 使用基于 OAuth 2.0 令牌的授权" 4.5.1. OAuth 2.0 授权机制 Expand section "4.5.1. OAuth 2.0 授权机制" Collapse section "4.5.1. OAuth 2.0 授权机制" 4.5.1.1. Kafka 代理自定义授权器 4.5.2. 配置 OAuth 2.0 授权支持 4.5.3. 在 Red Hat Single Sign-On Authorization Services 中管理策略和权限 Expand section "4.5.3. 在 Red Hat Single Sign-On Authorization Services 中管理策略和权限" Collapse section "4.5.3. 在 Red Hat Single Sign-On Authorization Services 中管理策略和权限" 4.5.3.1. Kafka 和红帽单点登录授权模型概述 4.5.3.2. 将 Red Hat Single Sign-On Authorization Services 映射到 Kafka 授权模型 4.5.3.3. Kafka 操作所需的权限示例 4.5.4. 试用红帽单点登录授权服务 Expand section "4.5.4. 试用红帽单点登录授权服务" Collapse section "4.5.4. 试用红帽单点登录授权服务" 4.5.4.1. 访问红帽单点登录管理控制台 4.5.4.2. 使用 Red Hat Single Sign-On 授权部署 Kafka 集群 4.5.4.3. 为 CLI Kafka 客户端会话准备 TLS 连接 4.5.4.4. 使用 CLI Kafka 客户端会话检查对 Kafka 的授权访问权限 5. 使用 AMQ Streams Operator Expand section "5. 使用 AMQ Streams Operator" Collapse section "5. 使用 AMQ Streams Operator" 5.1. 使用 Cluster Operator Expand section "5.1. 使用 Cluster Operator" Collapse section "5.1. 使用 Cluster Operator" 5.1.1. Cluster Operator 配置 Expand section "5.1.1. Cluster Operator 配置" Collapse section "5.1.1. Cluster Operator 配置" 5.1.1.1. 功能门 Expand section "5.1.1.1. 功能门" Collapse section "5.1.1.1. 功能门" 5.1.1.1.1. control plane 侦听程序功能门 5.1.1.1.2. 服务帐户补丁功能门 5.1.1.2. 通过 ConfigMap 日志记录配置 5.1.1.3. 使用网络策略限制 Cluster Operator 访问 5.1.1.4. 定期协调 5.1.2. 调配基于角色的访问控制(RBAC) Expand section "5.1.2. 调配基于角色的访问控制(RBAC)" Collapse section "5.1.2. 调配基于角色的访问控制(RBAC)" 5.1.2.1. 委派的权限 5.1.2.2. ServiceAccount 5.1.2.3. ClusterRoles 5.1.2.4. ClusterRoleBindings 5.1.3. 使用默认代理设置配置 Cluster Operator 5.2. 使用主题 Operator Expand section "5.2. 使用主题 Operator" Collapse section "5.2. 使用主题 Operator" 5.2.1. Kafka 主题资源 Expand section "5.2.1. Kafka 主题资源" Collapse section "5.2.1. Kafka 主题资源" 5.2.1.1. 为主题处理识别 Kafka 集群 5.2.1.2. Kafka 主题使用建议 5.2.1.3. Kafka 主题命名约定 5.2.2. 主题 Operator 主题存储 Expand section "5.2.2. 主题 Operator 主题存储" Collapse section "5.2.2. 主题 Operator 主题存储" 5.2.2.1. 内部主题存储主题 5.2.2.2. 从 ZooKeeper 迁移主题元数据 5.2.2.3. 降级到使用 ZooKeeper 存储主题元数据的 AMQ Streams 版本 5.2.2.4. 主题 Operator 主题复制和扩展 5.2.2.5. 处理主题的更改 5.2.3. 配置 Kafka 主题 5.2.4. 使用资源请求和限值配置主题 Operator 5.3. 使用 User Operator Expand section "5.3. 使用 User Operator" Collapse section "5.3. 使用 User Operator" 5.3.1. 使用资源请求和限值配置 User Operator 5.4. 使用 Prometheus 指标监控 Operator 6. Kafka Bridge Expand section "6. Kafka Bridge" Collapse section "6. Kafka Bridge" 6.1. Kafka 网桥概述 Expand section "6.1. Kafka 网桥概述" Collapse section "6.1. Kafka 网桥概述" 6.1.1. Kafka Bridge 接口 Expand section "6.1.1. Kafka Bridge 接口" Collapse section "6.1.1. Kafka Bridge 接口" 6.1.1.1. HTTP 请求 6.1.2. Kafka Bridge 支持的客户端 6.1.3. 保护 Kafka 网桥 6.1.4. 访问 OpenShift 外部的 Kafka 网桥 6.1.5. 对 Kafka Bridge 的请求 Expand section "6.1.5. 对 Kafka Bridge 的请求" Collapse section "6.1.5. 对 Kafka Bridge 的请求" 6.1.5.1. 内容类型标头 6.1.5.2. 嵌入式数据格式 6.1.5.3. 消息格式 6.1.5.4. 接受标头 6.1.6. CORS Expand section "6.1.6. CORS" Collapse section "6.1.6. CORS" 6.1.6.1. 简单请求 6.1.6.2. Preflighted 请求 6.1.7. Kafka Bridge API 资源 6.1.8. Kafka Bridge 部署 6.2. Kafka Bridge quickstart Expand section "6.2. Kafka Bridge quickstart" Collapse section "6.2. Kafka Bridge quickstart" 6.2.1. 将 Kafka Bridge 部署到 OpenShift 集群 6.2.2. 将 Kafka Bridge 服务公开到您的本地机器 6.2.3. 生成到主题和分区的消息 6.2.4. 创建 Kafka 网桥消费者 6.2.5. 将 Kafka 网桥消费者订阅到主题 6.2.6. 从 Kafka Bridge 用户检索最新信息 6.2.7. 将偏移提交到日志 6.2.8. 寻找分区的偏移 6.2.9. 删除 Kafka 网桥消费者 7. 使用带有 3scale 的 Kafka 网桥 Expand section "7. 使用带有 3scale 的 Kafka 网桥" Collapse section "7. 使用带有 3scale 的 Kafka 网桥" 7.1. 使用带有 3scale 的 Kafka 网桥 Expand section "7.1. 使用带有 3scale 的 Kafka 网桥" Collapse section "7.1. 使用带有 3scale 的 Kafka 网桥" 7.1.1. Kafka Bridge 服务发现 7.1.2. 3scale APIcast 网关策略 7.1.3. TLS 验证 7.1.4. 3scale 文档 7.2. 为 Kafka 网桥部署 3scale 8. 用于集群重新平衡的精简控制 Expand section "8. 用于集群重新平衡的精简控制" Collapse section "8. 用于集群重新平衡的精简控制" 8.1. 为什么使用清理控制? 8.2. 优化目标概述 8.3. 优化调整概述 8.4. 重新平衡性能调优概述 8.5. 精简控制配置 8.6. 部署清理控制 8.7. 生成优化分析 8.8. 批准优化建议 8.9. 停止集群重新平衡 8.10. 修复 KafkaRebalance 资源的问题 9. 使用 Service Registry 验证模式 10. 分布式追踪 Expand section "10. 分布式追踪" Collapse section "10. 分布式追踪" 10.1. OpenTracing 和 Jaeger 概述 10.2. 为 Kafka 客户端设置追踪 Expand section "10.2. 为 Kafka 客户端设置追踪" Collapse section "10.2. 为 Kafka 客户端设置追踪" 10.2.1. 为 Kafka 客户端初始化 Jaeger tracer 10.2.2. 用于追踪的环境变量 10.3. 使用 tracers 强制 Kafka 客户端 Expand section "10.3. 使用 tracers 强制 Kafka 客户端" Collapse section "10.3. 使用 tracers 强制 Kafka 客户端" 10.3.1. 强制生产者和消费者进行追踪 Expand section "10.3.1. 强制生产者和消费者进行追踪" Collapse section "10.3.1. 强制生产者和消费者进行追踪" 10.3.1.1. Decorator 模式中的自定义范围名称 10.3.1.2. 内置范围名称 10.3.2. 用于追踪的 Kafka Streams 应用程序 10.4. 为 MirrorMaker、Kafka Connect 和 Kafka Bridge 设置追踪 Expand section "10.4. 为 MirrorMaker、Kafka Connect 和 Kafka Bridge 设置追踪" Collapse section "10.4. 为 MirrorMaker、Kafka Connect 和 Kafka Bridge 设置追踪" 10.4.1. 在 MirrorMaker、Kafka Connect 和 Kafka Bridge 资源中启用追踪 11. 管理 TLS 证书 Expand section "11. 管理 TLS 证书" Collapse section "11. 管理 TLS 证书" 11.1. 证书颁发机构 Expand section "11.1. 证书颁发机构" Collapse section "11.1. 证书颁发机构" 11.1.1. CA 证书 11.1.2. 安装您自己的 CA 证书 11.2. Secrets Expand section "11.2. Secrets" Collapse section "11.2. Secrets" 11.2.1. PKCS #12 存储 11.2.2. 集群 CA Secret 11.2.3. 客户端 CA Secret 11.2.4. 在 Secret 中添加标签和注解 11.2.5. 在 CA Secret 中禁用 ownerReference 11.2.6. 用户 Secret 11.3. 证书续订和有效期周期 Expand section "11.3. 证书续订和有效期周期" Collapse section "11.3. 证书续订和有效期周期" 11.3.1. 使用自动生成的 CA 证书的续订过程 11.3.2. 客户端证书续订 11.3.3. 手动续订 Cluster Operator 生成的 CA 证书 11.3.4. 替换 Cluster Operator 生成的 CA 证书使用的私钥 11.3.5. 续订您自己的 CA 证书 11.4. TLS 连接 Expand section "11.4. TLS 连接" Collapse section "11.4. TLS 连接" 11.4.1. zookeeper 通讯 11.4.2. Kafka 间通信 11.4.3. 主题和用户 Operator 11.4.4. Sything Control 11.4.5. Kafka 客户端连接 11.5. 配置内部客户端以信任集群 CA 11.6. 配置外部客户端以信任集群 CA 11.7. Kafka 侦听程序证书 Expand section "11.7. Kafka 侦听程序证书" Collapse section "11.7. Kafka 侦听程序证书" 11.7.1. 提供您自己的 Kafka 侦听程序证书 11.7.2. Kafka 监听程序服务器证书中的其他主题 Expand section "11.7.2. Kafka 监听程序服务器证书中的其他主题" Collapse section "11.7.2. Kafka 监听程序服务器证书中的其他主题" 11.7.2.1. TLS 侦听器 SAN 示例 11.7.2.2. 外部监听程序 SAN 示例 12. 管理 AMQ 流 Expand section "12. 管理 AMQ 流" Collapse section "12. 管理 AMQ 流" 12.1. 使用自定义资源 Expand section "12.1. 使用自定义资源" Collapse section "12.1. 使用自定义资源" 12.1.1. 对自定义资源执行 oc 操作 Expand section "12.1.1. 对自定义资源执行 oc 操作" Collapse section "12.1.1. 对自定义资源执行 oc 操作" 12.1.1.1. 资源类型 12.1.1.2. 查询子资源的状态 12.1.2. AMQ Streams 自定义资源状态信息 12.1.3. 查找自定义资源的状态 12.2. 暂停自定义资源协调 12.3. 手动启动 Kafka 和 ZooKeeper 集群的滚动更新 Expand section "12.3. 手动启动 Kafka 和 ZooKeeper 集群的滚动更新" Collapse section "12.3. 手动启动 Kafka 和 ZooKeeper 集群的滚动更新" 12.3.1. 先决条件 12.3.2. 使用 StatefulSet 注解执行滚动更新 12.3.3. 使用 Pod 注解执行滚动更新 12.4. 使用标签和注解发现服务 Expand section "12.4. 使用标签和注解发现服务" Collapse section "12.4. 使用标签和注解发现服务" 12.4.1. 返回服务的连接详情 12.5. 从持久性卷中恢复集群 Expand section "12.5. 从持久性卷中恢复集群" Collapse section "12.5. 从持久性卷中恢复集群" 12.5.1. 从命名空间删除中恢复 12.5.2. 在 OpenShift 集群丢失后进行恢复 12.5.3. 从持久性卷中恢复已删除的集群 12.6. 使用 Kafka Static Quota 插件设置代理的限制 12.7. 调整 Kafka 配置 Expand section "12.7. 调整 Kafka 配置" Collapse section "12.7. 调整 Kafka 配置" 12.7.1. Kafka 代理配置调整 Expand section "12.7.1. Kafka 代理配置调整" Collapse section "12.7.1. Kafka 代理配置调整" 12.7.1.1. 基本代理配置 12.7.1.2. 复制高可用性主题 12.7.1.3. 事务和提交的内部主题设置 12.7.1.4. 通过增加 I/O 线程改进请求处理吞吐量 12.7.1.5. 为高延迟连接增加带宽 12.7.1.6. 使用数据保留策略管理日志 12.7.1.7. 使用清理策略删除日志数据 12.7.1.8. 管理磁盘使用率 12.7.1.9. 处理大消息大小 12.7.1.10. 控制消息数据的日志清除 12.7.1.11. 对可用性进行分区重新平衡 12.7.1.12. 未清理领导选举机制 12.7.1.13. 避免不必要的消费者组重新平衡 12.7.2. Kafka 生成器配置调整 Expand section "12.7.2. Kafka 生成器配置调整" Collapse section "12.7.2. Kafka 生成器配置调整" 12.7.2.1. 基本制作者配置 12.7.2.2. 数据持久性 12.7.2.3. 订购交付 12.7.2.4. 可靠性保证 12.7.2.5. 优化吞吐量和延迟 12.7.3. Kafka 使用者配置调整 Expand section "12.7.3. Kafka 使用者配置调整" Collapse section "12.7.3. Kafka 使用者配置调整" 12.7.3.1. 基本使用者配置 12.7.3.2. 使用消费者组扩展数据消耗 12.7.3.3. 消息排序保证 12.7.3.4. 优化吞吐量和延迟 12.7.3.5. 在提交偏移时避免数据丢失或重复 Expand section "12.7.3.5. 在提交偏移时避免数据丢失或重复" Collapse section "12.7.3.5. 在提交偏移时避免数据丢失或重复" 12.7.3.5.1. 控制事务性消息 12.7.3.6. 从失败中恢复,以避免数据丢失 12.7.3.7. 管理偏移策略 12.7.3.8. 最小化重新平衡的影响 12.8. 卸载 AMQ 流 12.9. 常见问题解答 Expand section "12.9. 常见问题解答" Collapse section "12.9. 常见问题解答" 12.9.1. 与 Cluster Operator 相关的问题 Expand section "12.9.1. 与 Cluster Operator 相关的问题" Collapse section "12.9.1. 与 Cluster Operator 相关的问题" 12.9.1.1. 为什么我需要集群管理员特权才能安装 AMQ Streams? 12.9.1.2. 为什么 Cluster Operator 需要创建 ClusterRoleBinding? 12.9.1.3. 标准 OpenShift 用户是否可以创建 Kafka 自定义资源? 12.9.1.4. 在 日志中获取锁定 警告意味着什么? 12.9.1.5. 为什么在使用 TLS 连接 NodePort 时主机名验证失败? 13. 自定义资源 API 参考 Expand section "13. 自定义资源 API 参考" Collapse section "13. 自定义资源 API 参考" 13.1. 常见配置属性 Expand section "13.1. 常见配置属性" Collapse section "13.1. 常见配置属性" 13.1.1. replicas 13.1.2. bootstrapServers 13.1.3. ssl 13.1.4. trustedCertificates 13.1.5. 资源 13.1.6. image 13.1.7. livenessProbe 和 readinessProbe 健康检查 13.1.8. metricsConfig 13.1.9. jvmOptions 13.1.10. 垃圾收集器日志记录 13.2. 架构属性 Expand section "13.2. 架构属性" Collapse section "13.2. 架构属性" 13.2.1. Kafka 模式参考 13.2.2. KafkaSpec 模式参考 13.2.3. KafkaClusterSpec 模式参考 Expand section "13.2.3. KafkaClusterSpec 模式参考" Collapse section "13.2.3. KafkaClusterSpec 模式参考" 13.2.3.1. 监听程序 13.2.3.2. config 13.2.3.3. brokerRackInitImage 13.2.3.4. logging 13.2.3.5. KafkaClusterSpec 模式属性 13.2.4. GenericKafkaListener 模式参考 Expand section "13.2.4. GenericKafkaListener 模式参考" Collapse section "13.2.4. GenericKafkaListener 模式参考" 13.2.4.1. 监听程序 13.2.4.2. type 13.2.4.3. port 13.2.4.4. tls 13.2.4.5. 身份验证 13.2.4.6. networkPolicyPeers 13.2.4.7. GenericKafkaListener 架构属性 13.2.5. KafkaListenerAuthenticationTls 模式参考 13.2.6. KafkaListenerAuthenticationScramSha512 schema reference 13.2.7. KafkaListenerAuthenticationOAuth 模式参考 13.2.8. GenericSecretSource 模式参考 13.2.9. CertSecretSource 模式参考 13.2.10. GenericKafkaListenerConfiguration 模式参考 Expand section "13.2.10. GenericKafkaListenerConfiguration 模式参考" Collapse section "13.2.10. GenericKafkaListenerConfiguration 模式参考" 13.2.10.1. brokerCertChainAndKey 13.2.10.2. externalTrafficPolicy 13.2.10.3. loadBalancerSourceRanges 13.2.10.4. class 13.2.10.5. preferredNodePortAddressType 13.2.10.6. useServiceDnsDomain 13.2.10.7. GenericKafkaListenerConfiguration 模式属性 13.2.11. CertAndKeySecretSource schema reference 13.2.12. GenericKafkaListenerConfigurationBootstrap schema reference Expand section "13.2.12. GenericKafkaListenerConfigurationBootstrap schema reference" Collapse section "13.2.12. GenericKafkaListenerConfigurationBootstrap schema reference" 13.2.12.1. alternativeNames 13.2.12.2. host 13.2.12.3. nodePort 13.2.12.4. loadBalancerIP 13.2.12.5. annotations 13.2.12.6. GenericKafkaListenerConfigurationBootstrap schema properties 13.2.13. GenericKafkaListenerConfigurationBroker 模式参考 Expand section "13.2.13. GenericKafkaListenerConfigurationBroker 模式参考" Collapse section "13.2.13. GenericKafkaListenerConfigurationBroker 模式参考" 13.2.13.1. GenericKafkaListenerConfigurationBroker 模式属性 13.2.14. EphemeralStorage 架构参考 13.2.15. PersistentClaimStorage 架构参考 13.2.16. PersistentClaimStorageOverride schema reference 13.2.17. JbodStorage schema reference 13.2.18. KafkaAuthorizationSimple schema 参考 Expand section "13.2.18. KafkaAuthorizationSimple schema 参考" Collapse section "13.2.18. KafkaAuthorizationSimple schema 参考" 13.2.18.1. superUsers 13.2.18.2. KafkaAuthorizationSimple schema 属性 13.2.19. KafkaAuthorizationOpa 模式参考 Expand section "13.2.19. KafkaAuthorizationOpa 模式参考" Collapse section "13.2.19. KafkaAuthorizationOpa 模式参考" 13.2.19.1. url 13.2.19.2. allowOnError 13.2.19.3. initialCacheCapacity 13.2.19.4. maximumCacheSize 13.2.19.5. expireAfterMs 13.2.19.6. superUsers 13.2.19.7. KafkaAuthorizationOpa 模式属性 13.2.20. KafkaAuthorizationKeycloak 模式参考 13.2.21. KafkaAuthorizationCustom 模式参考 Expand section "13.2.21. KafkaAuthorizationCustom 模式参考" Collapse section "13.2.21. KafkaAuthorizationCustom 模式参考" 13.2.21.1. authorizerClass 13.2.21.2. superUsers 13.2.21.3. KafkaAuthorizationCustom schema 属性 13.2.22. rack 架构参考 Expand section "13.2.22. rack 架构参考" Collapse section "13.2.22. rack 架构参考" 13.2.22.1. 在机架间分散分区副本 13.2.22.2. 使用来自最接近副本的消息 13.2.22.3. rack 架构属性 13.2.23. 探测 模式参考 13.2.24. JvmOptions 架构参考 13.2.25. SystemProperty 架构参考 13.2.26. KafkaJmxOptions 模式参考 Expand section "13.2.26. KafkaJmxOptions 模式参考" Collapse section "13.2.26. KafkaJmxOptions 模式参考" 13.2.26.1. KafkaJmxOptions 架构属性 13.2.27. KafkaJmxAuthenticationPassword 架构参考 13.2.28. JmxPrometheusExporterMetrics schema reference 13.2.29. ExternalConfigurationReference 模式参考 13.2.30. InlineLogging schema 参考 13.2.31. ExternalLogging 架构参考 13.2.32. KafkaClusterTemplate 模式参考 13.2.33. StatefulSetTemplate 模式参考 13.2.34. MetadataTemplate 架构参考 Expand section "13.2.34. MetadataTemplate 架构参考" Collapse section "13.2.34. MetadataTemplate 架构参考" 13.2.34.1. MetadataTemplate 架构属性 13.2.35. PodTemplate 架构参考 Expand section "13.2.35. PodTemplate 架构参考" Collapse section "13.2.35. PodTemplate 架构参考" 13.2.35.1. hostAliases 13.2.35.2. PodTemplate 架构属性 13.2.36. InternalServiceTemplate 模式参考 13.2.37. ExternalServiceTemplate 模式引用 Expand section "13.2.37. ExternalServiceTemplate 模式引用" Collapse section "13.2.37. ExternalServiceTemplate 模式引用" 13.2.37.1. ExternalServiceTemplate 架构属性 13.2.38. resourcetemplate 架构引用 13.2.39. PodDisruptionBudgetTemplate 模式参考 Expand section "13.2.39. PodDisruptionBudgetTemplate 模式参考" Collapse section "13.2.39. PodDisruptionBudgetTemplate 模式参考" 13.2.39.1. PodDisruptionBudgetTemplate 架构属性 13.2.40. ContainerTemplate 架构参考 Expand section "13.2.40. ContainerTemplate 架构参考" Collapse section "13.2.40. ContainerTemplate 架构参考" 13.2.40.1. ContainerTemplate 架构属性 13.2.41. ContainerEnvVar 模式参考 13.2.42. ZookeeperClusterSpec 模式参考 Expand section "13.2.42. ZookeeperClusterSpec 模式参考" Collapse section "13.2.42. ZookeeperClusterSpec 模式参考" 13.2.42.1. config 13.2.42.2. logging 13.2.42.3. ZookeeperClusterSpec 模式属性 13.2.43. ZookeeperClusterTemplate schema reference 13.2.44. EntityOperatorSpec 模式参考 13.2.45. EntityTopicOperatorSpec schema reference Expand section "13.2.45. EntityTopicOperatorSpec schema reference" Collapse section "13.2.45. EntityTopicOperatorSpec schema reference" 13.2.45.1. logging 13.2.45.2. EntityTopicOperatorSpec schema properties 13.2.46. EntityUserOperatorSpec 模式参考 Expand section "13.2.46. EntityUserOperatorSpec 模式参考" Collapse section "13.2.46. EntityUserOperatorSpec 模式参考" 13.2.46.1. logging 13.2.46.2. EntityUserOperatorSpec 模式属性 13.2.47. TlsSidecar 架构参考 Expand section "13.2.47. TlsSidecar 架构参考" Collapse section "13.2.47. TlsSidecar 架构参考" 13.2.47.1. TlsSidecar 架构属性 13.2.48. EntityOperatorTemplate 模式参考 13.2.49. certificateAuthority schema 参考 13.2.50. CruiseControlSpec 模式参考 13.2.51. CruiseControlTemplate 模式参考 13.2.52. BrokerCapacity schema 参考 13.2.53. KafkaExporterSpec 模式参考 13.2.54. KafkaExporterTemplate 模式参考 13.2.55. KafkaStatus 架构参考 13.2.56. 条件 架构参考 13.2.57. ListenerStatus 模式参考 13.2.58. ListenerAddress 模式参考 13.2.59. KafkaConnect 模式参考 13.2.60. KafkaConnectSpec 模式参考 Expand section "13.2.60. KafkaConnectSpec 模式参考" Collapse section "13.2.60. KafkaConnectSpec 模式参考" 13.2.60.1. config 13.2.60.2. logging 13.2.60.3. KafkaConnectSpec schema 属性 13.2.61. KafkaConnectTls 模式参考 Expand section "13.2.61. KafkaConnectTls 模式参考" Collapse section "13.2.61. KafkaConnectTls 模式参考" 13.2.61.1. trustedCertificates 13.2.61.2. KafkaConnectTls schema 属性 13.2.62. KafkaClientAuthenticationTls 模式参考 Expand section "13.2.62. KafkaClientAuthenticationTls 模式参考" Collapse section "13.2.62. KafkaClientAuthenticationTls 模式参考" 13.2.62.1. certificateAndKey 13.2.62.2. KafkaClientAuthenticationTls schema 属性 13.2.63. KafkaClientAuthenticationScramSha512 schema reference Expand section "13.2.63. KafkaClientAuthenticationScramSha512 schema reference" Collapse section "13.2.63. KafkaClientAuthenticationScramSha512 schema reference" 13.2.63.1. username 13.2.63.2. passwordSecret 13.2.63.3. KafkaClientAuthenticationScramSha512 schema properties 13.2.64. PasswordSecretSource 模式参考 13.2.65. KafkaClientAuthenticationPlain 模式参考 Expand section "13.2.65. KafkaClientAuthenticationPlain 模式参考" Collapse section "13.2.65. KafkaClientAuthenticationPlain 模式参考" 13.2.65.1. username 13.2.65.2. passwordSecret 13.2.65.3. KafkaClientAuthenticationPlain 架构属性 13.2.66. KafkaClientAuthenticationOAuth 模式参考 Expand section "13.2.66. KafkaClientAuthenticationOAuth 模式参考" Collapse section "13.2.66. KafkaClientAuthenticationOAuth 模式参考" 13.2.66.1. KafkaClientAuthenticationOAuth 模式属性 13.2.67. Jaegertracing 模式参考 13.2.68. KafkaConnectTemplate 模式参考 13.2.69. DeploymentTemplate 架构参考 13.2.70. ExternalConfiguration 架构参考 Expand section "13.2.70. ExternalConfiguration 架构参考" Collapse section "13.2.70. ExternalConfiguration 架构参考" 13.2.70.1. env 13.2.70.2. 卷 13.2.70.3. ExternalConfiguration 架构属性 13.2.71. ExternalConfigurationEnv 模式参考 13.2.72. ExternalConfigurationEnvVarSource 模式参考 13.2.73. ExternalConfigurationVolumeSource 模式引用 13.2.74. 构建 架构参考 Expand section "13.2.74. 构建 架构参考" Collapse section "13.2.74. 构建 架构参考" 13.2.74.1. output 13.2.74.2. plugins 13.2.74.3. 构建 架构属性 13.2.75. dockerOutput 模式参考 13.2.76. ImageStreamOutput 模式参考 13.2.77. 插件 架构参考 13.2.78. JarArtifact 架构参考 13.2.79. TgzArtifact 架构参考 13.2.80. ZipArtifact 架构参考 13.2.81. OtherArtifact 架构参考 13.2.82. KafkaConnectStatus 模式参考 13.2.83. ConnectorPlugin 架构参考 13.2.84. KafkaConnectS2I 模式参考 13.2.85. KafkaConnectS2ISpec 模式参考 Expand section "13.2.85. KafkaConnectS2ISpec 模式参考" Collapse section "13.2.85. KafkaConnectS2ISpec 模式参考" 13.2.85.1. KafkaConnectS2ISpec schema 属性 13.2.86. KafkaConnectS2IStatus 模式参考 13.2.87. KafkaTopic 架构参考 13.2.88. KafkaTopicSpec 模式参考 13.2.89. KafkaTopicStatus schema reference 13.2.90. KafkaUser 架构参考 13.2.91. KafkaUserSpec 模式参考 13.2.92. KafkaUserTlsClientAuthentication schema reference 13.2.93. KafkaUserScramSha512ClientAuthentication schema reference 13.2.94. KafkaUserAuthorizationSimple schema 参考 13.2.95. AclRule 架构参考 Expand section "13.2.95. AclRule 架构参考" Collapse section "13.2.95. AclRule 架构参考" 13.2.95.1. resource 13.2.95.2. type 13.2.95.3. 操作 13.2.95.4. host 13.2.95.5. AclRule 架构属性 13.2.96. AclRuleTopicResource 模式参考 13.2.97. AclRuleGroupResource schema reference 13.2.98. AclRuleClusterResource 模式参考 13.2.99. AclRuleTransactionalIdResource schema reference 13.2.100. KafkaUserQuotas 架构参考 Expand section "13.2.100. KafkaUserQuotas 架构参考" Collapse section "13.2.100. KafkaUserQuotas 架构参考" 13.2.100.1. quotas 13.2.100.2. KafkaUserQuotas 架构属性 13.2.101. KafkaUserTemplate 模式参考 Expand section "13.2.101. KafkaUserTemplate 模式参考" Collapse section "13.2.101. KafkaUserTemplate 模式参考" 13.2.101.1. KafkaUserTemplate 架构属性 13.2.102. KafkaUserStatus 模式参考 13.2.103. KafkaMirrorMaker 模式参考 13.2.104. KafkaMirrorMakerSpec 模式参考 Expand section "13.2.104. KafkaMirrorMakerSpec 模式参考" Collapse section "13.2.104. KafkaMirrorMakerSpec 模式参考" 13.2.104.1. Include 13.2.104.2. KafkaMirrorMakerConsumerSpec and KafkaMirrorMakerProducerSpec 13.2.104.3. logging 13.2.104.4. KafkaMirrorMakerSpec 模式属性 13.2.105. KafkaMirrorMakerConsumerSpec schema reference Expand section "13.2.105. KafkaMirrorMakerConsumerSpec schema reference" Collapse section "13.2.105. KafkaMirrorMakerConsumerSpec schema reference" 13.2.105.1. numStreams 13.2.105.2. offsetCommitInterval 13.2.105.3. config 13.2.105.4. groupId 13.2.105.5. KafkaMirrorMakerConsumerSpec schema properties 13.2.106. KafkaMirrorMakerTls 模式参考 Expand section "13.2.106. KafkaMirrorMakerTls 模式参考" Collapse section "13.2.106. KafkaMirrorMakerTls 模式参考" 13.2.106.1. trustedCertificates 13.2.106.2. kafkaMirrorMakerTls 架构属性 13.2.107. KafkaMirrorMakerProducerSpec schema reference Expand section "13.2.107. KafkaMirrorMakerProducerSpec schema reference" Collapse section "13.2.107. KafkaMirrorMakerProducerSpec schema reference" 13.2.107.1. abortOnSendFailure 13.2.107.2. config 13.2.107.3. KafkaMirrorMakerProducerSpec schema properties 13.2.108. KafkaMirrorMakerTemplate 模式参考 13.2.109. KafkaMirrorMakerStatus 模式参考 13.2.110. KafkaBridge 模式参考 13.2.111. KafkaBridgeSpec 模式参考 Expand section "13.2.111. KafkaBridgeSpec 模式参考" Collapse section "13.2.111. KafkaBridgeSpec 模式参考" 13.2.111.1. logging 13.2.111.2. KafkaBridgeSpec 模式属性 13.2.112. KafkaBridgeTls 模式参考 13.2.113. KafkaBridgeHttpConfig schema reference Expand section "13.2.113. KafkaBridgeHttpConfig schema reference" Collapse section "13.2.113. KafkaBridgeHttpConfig schema reference" 13.2.113.1. CORS 13.2.113.2. KafkaBridgeHttpConfig schema properties 13.2.114. KafkaBridgeHttpCors schema reference 13.2.115. KafkaBridgeAdminClientSpec schema reference 13.2.116. KafkaBridgeConsumerSpec schema reference Expand section "13.2.116. KafkaBridgeConsumerSpec schema reference" Collapse section "13.2.116. KafkaBridgeConsumerSpec schema reference" 13.2.116.1. KafkaBridgeConsumerSpec schema properties 13.2.117. KafkaBridgeProducerSpec schema reference Expand section "13.2.117. KafkaBridgeProducerSpec schema reference" Collapse section "13.2.117. KafkaBridgeProducerSpec schema reference" 13.2.117.1. KafkaBridgeProducerSpec schema properties 13.2.118. KafkaBridgeTemplate 模式引用 13.2.119. KafkaBridgeStatus 模式参考 13.2.120. KafkaConnector 模式参考 13.2.121. KafkaConnectorSpec 模式参考 13.2.122. KafkaConnectorStatus 模式参考 13.2.123. KafkaMirrorMaker2 模式参考 13.2.124. KafkaMirrorMaker2Spec 模式参考 13.2.125. KafkaMirrorMaker2ClusterSpec 模式参考 Expand section "13.2.125. KafkaMirrorMaker2ClusterSpec 模式参考" Collapse section "13.2.125. KafkaMirrorMaker2ClusterSpec 模式参考" 13.2.125.1. config 13.2.125.2. KafkaMirrorMaker2ClusterSpec schema properties 13.2.126. KafkaMirrorMaker2Tls 模式参考 13.2.127. KafkaMirrorMaker2MirrorSpec 模式参考 13.2.128. KafkaMirrorMaker2ConnectorSpec schema reference 13.2.129. KafkaMirrorMaker2Status 模式参考 13.2.130. KafkaRebalance 模式参考 13.2.131. KafkaRebalanceSpec 模式参考 13.2.132. KafkaRebalanceStatus 模式参考 A. 使用您的订阅 Settings Close Language: 简体中文 日本語 English Language: 简体中文 日本語 English Format: Multi-page Single-page Format: Multi-page Single-page Language and Page Formatting Options Language: 简体中文 日本語 English Language: 简体中文 日本語 English Format: Multi-page Single-page Format: Multi-page Single-page 13.2.54. KafkaExporterTemplate 模式参考 用于: KafkaExporterSpec 属性描述 Deployment Kafka 导出器 部署的模板. ResourceTemplate Pod Kafka 导出器 Pod 模板. PodTemplate service service 属性已弃用。Kafka Exporter 服务已被删除。Kafka Exporter Service 模板. ResourceTemplate Container Kafka Exporter 容器的模板。 ContainerTemplate serviceAccount Kafka Exporter 服务帐户的模板。 ResourceTemplate Previous Next