Multiple advertised listeners

    为确保客户端能够从内部或外部网络连接到 Pulsar 集群,Pulsar 在 broker 配置文件中引入了两个配置项: 和 internalListenerName,保证 broker 支持多个 Advertised 监听器,也实现了内部和外部网络流量之间的隔离。

    • internalListenerName:用于指定 broker 使用的内部服务的 URL。 你可以选择 advertisedListeners 中某一个监听器的名称作为 internalListenerName 的值。 如果没有指定 ,则 broker 默认使用 Advertised 监听器列表中的第一个监听器作为 internalListenerName 的值。

    使用多个 Advertised 监听器

    Pulsar 客户端使用多个 Advertised 监听器需要以下两步。

    1. 在 broker 配置文件配置多个 Advertised 监听器。
    1. PulsarClient client = PulsarClient.builder()
    2. .serviceUrl("pulsar://xxxx:6650")
    3. .build();