Timeout sending messages

0

Hey everyone.

I'm getting a timeout when trying to send messages:
ERROR Error when sending message to topic test with key: null, value: 4 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.

I have properly setup the cluster (which has ACTIVE state), and created a couple of topics (which I can list properly as well) using a client machine created using the guide with its security group added to the security group of the cluster nodes. Somehow though, I can't send messages.

Can anyone please help me troubleshoot my issue?

Edited by: joaquinscript on Feb 27, 2019 2:35 PM

已提問 5 年前檢視次數 373 次
1 個回答
0

Found the error, I was using ZookeeperConnectString instead of BootstrapBrokerString in the arguments for the producer and consumer BrokerList

已回答 5 年前

您尚未登入。 登入 去張貼答案。

一個好的回答可以清楚地回答問題並提供建設性的意見回饋,同時有助於提問者的專業成長。

回答問題指南