MSK クラスターの Advertized.listeners 構成を設定しようとしています。ただし、次のエラーが返されます。
要件が満たされませんでした: inter.broker.listener.name は、advertized.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)