我有一个 Spring Boot 应用程序,它会向Kafka (AWS MSK)
. 从我的本地机器上,我可以将消息发送到MSK
同一个应用程序无法从AWS Fargate
.
Logs:
Updated cluster metadata version 1 to Cluster(id = null, nodes = [<bootstrap server> (id: -1 rack: null), <bootstrap server> (id: -2 rack: null),<bootstrap server> (id: -3 rack: null)], partitions = [], controller = null)
Initialize connection to node <bootstrap server> (id: -2 rack: null) for sending metadata request
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.