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.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 YAML 配置示例 2.1.2. 数据存储注意事项 Expand section "2.1.2. 数据存储注意事项" Collapse section "2.1.2. 数据存储注意事项" 2.1.2.1. 文件系统 2.1.2.2. Apache Kafka 和 ZooKeeper 存储 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.2. 持久性存储 Expand section "2.1.3.2. 持久性存储" Collapse section "2.1.3.2. 持久性存储" 2.1.3.2.1. 存储类覆盖 2.1.3.2.2. 持久性卷声明命名 2.1.3.2.3. 日志目录 2.1.3.3. 重新定义持久性卷大小 2.1.3.4. JBOD 存储概述 Expand section "2.1.3.4. JBOD 存储概述" Collapse section "2.1.3.4. JBOD 存储概述" 2.1.3.4.1. JBOD 配置 2.1.3.4.2. JBOD 和持久性卷声明 2.1.3.4.3. 日志目录 2.1.3.5. 将卷添加到 JBOD 存储 2.1.3.6. 从 JBOD 存储中删除卷 2.1.4. Kafka 代理副本 Expand section "2.1.4. Kafka 代理副本" Collapse section "2.1.4. Kafka 代理副本" 2.1.4.1. 配置代理节点的数量 2.1.5. Kafka 代理配置 Expand section "2.1.5. Kafka 代理配置" Collapse section "2.1.5. Kafka 代理配置" 2.1.5.1. 配置 Kafka 代理 2.1.6. 监听程序配置 2.1.7. zookeeper 副本 Expand section "2.1.7. zookeeper 副本" Collapse section "2.1.7. zookeeper 副本" 2.1.7.1. ZooKeeper 节点数量 2.1.7.2. 更改 ZooKeeper 副本数量 2.1.8. zookeeper 配置 Expand section "2.1.8. zookeeper 配置" Collapse section "2.1.8. zookeeper 配置" 2.1.8.1. zookeeper 配置 2.1.8.2. 配置 ZooKeeper 2.1.9. zookeeper 连接 Expand section "2.1.9. zookeeper 连接" Collapse section "2.1.9. zookeeper 连接" 2.1.9.1. 从终端连接到 ZooKeeper 2.1.10. 实体 Operator Expand section "2.1.10. 实体 Operator" Collapse section "2.1.10. 实体 Operator" 2.1.10.1. 实体 Operator 配置属性 2.1.10.2. 主题 Operator 配置属性 2.1.10.3. 用户 Operator 配置属性 2.1.10.4. Operator 日志记录器 2.1.10.5. 配置实体 Operator 2.1.11. CPU 和内存资源 Expand section "2.1.11. CPU 和内存资源" Collapse section "2.1.11. CPU 和内存资源" 2.1.11.1. 资源限值和请求 Expand section "2.1.11.1. 资源限值和请求" Collapse section "2.1.11.1. 资源限值和请求" 2.1.11.1.1. 资源请求 2.1.11.1.2. 资源限值 2.1.11.1.3. 支持的 CPU 格式 2.1.11.1.4. 支持的内存格式 2.1.11.2. 配置资源请求和限值 2.1.12. Kafka 日志记录器 2.1.13. Kafka 机架感知 Expand section "2.1.13. Kafka 机架感知" Collapse section "2.1.13. Kafka 机架感知" 2.1.13.1. 在 Kafka 代理中配置机架感知 2.1.14. healthchecks Expand section "2.1.14. healthchecks" Collapse section "2.1.14. healthchecks" 2.1.14.1. healthcheck 配置 2.1.14.2. 配置健康检查 2.1.15. Prometheus 指标 Expand section "2.1.15. Prometheus 指标" Collapse section "2.1.15. Prometheus 指标" 2.1.15.1. 指标配置 2.1.15.2. 配置 Prometheus 指标 2.1.16. JMX 选项 Expand section "2.1.16. JMX 选项" Collapse section "2.1.16. JMX 选项" 2.1.16.1. 配置 JMX 选项 2.1.17. JVM 选项 Expand section "2.1.17. JVM 选项" Collapse section "2.1.17. JVM 选项" 2.1.17.1. JVM 配置 2.1.17.2. 配置 JVM 选项 2.1.18. 容器镜像 Expand section "2.1.18. 容器镜像" Collapse section "2.1.18. 容器镜像" 2.1.18.1. 容器镜像配置 2.1.18.2. 配置容器镜像 2.1.19. TLS sidecar Expand section "2.1.19. TLS sidecar" Collapse section "2.1.19. TLS sidecar" 2.1.19.1. TLS sidecar 配置 2.1.19.2. 配置 TLS sidecar 2.1.20. 配置 pod 调度 Expand section "2.1.20. 配置 pod 调度" Collapse section "2.1.20. 配置 pod 调度" 2.1.20.1. 根据其他应用程序调度 pod Expand section "2.1.20.1. 根据其他应用程序调度 pod" Collapse section "2.1.20.1. 根据其他应用程序调度 pod" 2.1.20.1.1. 避免关键应用程序共享节点 2.1.20.1.2. 关联性 2.1.20.1.3. 在 Kafka 组件中配置 pod 反关联性 2.1.20.2. 将 pod 调度到特定的节点 Expand section "2.1.20.2. 将 pod 调度到特定的节点" Collapse section "2.1.20.2. 将 pod 调度到特定的节点" 2.1.20.2.1. 节点调度 2.1.20.2.2. 关联性 2.1.20.2.3. 在 Kafka 组件中配置节点关联性 2.1.20.3. 使用专用节点 Expand section "2.1.20.3. 使用专用节点" Collapse section "2.1.20.3. 使用专用节点" 2.1.20.3.1. 专用节点 2.1.20.3.2. 关联性 2.1.20.3.3. 容限(Tolerations) 2.1.20.3.4. 设置专用节点并在节点上调度 pod 2.1.21. Kafka Exporter 2.1.22. 对 Kafka 集群执行滚动更新 2.1.23. 执行 ZooKeeper 集群的滚动更新 2.1.24. 扩展集群 Expand section "2.1.24. 扩展集群" Collapse section "2.1.24. 扩展集群" 2.1.24.1. 扩展 Kafka 集群 Expand section "2.1.24.1. 扩展 Kafka 集群" Collapse section "2.1.24.1. 扩展 Kafka 集群" 2.1.24.1.1. 在集群中添加代理 2.1.24.1.2. 从集群中删除代理 2.1.24.2. 分区重新分配 Expand section "2.1.24.2. 分区重新分配" Collapse section "2.1.24.2. 分区重新分配" 2.1.24.2.1. 重新分配 JSON 文件 2.1.24.2.2. 在 JBOD 卷间重新分配分区 2.1.24.3. 生成重新分配 JSON 文件 2.1.24.4. 手动创建重新分配 JSON 文件 2.1.24.5. 重新分配节流 2.1.24.6. 扩展 Kafka 集群 2.1.24.7. 缩减 Kafka 集群 2.1.25. 手动删除 Kafka 节点 2.1.26. 手动删除 ZooKeeper 节点 2.1.27. 用于滚动更新的维护时间窗 Expand section "2.1.27. 用于滚动更新的维护时间窗" Collapse section "2.1.27. 用于滚动更新的维护时间窗" 2.1.27.1. 维护时间窗概述 2.1.27.2. 维护时间窗定义 2.1.27.3. 配置维护时间窗 2.1.28. 手动续订 CA 证书 2.1.29. 替换私钥 2.1.30. 作为 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 Connect 集群资源列表 2.2.5. Kafka Connect(S2I)集群资源列表 2.2.6. 与 Debezium 集成以捕获更改数据 2.3. Kafka MirrorMaker 集群配置 Expand section "2.3. Kafka MirrorMaker 集群配置" Collapse section "2.3. Kafka MirrorMaker 集群配置" 2.3.1. 配置 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.3. ACL 规则同步 2.4.4. 使用 MirrorMaker 2.0 在 Kafka 集群间同步数据 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. 外部日志记录 Expand section "2.7. 外部日志记录" Collapse section "2.7. 外部日志记录" 2.7.1. 为日志记录创建 ConfigMap 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 身份验证 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 授权支持 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. 定期协调 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.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. 处理主题的更改 5.2.1.3. Kafka 主题使用建议 5.2.1.4. Kafka 主题命名约定 5.2.2. 配置 Kafka 主题 5.2.3. 使用资源请求和限值配置主题 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 管理模式 Expand section "9. 使用 Service Registry 管理模式" Collapse section "9. 使用 Service Registry 管理模式" 9.1. 为什么使用服务注册表? 9.2. 制作者模式配置 9.3. 使用者架构配置 9.4. 查找模式的策略 9.5. Service Registry 常量 9.6. 安装 Service Registry 9.7. 将架构注册到服务 registry 9.8. 从制作者客户端使用 Service Registry 模式 9.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.3. 证书续订和有效期周期 Expand section "11.3. 证书续订和有效期周期" Collapse section "11.3. 证书续订和有效期周期" 11.3.1. 使用生成的 CA 的续订过程 11.3.2. 客户端应用程序 Expand section "11.3.2. 客户端应用程序" Collapse section "11.3.2. 客户端应用程序" 11.3.2.1. 客户端证书续订 11.3.3. 手动续订 CA 证书 11.3.4. 续订您自己的 CA 证书 11.4. 替换私钥 11.5. TLS 连接 Expand section "11.5. TLS 连接" Collapse section "11.5. TLS 连接" 11.5.1. zookeeper 通讯 11.5.2. Kafka Interbroker 通信 11.5.3. 主题和用户 Operator 11.5.4. Sything Control 11.5.5. Kafka 客户端连接 11.6. 配置内部客户端以信任集群 CA 11.7. 配置外部客户端以信任集群 CA 11.8. Kafka 侦听程序证书 Expand section "11.8. Kafka 侦听程序证书" Collapse section "11.8. Kafka 侦听程序证书" 11.8.1. 提供您自己的 Kafka 侦听程序证书 11.8.2. Kafka 监听程序服务器证书中的其他主题 Expand section "11.8.2. Kafka 监听程序服务器证书中的其他主题" Collapse section "11.8.2. Kafka 监听程序服务器证书中的其他主题" 11.8.2.1. TLS 侦听器 SAN 示例 11.8.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. 使用标签和注解发现服务 Expand section "12.2. 使用标签和注解发现服务" Collapse section "12.2. 使用标签和注解发现服务" 12.2.1. 返回服务的连接详情 12.3. 从持久性卷中恢复集群 Expand section "12.3. 从持久性卷中恢复集群" Collapse section "12.3. 从持久性卷中恢复集群" 12.3.1. 从命名空间删除中恢复 12.3.2. 在 OpenShift 集群丢失后进行恢复 12.3.3. 从持久性卷中恢复已删除的集群 12.4. 调整客户端配置 Expand section "12.4. 调整客户端配置" Collapse section "12.4. 调整客户端配置" 12.4.1. Kafka 生成器配置调整 Expand section "12.4.1. Kafka 生成器配置调整" Collapse section "12.4.1. Kafka 生成器配置调整" 12.4.1.1. 基本制作者配置 12.4.1.2. 数据持久性 12.4.1.3. 订购交付 12.4.1.4. 可靠性保证 12.4.1.5. 优化吞吐量和延迟 12.4.2. Kafka 使用者配置调整 Expand section "12.4.2. Kafka 使用者配置调整" Collapse section "12.4.2. Kafka 使用者配置调整" 12.4.2.1. 基本使用者配置 12.4.2.2. 使用消费者组扩展数据消耗 12.4.2.3. 消息排序保证 12.4.2.4. 优化吞吐量和延迟 12.4.2.5. 在提交偏移时避免数据丢失或重复 Expand section "12.4.2.5. 在提交偏移时避免数据丢失或重复" Collapse section "12.4.2.5. 在提交偏移时避免数据丢失或重复" 12.4.2.5.1. 控制事务性消息 12.4.2.6. 从失败中恢复,以避免数据丢失 12.4.2.7. 管理偏移策略 12.4.2.8. 最小化重新平衡的影响 12.5. 卸载 AMQ 流 A. 常见问题解答 Expand section "A. 常见问题解答" Collapse section "A. 常见问题解答" A.1. 与 Cluster Operator 相关的问题 Expand section "A.1. 与 Cluster Operator 相关的问题" Collapse section "A.1. 与 Cluster Operator 相关的问题" A.1.1. 为什么我需要集群管理员特权才能安装 AMQ Streams? A.1.2. 为什么 Cluster Operator 需要创建 ClusterRoleBinding? A.1.3. 标准 OpenShift 用户是否可以创建 Kafka 自定义资源? A.1.4. 在 日志中获取锁定 警告意味着什么? A.1.5. 为什么在使用 TLS 连接 NodePort 时主机名验证失败? B. 自定义资源 API 参考 Expand section "B. 自定义资源 API 参考" Collapse section "B. 自定义资源 API 参考" B.1. 常见配置属性 Expand section "B.1. 常见配置属性" Collapse section "B.1. 常见配置属性" B.1.1. replicas B.1.2. bootstrapServers B.1.3. ssl B.1.4. trustedCertificates B.1.5. 资源 B.1.6. 镜像 B.1.7. livenessProbe 和 readinessProbe 健康检查 B.1.8. metrics B.1.9. jvmOptions B.1.10. 垃圾收集器日志记录 B.2. Kafka 模式参考 B.3. KafkaSpec 模式参考 B.4. KafkaClusterSpec 模式参考 Expand section "B.4. KafkaClusterSpec 模式参考" Collapse section "B.4. KafkaClusterSpec 模式参考" B.4.1. 监听程序 B.4.2. config B.5. EphemeralStorage 架构参考 B.6. PersistentClaimStorage 架构参考 B.7. PersistentClaimStorageOverride 模式参考 B.8. JbodStorage schema reference B.9. GenericKafkaListener 模式参考 Expand section "B.9. GenericKafkaListener 模式参考" Collapse section "B.9. GenericKafkaListener 模式参考" B.9.1. 监听程序 B.9.2. type B.9.3. 端口 B.9.4. tls B.9.5. 身份验证 B.9.6. networkPolicyPeers B.10. KafkaListenerAuthenticationTls 模式参考 B.11. KafkaListenerAuthenticationScramSha512 schema reference B.12. KafkaListenerAuthenticationOAuth 模式参考 B.13. GenericSecretSource 模式参考 B.14. CertSecretSource 模式参考 B.15. GenericKafkaListenerConfiguration 模式参考 Expand section "B.15. GenericKafkaListenerConfiguration 模式参考" Collapse section "B.15. GenericKafkaListenerConfiguration 模式参考" B.15.1. brokerCertChainAndKey B.15.2. externalTrafficPolicy B.15.3. loadBalancerSourceRanges B.15.4. class B.15.5. preferredNodePortAddressType B.15.6. useServiceDnsDomain B.16. CertAndKeySecretSource 模式参考 B.17. GenericKafkaListenerConfigurationBootstrap 架构参考 Expand section "B.17. GenericKafkaListenerConfigurationBootstrap 架构参考" Collapse section "B.17. GenericKafkaListenerConfigurationBootstrap 架构参考" B.17.1. alternativeNames B.17.2. 主机 B.17.3. nodePort B.17.4. loadBalancerIP B.17.5. annotations B.18. GenericKafkaListenerConfigurationBroker schema reference B.19. KafkaListeners 模式参考 B.20. KafkaListenerPlain 模式参考 B.21. KafkaListenerTls 模式参考 B.22. TlsListenerConfiguration 模式参考 B.23. KafkaListenerExternalRoute schema reference B.24. RouteListenerOverride 模式参考 B.25. RouteListenerBootstrapOverride 架构参考 B.26. RouteListenerBrokerOverride schema reference B.27. KafkaListenerExternalConfiguration 模式参考 B.28. KafkaListenerExternalLoadBalancer schema reference B.29. LoadBalancerListenerOverride 模式参考 B.30. LoadBalancerListenerBootstrapOverride 模式参考 B.31. LoadBalancerListenerBrokerOverride 模式参考 B.32. KafkaListenerExternalNodePort schema reference B.33. NodePortListenerOverride 模式参考 B.34. NodePortListenerBootstrapOverride 架构参考 B.35. NodePortListenerBrokerOverride 架构参考 B.36. NodePortListenerConfiguration 模式参考 B.37. KafkaListenerExternalIngress schema reference B.38. IngressListenerConfiguration 模式参考 B.39. IngressListenerBootstrapConfiguration 模式参考 B.40. IngressListenerBrokerConfiguration 模式参考 B.41. KafkaAuthorizationSimple schema 参考 Expand section "B.41. KafkaAuthorizationSimple schema 参考" Collapse section "B.41. KafkaAuthorizationSimple schema 参考" B.41.1. superUsers B.42. KafkaAuthorizationOpa 模式参考 Expand section "B.42. KafkaAuthorizationOpa 模式参考" Collapse section "B.42. KafkaAuthorizationOpa 模式参考" B.42.1. url B.42.2. allowOnError B.42.3. initialCacheCapacity B.42.4. maximumCacheSize B.42.5. expireAfterMs B.42.6. superUsers B.43. KafkaAuthorizationKeycloak 模式参考 B.44. rack 架构参考 B.45. 探测 模式参考 B.46. JvmOptions 架构参考 B.47. SystemProperty 架构参考 B.48. KafkaJmxOptions 模式参考 B.49. KafkaJmxAuthenticationPassword 架构参考 B.50. InlineLogging schema 参考 B.51. ExternalLogging 架构参考 B.52. TlsSidecar 架构参考 B.53. KafkaClusterTemplate 模式参考 B.54. StatefulSetTemplate 模式参考 B.55. MetadataTemplate 架构参考 B.56. PodTemplate 架构参考 Expand section "B.56. PodTemplate 架构参考" Collapse section "B.56. PodTemplate 架构参考" B.56.1. hostAliases B.57. resourcetemplate 架构引用 B.58. ExternalServiceTemplate 模式引用 B.59. PodDisruptionBudgetTemplate 模式参考 B.60. ContainerTemplate 架构参考 B.61. ContainerEnvVar 模式参考 B.62. ZookeeperClusterSpec 模式参考 B.63. ZookeeperClusterTemplate 模式参考 B.64. TopicOperatorSpec 模式参考 B.65. EntityOperatorSpec 模式参考 B.66. EntityTopicOperatorSpec 模式参考 B.67. EntityUserOperatorSpec 模式参考 B.68. EntityOperatorTemplate 模式参考 B.69. certificateAuthority schema 参考 B.70. CruiseControlSpec 模式参考 B.71. CruiseControlTemplate 模式参考 B.72. BrokerCapacity schema 参考 B.73. KafkaExporterSpec 模式参考 B.74. KafkaExporterTemplate 模式参考 B.75. KafkaStatus 架构参考 B.76. 条件 架构参考 B.77. ListenerStatus 模式参考 B.78. ListenerAddress 模式参考 B.79. KafkaConnect 模式参考 B.80. KafkaConnectSpec 模式参考 Expand section "B.80. KafkaConnectSpec 模式参考" Collapse section "B.80. KafkaConnectSpec 模式参考" B.80.1. config B.80.2. logging B.81. KafkaConnectTls 模式参考 Expand section "B.81. KafkaConnectTls 模式参考" Collapse section "B.81. KafkaConnectTls 模式参考" B.81.1. trustedCertificates B.82. KafkaClientAuthenticationTls 模式参考 Expand section "B.82. KafkaClientAuthenticationTls 模式参考" Collapse section "B.82. KafkaClientAuthenticationTls 模式参考" B.82.1. certificateAndKey B.83. KafkaClientAuthenticationScramSha512 模式参考 Expand section "B.83. KafkaClientAuthenticationScramSha512 模式参考" Collapse section "B.83. KafkaClientAuthenticationScramSha512 模式参考" B.83.1. username B.83.2. passwordSecret B.84. PasswordSecretSource 模式参考 B.85. KafkaClientAuthenticationPlain 模式参考 Expand section "B.85. KafkaClientAuthenticationPlain 模式参考" Collapse section "B.85. KafkaClientAuthenticationPlain 模式参考" B.85.1. username B.85.2. passwordSecret B.86. KafkaClientAuthenticationOAuth 模式参考 B.87. Jaegertracing 模式参考 B.88. KafkaConnectTemplate 模式参考 B.89. ExternalConfiguration 架构参考 Expand section "B.89. ExternalConfiguration 架构参考" Collapse section "B.89. ExternalConfiguration 架构参考" B.89.1. env B.89.2. 卷 B.90. ExternalConfigurationEnv 模式参考 B.91. ExternalConfigurationEnvVarSource 模式参考 B.92. ExternalConfigurationVolumeSource 模式引用 B.93. KafkaConnectStatus 模式参考 B.94. ConnectorPlugin 架构参考 B.95. KafkaConnectS2I 模式参考 B.96. KafkaConnectS2ISpec 模式参考 B.97. KafkaConnectS2IStatus 模式参考 B.98. KafkaTopic 架构参考 B.99. KafkaTopicSpec 模式参考 B.100. KafkaTopicStatus 模式参考 B.101. KafkaUser 架构参考 B.102. KafkaUserSpec 模式参考 B.103. KafkaUserTlsClientAuthentication 模式参考 B.104. KafkaUserScramSha512ClientAuthentication 模式参考 B.105. KafkaUserAuthorizationSimple schema 参考 B.106. AclRule 架构参考 Expand section "B.106. AclRule 架构参考" Collapse section "B.106. AclRule 架构参考" B.106.1. resource B.106.2. type B.106.3. 操作 B.106.4. 主机 B.107. AclRuleTopicResource 模式参考 B.108. AclRuleGroupResource 模式参考 B.109. AclRuleClusterResource 模式参考 B.110. AclRuleTransactionalIdResource 模式参考 B.111. KafkaUserQuotas 架构参考 Expand section "B.111. KafkaUserQuotas 架构参考" Collapse section "B.111. KafkaUserQuotas 架构参考" B.111.1. quotas B.112. KafkaUserTemplate 模式参考 B.113. KafkaUserStatus 模式参考 B.114. KafkaMirrorMaker 模式参考 B.115. KafkaMirrorMakerSpec 模式参考 Expand section "B.115. KafkaMirrorMakerSpec 模式参考" Collapse section "B.115. KafkaMirrorMakerSpec 模式参考" B.115.1. whitelist B.115.2. KafkaMirrorMakerConsumerSpec and KafkaMirrorMakerProducerSpec B.115.3. logging B.116. KafkaMirrorMakerConsumerSpec 模式参考 Expand section "B.116. KafkaMirrorMakerConsumerSpec 模式参考" Collapse section "B.116. KafkaMirrorMakerConsumerSpec 模式参考" B.116.1. numStreams B.116.2. offsetCommitInterval B.116.3. config B.116.4. groupId B.117. KafkaMirrorMakerTls 模式参考 Expand section "B.117. KafkaMirrorMakerTls 模式参考" Collapse section "B.117. KafkaMirrorMakerTls 模式参考" B.117.1. trustedCertificates B.118. KafkaMirrorMakerProducerSpec schema reference Expand section "B.118. KafkaMirrorMakerProducerSpec schema reference" Collapse section "B.118. KafkaMirrorMakerProducerSpec schema reference" B.118.1. abortOnSendFailure B.118.2. config B.119. KafkaMirrorMakerTemplate 模式参考 B.120. KafkaMirrorMakerStatus 模式参考 B.121. KafkaBridge 模式参考 B.122. KafkaBridgeSpec 模式参考 Expand section "B.122. KafkaBridgeSpec 模式参考" Collapse section "B.122. KafkaBridgeSpec 模式参考" B.122.1. logging B.123. KafkaBridgeTls 模式参考 B.124. KafkaBridgeHttpConfig schema reference Expand section "B.124. KafkaBridgeHttpConfig schema reference" Collapse section "B.124. KafkaBridgeHttpConfig schema reference" B.124.1. CORS B.125. KafkaBridgeHttpCors schema reference B.126. KafkaBridgeConsumerSpec 模式参考 B.127. KafkaBridgeProducerSpec schema reference B.128. KafkaBridgeTemplate schema reference B.129. KafkaBridgeStatus 模式参考 B.130. KafkaConnector 模式参考 B.131. KafkaConnectorSpec 模式参考 B.132. KafkaConnectorStatus 模式参考 B.133. KafkaMirrorMaker2 模式参考 B.134. KafkaMirrorMaker2Spec 模式参考 B.135. KafkaMirrorMaker2ClusterSpec 模式参考 Expand section "B.135. KafkaMirrorMaker2ClusterSpec 模式参考" Collapse section "B.135. KafkaMirrorMaker2ClusterSpec 模式参考" B.135.1. config B.136. KafkaMirrorMaker2Tls 模式参考 B.137. KafkaMirrorMaker2MirrorSpec 模式参考 B.138. KafkaMirrorMaker2ConnectorSpec 模式参考 B.139. KafkaMirrorMaker2Status 模式参考 B.140. KafkaRebalance 模式参考 B.141. KafkaRebalanceSpec 模式参考 B.142. KafkaRebalanceStatus 模式参考 C. 使用您的订阅 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 B.22. TlsListenerConfiguration 模式参考 用于:KafkaListenerTls 属性描述 brokerCertChainAndKey 引用存放证书和私钥对的 Secret。证书可以选择包含整个链。 CertAndKeySecretSource Previous Next