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
