我正在尝试设置我的msk群集的advised.listeners配置。但是,我得到了以下错误:
要求失败:inter.broker.listener.name必须是在Adverted.listeners中定义的侦听器名称
我不知道这个错误是什么意思。我试过找它,但什么也找不到。我有我所有的专有网络相关的配置设置。我能够从集群中读取主题名和其他配置。
我使用的是python的合流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)
暂无答案!
目前还没有任何答案,快来回答吧!