1.3. 配置监听程序以连接到 Kafka 代理
监听器用于客户端与 Kafka 代理的连接。AMQ Streams 提供了一个通用 GenericKafkaListener
模式,它带有属性来配置通过 Kafka
资源配置监听程序。
GenericKafkaListener
提供了灵活的监听程序配置方法。您可以指定属性来配置用于在 OpenShift 集群 或外部 监听程序内进行连接 的内部 监听程序。
每个侦听器都 定义为 Kafka
资源中的一个数组。您可以根据需要配置任意数量的监听程序,只要其名称和端口是唯一的。您可以使用身份验证为安全连接配置监听程序。
1.3.1. 配置内部监听程序 复制链接链接已复制到粘贴板!
内部监听程序将客户端连接到 OpenShift 集群中的 Kafka 代理。内部
类型监听程序配置使用无头服务和提供给代理 pod 的 DNS 名称。
您可能需要将 OpenShift 网络加入外部网络。在这种情况下,您可以配置一个 内部
类型监听程序(使用 useServiceDnsDomain
属性),以便不使用 OpenShift 服务 DNS 域(通常为 .cluster.local
)。
您还可以配置 cluster-ip
类型的监听程序,它基于每个broker ClusterIP
服务公开 Kafka 集群。当您无法通过无头服务路由或者您希望纳入自定义访问机制时,这个选项是一个实用的选项。例如,您可以在为特定的 Ingress Controller 或 OpenShift 网关 API 构建自己的类型的外部监听程序时使用此监听程序。
1.3.2. 配置外部监听程序 复制链接链接已复制到粘贴板!
配置外部监听程序以处理来自需要不同验证机制的网络对 Kafka 集群的访问。
您可以使用指定的连接机制(如负载均衡器或路由)为 OpenShift 环境外的客户端访问配置外部监听程序。
1.3.3. 提供监听程序证书 复制链接链接已复制到粘贴板!
您可以为启用了 TLS 加密的 TLS 监听器或外部监听程序提供自己的服务器证书,称为 Kafka 侦听器证书。如需更多信息,请参阅 Kafka 侦听器证书。
如果您在使用外部监听程序时需要扩展 Kafka 集群,可能会触发所有 Kafka 代理的滚动更新。这取决于配置。