第 16 章 GenericKafkaListenerConfigurationBroker 模式参考
used in: GenericKafkaListenerConfiguration
GenericKafkaListenerConfigurationBroker 模式属性的完整列表
为监听程序配置代理设置。
主机,nodePort,loadBalancerIP, 和 annotations 属性的配置示例显示在 GenericKafkaListenerConfiguration schema 部分中。
16.1. 覆盖代理公告的地址 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
默认情况下,Apache Kafka 的 Streams 会尝试自动决定 Kafka 集群向其客户端公告的主机名和端口。在所有情况下都不够,因为运行 Apache Kafka 的基础架构可能无法提供可通过其访问 Kafka 的正确主机名或端口。
您可以指定代理 ID,并在监听程序的配置属性中自定义公告的主机名和端口。然后,Apache Kafka 的 Streams 会在 Kafka 代理中自动配置公告的地址,并将其添加到代理证书中,以便它可用于 TLS 主机名验证。覆盖公告的主机和端口适用于所有类型的监听程序。
配置 的外部路由监听程序的示例,带有覆盖公告的地址的覆盖
listeners:
#...
- name: external1
port: 9094
type: route
tls: true
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
# ...