kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jagannath Bilgi <jsbi...@yahoo.com.INVALID>
Subject Kafka-Connect- org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
Date Fri, 27 Apr 2018 20:09:57 GMT
Hi Team,
I am new to Kafka. Would like to explore option of using Kafka during data processing.
Using Oracle virtual box for practicing Kafka and zookeeper. Below are the steps followed
to deploy and test.
1) Start docker-compose
2) Get into Kafka container. Command (docker exec -it proj1_kafka-1_1 bash)3) Move to working
directory4) Create file referred in source property file.5) Start Kafka -connect. Command
(/usr/bin/connect-standalone /jb/connect-standalone.properties /jb/connect-file-source.properties
/jb/connect-file-sink.properties)
However getting below error message
[2018-04-27 14:35:56,595] ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectStandalone:122)org.apache.kafka.connect.errors.ConnectException:
Failed to connect to and describe Kafka cluster. Check worker's broker connection and security
properties.       at org.apache.kafka.connect.util.ConnectUtils.lookupKafkaClusterId(ConnectUtils.java:64) 
     at org.apache.kafka.connect.util.ConnectUtils.lookupKafkaClusterId(ConnectUtils.java:45) 
     at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:81)Caused
by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException:
Timed out waiting for a node assignment.       at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45) 
     at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32) 
     at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89) 
     at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:258) 
     at org.apache.kafka.connect.util.ConnectUtils.lookupKafkaClusterId(ConnectUtils.java:58) 
     ... 2 moreCaused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting
for a node assignment.
Please advise how to resolve the same.
NB. Attached docker compose file and other property files used.
Thanks and regards
Jagannath S Bilgi

Mime
  • Unnamed multipart/mixed (inline, None, 0 bytes)
View raw message