aws msk设置播发侦听器

zyfwsgd6  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(327)

我正在尝试设置我的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)

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题