问题描述
我最近在我的 MSK 集群配置中添加了 advertised.listeners
属性。使用的命令是
/usr/local/kafka/bin/kafka-configs.sh --bootstrap-server b-1.xxxxxxxxx.c4.kafka.xxxxxxxxx.amazonaws.com:9094 \
--entity-type brokers \
--entity-name 1 \
--alter \
--command-config kafka.client.properties \
--add-config advertised.listeners=[CLIENT_SECURE://b-1.xxxxxxxxx.c4.kafka.xxxxxxxxx.amazonaws.com:9002,REPLICATION://b-1-internal.xxxxxxxxx.kafka.xxxxxxxxx.amazonaws.com:9093,REPLICATION_SECURE://b-1-internal.xxxxxxxxx.kafka.xxxxxxxxx.amazonaws.com:9095]
但是,现在如果我尝试使用以下命令恢复配置
/usr/local/kafka/bin/kafka-configs.sh --bootstrap-server b-1.xxxxxxxxx.kafka.xxxxxxxxx.amazonaws.com:9002 \
--entity-type brokers \
--entity-name 1 \
--describe \
--all \
--command-config kafka.client.properties
我在跟踪日志中收到一条消息,说 "Client is not ready to send to node"
。
最初我认为这与安全组有关,但确认它们是开放的并允许流量。任何帮助都会像往常一样不胜感激!
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)