title: Failed to find the class io.confluent.connect.gcs.GcsSinkConnector while starting kafka-gcs confluent connector
body: <p>I am using confluent connector for kafka and Google Cloud Storage(GCS). I installed confluent using:</p>
  
  <p>(I am doing this on Ubuntu 16.04 and all these commands were executed in the home directory.)</p>
  
  <pre><code>curl https://packages.confluent.io/archive/5.0/confluent-5.0.0-2.11.tar.gz | tar xz
  </code></pre>
  
  <p>I then installed confluent-hub by:</p>
  
  <pre><code>curl http://client.hub.confluent.io/confluent-hub-client-latest.tar.gz | tar xz
  </code></pre>
  
  <p>I then installed the kafka-GCS connector using:</p>
  
  <pre><code>confluent-hub install confluentinc/kafka-connect-gcs:5.0.1
  </code></pre>
  
  <p>I then export the path using:</p>
  
  <pre><code>export PATH=&lt;insert-path-here&gt;/confluent-5.0.0/bin:$PATH
  </code></pre>
  
  <p>I then start confluent using:</p>
  
  <pre><code>confluent start
  </code></pre>
  
  <p>it shows:</p>
  
  <pre><code>This CLI is intended for development only, not for production
  https://docs.confluent.io/current/cli/index.html
  
  Using CONFLUENT_CURRENT: /tmp/confluent.pc9RaNNQ
  Starting zookeeper
  zookeeper is [UP]
  Starting kafka
  kafka is [UP]
  Starting schema-registry
  schema-registry is [UP]
  Starting kafka-rest
  kafka-rest is [UP]
  Starting connect
  connect is [UP]
  Starting ksql-server
  ksql-server is [UP]
  Starting control-center
  control-center is [UP]
  </code></pre>
  
  <p>Checking confluent by:</p>
  
  <pre><code>confluent status
  </code></pre>
  
  <p>gives me:</p>
  
  <pre><code>This CLI is intended for development only, not for production
  https://docs.confluent.io/current/cli/index.html
  
  control-center is [UP]
  ksql-server is [UP]
  connect is [UP]
  kafka-rest is [UP]
  schema-registry is [UP]
  kafka is [UP]
  zookeeper is [UP]
  </code></pre>
  
  <p>All is fine up until now. Zookeeper and kafka are both up and running. Now when I use the following command to start the kafka-gcs confluent connector:</p>
  
  <pre><code>confluent load gcs -d quickstart-gcs.properties
  </code></pre>
  
  <p>it gives the following error:</p>
  
  <pre><code>Failed to find any class that implements Connector and which name 
  matches io.confluent.connect.gcs.GcsSinkConnector
  </code></pre>
  
  <p>The quickstart-gcs.properties file is in the home directory and looks something like this:</p>
  
  <pre><code>name=gcs-sink
  connector.class=io.confluent.connect.gcs.GcsSinkConnector
  tasks.max=1
  topics=test
  
  gcs.bucket.name=test_bucket
  gcs.part.size=5242880
  flush.size=3
  
  gcs.credentials.path=/path/to/kafka/key.json
  
  storage.class=io.confluent.connect.gcs.storage.GcsStorage
  format.class=io.confluent.connect.gcs.format.avro.AvroFormat
  partitioner.class=io.confluent.connect.storage.partitioner
                    .DefaultPartitioner
  
  schema.compatibility=NONE
  
  confluent.topic.bootstrap.servers=localhost:9092
  confluent.topic.replication.factor=1
  
  confluent.license=
  </code></pre>
  
  <p>The line:</p>
  
  <pre><code>partitioner.class=io.confluent.connect.storage.partitioner
                    .DefaultPartitioner
  </code></pre>
  
  <p>actually reads:</p>
  
  <pre><code>partitioner.class=io.confluent.connect.storage.partitioner.DefaultPartitioner
  </code></pre>
  
  <p>I had to write it like that because of the editor limitations. Sorry for that.</p>
  
  <p>The last line in quickstart-gcs.properties as per the <a href="https://docs.confluent.io/current/connect/kafka-connect-gcs/index.html#connect-gcs" rel="nofollow noreferrer">documentations</a> actually reads:</p>
  
  <pre><code>confluent.license="" 
  </code></pre>
  
  <p>but it did not work for me.</p>
  
  <p>Any help here is greatly appreciated.</p>
  
  <p><strong>EDIT 1:</strong> As per @cricket_007 comment:</p>
  
  <pre><code>curl http://localhost:8083/connector-plugins
  </code></pre>
  
  <p>gives:</p>
  
  <blockquote>
    <p>[{"class":"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector","type":"sink","version":"5.0.0"},{"class":"io.confluent.connect.hdfs.HdfsSinkConnector","type":"sink","version":"5.0.0"},{"class":"io.confluent.connect.hdfs.tools.SchemaSourceConnector","type":"source","version":"2.0.0-cp1"},{"class":"io.confluent.connect.jdbc.JdbcSinkConnector","type":"sink","version":"5.0.0"},{"class":"io.confluent.connect.jdbc.JdbcSourceConnector","type":"source","version":"5.0.0"},{"class":"io.confluent.connect.s3.S3SinkConnector","type":"sink","version":"5.0.0"},{"class":"io.confluent.connect.storage.tools.SchemaSourceConnector","type":"source","version":"2.0.0-cp1"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector","type":"sink","version":"2.0.0-cp1"},{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector","type":"source","version":"2.0.0-cp1"}]</p>
  </blockquote>