1

我有一个 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.
4

0 回答 0