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년 전

로그인하지 않았습니다. 로그인해야 답변을 게시할 수 있습니다.

좋은 답변은 질문에 명확하게 답하고 건설적인 피드백을 제공하며 질문자의 전문적인 성장을 장려합니다.

질문 답변하기에 대한 가이드라인

관련 콘텐츠