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