org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches com.tuplejump.kafka.connect .cassandra.CassandraSink available connectors are: org.apache.kafka.connect. source.SourceConnector, org.apache.kafka.connect.file. FileStreamSinkConnector, org.apache.kafka.connect.sink.SinkConnector, org. apache.kafka.connect.tools.MockSinkConnector, com.evokly.kafka.connect.mqtt. MqttSourceConnector, org.apache.kafka.connect.tools.VerifiableSinkConnector, org.apache.kafka.connect.tools.MockConnector, org.apache.kafka.connect.tools .VerifiableSourceConnector, org.apache.kafka.connect.elasticsearchschema. ElasticsearchSinkConnector, org.apache.kafka.connect.file. FileStreamSourceConnector, org.apache.kafka.connect.tools. MockSourceConnector

Google Groups | Adarsh Lal | 2 months ago
  1. 0

    Kafka connect stops when connector with faulty configuration is registered

    Google Groups | 2 months ago | Adarsh Lal
    org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches com.tuplejump.kafka.connect .cassandra.CassandraSink available connectors are: org.apache.kafka.connect. source.SourceConnector, org.apache.kafka.connect.file. FileStreamSinkConnector, org.apache.kafka.connect.sink.SinkConnector, org. apache.kafka.connect.tools.MockSinkConnector, com.evokly.kafka.connect.mqtt. MqttSourceConnector, org.apache.kafka.connect.tools.VerifiableSinkConnector, org.apache.kafka.connect.tools.MockConnector, org.apache.kafka.connect.tools .VerifiableSourceConnector, org.apache.kafka.connect.elasticsearchschema. ElasticsearchSinkConnector, org.apache.kafka.connect.file. FileStreamSourceConnector, org.apache.kafka.connect.tools. MockSourceConnector
  2. 0

    [jira] [Commented] (KAFKA-2944) NullPointerException in KafkaConfigStorage when config storage starts right before shutdown request

    kafka-dev | 11 months ago | ASF GitHub Bot (JIRA)
    org.apache.kafka.connect.errors.ConnectException: Error writing root configuration to Kafka
  3. 0

    [jira] [Commented] (KAFKA-2944) NullPointerException in KafkaConfigStorage when config storage starts right before shutdown request

    kafka-dev | 11 months ago | ASF GitHub Bot (JIRA)
    org.apache.kafka.connect.errors.ConnectException: Error writing root configuration to Kafka
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    [jira] [Commented] (KAFKA-2944) NullPointerException in KafkaConfigStorage when config storage starts right before shutdown request

    kafka-dev | 11 months ago | ASF GitHub Bot (JIRA)
    org.apache.kafka.connect.errors.ConnectException: Error writing root configuration to Kafka
  6. 0

    [jira] [Commented] (KAFKA-2944) NullPointerException in KafkaConfigStorage when config storage starts right before shutdown request

    kafka-dev | 11 months ago | ASF GitHub Bot (JIRA)
    org.apache.kafka.connect.errors.ConnectException: Error writing root configuration to Kafka

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. org.apache.kafka.connect.errors.ConnectException

      Failed to find any class that implements Connector and which name matches com.tuplejump.kafka.connect .cassandra.CassandraSink available connectors are: org.apache.kafka.connect. source.SourceConnector, org.apache.kafka.connect.file. FileStreamSinkConnector, org.apache.kafka.connect.sink.SinkConnector, org. apache.kafka.connect.tools.MockSinkConnector, com.evokly.kafka.connect.mqtt. MqttSourceConnector, org.apache.kafka.connect.tools.VerifiableSinkConnector, org.apache.kafka.connect.tools.MockConnector, org.apache.kafka.connect.tools .VerifiableSourceConnector, org.apache.kafka.connect.elasticsearchschema. ElasticsearchSinkConnector, org.apache.kafka.connect.file. FileStreamSourceConnector, org.apache.kafka.connect.tools. MockSourceConnector

      at org.apache.kafka.connect.runtime.Worker.getConnectorClass()
    2. org.apache.kafka
      DistributedHerder.run
      1. org.apache.kafka.connect.runtime.Worker.getConnectorClass(Worker.java:226)
      2. org.apache.kafka.connect.runtime.Worker.startConnector(Worker.java:166)
      3. org.apache.kafka.connect.runtime.distributed.DistributedHerder.startConnector(DistributedHerder.java:789)
      4. org.apache.kafka.connect.runtime.distributed.DistributedHerder.startWork(DistributedHerder.java:755)
      5. org.apache.kafka.connect.runtime.distributed.DistributedHerder.handleRebalanceCompleted(DistributedHerder.java:715)
      6. org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:206)
      7. org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:176)
      7 frames
    3. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)[2016-10-12 10:50:22,773]
      1 frame