2

我正在尝试设置我的 MSK 集群的 Advertisementd.listeners 配置。但是,我收到以下错误:

要求失败:inter.broker.listener.name 必须是在 Advertisementd.listeners 中定义的侦听器名称

我不确定这个错误是什么意思。我已经尝试搜索它,但什么也没有出现。我有所有与 VPC 相关的配置设置。我能够从集群中读取主题名称和其他配置。

我正在使用 python 的 confluent_kafka 模块的管理客户端。

这是代码:

import confluent_kafka.admin
from confluent_kafka.admin import AdminClient, ConfigResource

a = AdminClient({'bootstrap.servers': '<server>:<port>'})
print(a.list_topics(timeout=5).topics) # Confirm connection

resources = list()
resources.append(ConfigResource(restype='BROKER',name='<broker_id', set_config={'advertised.listeners':'REPLICATION://<server>:<port>'}))
returned_futures = a.alter_configs(resources)
4

0 回答 0