7.3. Kafka 集群配置

Apache Kafka 的流支持以下存储配置选项来管理 Kafka 和 ZooKeeper 数据：

除了这些选项外，您还可以将 Apache Kafka 的 Streams 配置为使用分层存储。分层存储是 Kafka 中的 早期访问 功能，通过利用具有不同特征的并行使用存储类型为数据管理提供更大的灵活性。虽然其中一项基本存储选项必须配置为分层存储，但其支持组合，例如使用对象存储的块存储，以提高性能和可扩展性。

存储类型使用 storage 或 tier Storage 配置属性在自定义资源中指定：

对于存储在磁盘上的 Kafka 和 ZooKeeper 数据，存储的文件系统格式必须是 XFS 或 EXT4。如果基础架构支持，可以增加现有 Kafka 集群使用的磁盘容量。

侦听器配置客户端如何连接到 Kafka 集群。

通过在 Kafka 集群中为每个监听程序指定唯一名称和端口，您可以配置多个监听程序。

支持以下监听程序类型：

您可以为监听器启用 TLS 加密，并配置身份验证。

内部监听程序通过指定一个 internal 类型来公开 Kafka：

外部监听程序通过指定一个外部 类型 来公开 Kafka：

如果您使用 OAuth 2.0 进行基于令牌的身份验证，您可以将监听程序配置为使用授权服务器。

机架代表数据中心，或数据中心中的机架，或可用性区域。配置机架感知，以在机架之间分发 Kafka 代理 pod 和主题副本。使用 rack 属性启用机架感知，以指定 topologyKey。topologyKey 是分配给 OpenShift worker 节点的标签的名称，用于标识机架。Apache Kafka 的流会为每个 Kafka 代理分配一个机架 ID。Kafka 代理使用 ID 在机架间分布分区副本。您还可以指定 RackAwareReplicaSelector 选择器插件，以用于机架感知。该插件与代理和消费者的机架 ID 匹配，以便消息从最接近的副本消耗。要使用插件，消费者还必须启用机架感知。您可以在 Kafka Connect、M MirrorMaker 2 和 Kafka Bridge 中启用机架感知。