B.18. GenericKafkaListenerConfigurationBroker schema reference
用于:GenericKafkaListenerConfiguration
为外部监听程序配置代理服务覆盖。
您可以在 GenericKafkaListenerConfigurationBootstrap 模式中 看到 nodePort、host、loadBalancerIP 和 annotations 属性的示例配置,它为外部监听器配置 bootstrap 服务覆盖。
代理公告的地址
默认情况下,AMQ Streams 会尝试自动确定 Kafka 集群公告给客户端的主机名和端口。这并不适用于所有情况,因为运行 AMQ Streams 的基础架构可能无法提供可以通过其访问 Kafka 的正确主机名或端口。
您可以指定一个代理 ID,并在外部监听器 的配置 属性中自定义公告的主机名和端口。然后,AMQ Streams 将自动在 Kafka 代理中配置公告的地址,并将其添加到代理证书中,以便用于 TLS 主机名验证。覆盖公告的主机和端口可供所有类型的外部监听器使用。
配置了针对公告地址覆盖的外部 路由 监听程序示例
listeners:
#...
- name: external
port: 9094
type: route
tls: true
authentication:
type: tls
configuration:
brokers:
- broker: 0
advertisedHost: example.hostname.0
advertisedPort: 12340
- broker: 1
advertisedHost: example.hostname.1
advertisedPort: 12341
- broker: 2
advertisedHost: example.hostname.2
advertisedPort: 12342
# ...
| 属性 | 描述 |
|---|---|
| broker | kafka 代理的 ID(代理标识符)。代理 ID 从 0 开始,对应于代理副本数。 |
| 整数 | |
| advertisedHost |
代理的 advertised |
| 字符串 | |
| advertisedPort |
代理的 advertised |
| 整数 | |
| 主机 |
代理主机。此字段将用于 Ingress 资源或 Route 资源,以指定所需的主机名。此字段只能与 |
| 字符串 | |
| nodePort |
每个broker 服务的节点端口。此字段只能用于 |
| 整数 | |
| loadBalancerIP |
使用此字段中指定的 IP 地址请求 loadbalancer。此功能取决于底层云供应商是否支持在创建负载均衡器时指定 |
| 字符串 | |
| annotations |
添加到 |
| map |