PubSub Kafka Connect extrémité de connexion de noeud d'exception du fichier

Question

Pendant l'exécution PubSub Kafka se connecter en utilisant la commande:

.\bin\windows\connect-standalone.bat .\etc\kafka\WorkerConfig.properties 
.\etc\kafka\configSink.properties .\etc\kafka\configSource.properties 

Je reçois cette erreur:

Sending metadata request {topics=[test]} to node -1 
could not scan file META-INF/MANIFEST.MF in url file:/C:/confluent-3.3.0/bin/../share/java/kafka-serde-tools/commons-compress-1.8.1.jar with scanner SubTypesScanner 
could not scan file META-INF/MANIFEST.MF in url file:/C:/confluent-3.3.0/bin/../share/java/kafka-serde-tools/commons-compress-1.8.1.jar with scanner TypeAnnotationsScanner 
could not scan file META-INF/LICENSE.txt in url file:/C:/confluent-3.3.0/bin/../share/java/kafka-serde-tools/commons-compress-1.8.1.jar with scanner SubTypesScanner 
could not scan file META-INF/LICENSE.txt in url file:/C:/confluent-3.3.0/bin/../share/java/kafka-serde-tools/commons-compress-1.8.1.jar with scanner TypeAnnotationsScanner 
could not scan file META-INF/NOTICE.txt in url file:/C:/confluent-3.3.0/bin/../share/java/kafka-serde-tools/commons-compress-1.8.1.jar with scanner SubTypesScanner 
could not scan file META-INF/NOTICE.txt in url file:/C:/confluent-3.3.0/bin/../share/java/kafka-serde-tools/commons-compress-1.8.1.jar with scanner TypeAnnotationsScanner 
Connection with localhost/127.0.0.1 disconnected 
java.io.EOFException 
    at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83) 
    at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71) 
    at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:154) 
    at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:135) 
    at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:323) 
    at org.apache.kafka.common.network.Selector.poll(Selector.java:283) 
    at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) 
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:360) 
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224) 
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:192) 
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:163) 
    at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:181) 
    at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:229) 
    at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.ensurePartitionAssignment(ConsumerCoordinator.java:366) 
    at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:975) 
    at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:938) 
    at org.apache.kafka.connect.runtime.WorkerSinkTask.pollConsumer(WorkerSinkTask.java:316) 
    at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:222) 
    at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:170) 
    at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:142) 
    at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140) 
    at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175) 
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 
    at java.util.concurrent.FutureTask.run(FutureTask.java:266) 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
    at java.lang.Thread.run(Thread.java:745) 
Node -1 disconnected. 
Bootstrap broker localhost:2181 disconnected 
Cancelled GROUP_COORDINATOR request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@643b72cb, request=RequestSend(header={api_key=10,api_version=0,correlation_id=0,client_id=consumer-1}, body={group_id=connect-CPSConnectorSink}), createdTimeMs=1504105687600, sendTimeMs=1504105687724) with correlation id 0 due to node -1 being disconnected 
Give up sending metadata request since no node is available 

Je courais un courtier de kafka local et Zookeeper locale . Toute aide sur la façon de résoudre ce problème serait génial!

fichiers propriété here

Answer 1

Ainsi, après avoir essayé diverses corrections, je trouve que j'utilisais le numéro de port incorrect pour localhost. Le port 2181 était utilisé par Zookeeper tandis que le port 9092 était utilisé par Kafka Server. Donc, ma propriété originale WorkerConfig.properties était:

bootstrap.servers=localhost:2181 

Quand il doit être

bootstrap.server=localhost:9092 

Ainsi, morale de l'histoire est de vous assurer que vous utilisez le numéro d'hôte et le port de votre Kafka serveurs dans votre fichier de propriétés de connecteur, le mien étant WorkerConfig. Ceci est illustré here. Cela peut sembler logique, mais j'ai changé le numéro de port en essayant de corriger d'autres erreurs, mais sans le savoir, j'ai ajouté une autre erreur. Donc, si vous recevez l'erreur ci-dessus, vérifiez votre propriété bootstrap.server.