connect-file-sink not working:COORDINATOR_NOT_AVAILABLE

150 views
Skip to first unread message

hyjal

unread,
Nov 12, 2017, 10:44:47 PM11/12/17
to Confluent Platform
Architecture:
2 broker node kafka cluster.

connect-file-sink.properties
name=local-file-sink
connector.class=FileStreamSink
tasks.max=1
file=/tmp/test.sink.txt
topics=multest

topics
Topic: multest      Partition: 0      Leader:95   Replicas: 95,5
Topic: multest      Partition: 1      Leader:5     Replicas: 5,95
Topic: multest      Partition: 2      Leader:95   Replicas: 95,5

log
DEBUG Sending GroupCoordinator request for group connect-local-file-sink to broker 172.30.2.2:9092(id: 95 rack: null)(org.apache.kafka.clients.consume.internals.AbstactCoordinator:582)
DEBUG Received GroupCoordinator response ClientResponse(receivedTimeMs=1510513121037, latencyMs=0, disconnected=false, requestHeader={api_key=10,api_version=1,correlation_id=114,client_id=consumer-1}), responseBody=FindCoordinatorResponse(throttleTimeMs=0, errorMessage='null', error=COORDINATOR_NOT_AVAILABLE, node=:-1 (id: -1 rack: null))) for group connect-local-file-sink(org.apache.kafka.clients.consume.internals.AbstactCoordinator:593)
DEBUG Group coordinator lookup for group connect-local-file-sink failed: The coordinator is not available.(org.apache.kafka.clients.consume.internals.AbstactCoordinator:615)
DEBUG Coordinator discovery failed for group connect-local-file-sink, refreshing metadata(org.apache.kafka.clients.consume.internals.AbstactCoordinator:225)

I am using below command to start kafka Connect.
./bin/connect-standalone etc/kafka/connect-standalone.properties etc/kafka/connect-file-sink.properties 

Thanks
Reply all
Reply to author
Forward
0 new messages