Created
July 12, 2020 22:16
-
-
Save AdvaithD/5be40727ff9c0fdf6dd4400360baa9ae to your computer and use it in GitHub Desktop.
connecterror
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| (org.apache.kafka.connect.runtime.Worker) | |
| [2020-07-12 22:12:45,478] ERROR Failed to start task test_es_sink-0 (org.apache.kafka.connect.runtime.Worker) | |
| org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Converter and which name matches io.confluent.connect.elasticsearch.ElasticsearchSinkConnector, available converters are: PluginDesc{klass=class io.confluent.connect.avro.AvroConverter, name='io.confluent.connect.avro.AvroConverter', version='undefined', encodedVersion=undefined, type=converter, typeName='converter', location='file:/usr/share/java/kafka-connect-storage-common/'}, PluginDesc{klass=class io.confluent.connect.json.JsonSchemaConverter, name='io.confluent.connect.json.JsonSchemaConverter', version='undefined', encodedVersion=undefined, type=converter, typeName='converter', location='file:/usr/share/java/confluent-control-center/'}, PluginDesc{klass=class io.confluent.connect.protobuf.ProtobufConverter, name='io.confluent.connect.protobuf.ProtobufConverter', version='undefined', encodedVersion=undefined, type=converter, typeName='converter', location='file:/usr/share/java/confluent-control-center/'}, PluginDesc{klass=class org.apache.kafka.connect.converters.ByteArrayConverter, name='org.apache.kafka.connect.converters.ByteArrayConverter', version='undefined', encodedVersion=undefined, type=converter, typeName='converter', location='file:/usr/share/java/confluent-control-center/'}, PluginDesc{klass=class org.apache.kafka.connect.converters.DoubleConverter, name='org.apache.kafka.connect.converters.DoubleConverter', version='undefined', encodedVersion=undefined, type=converter, typeName='converter', location='file:/usr/share/java/confluent-control-center/'}, PluginDesc{klass=class org.apache.kafka.connect.converters.FloatConverter, name='org.apache.kafka.connect.converters.FloatConverter', version='undefined', encodedVersion=undefined, type=converter, typeName='converter', location='file:/usr/share/java/confluent-control-center/'}, PluginDesc{klass=class org.apache.kafka.connect.converters.IntegerConverter, name='org.apache.kafka.connect.converters.IntegerConverter', version='undefined', encodedVersion=undefined, type=converter, typeName='converter', location='file:/usr/share/java/confluent-control-center/'}, PluginDesc{klass=class org.apache.kafka.connect.converters.LongConverter, name='org.apache.kafka.connect.converters.LongConverter', version='undefined', encodedVersion=undefined, type=converter, typeName='converter', location='file:/usr/share/java/confluent-control-center/'}, PluginDesc{klass=class org.apache.kafka.connect.converters.ShortConverter, name='org.apache.kafka.connect.converters.ShortConverter', version='undefined', encodedVersion=undefined, type=converter, typeName='converter', location='file:/usr/share/java/confluent-control-center/'}, PluginDesc{klass=class org.apache.kafka.connect.json.JsonConverter, name='org.apache.kafka.connect.json.JsonConverter', version='undefined', encodedVersion=undefined, type=converter, typeName='converter', location='file:/usr/share/java/confluent-control-center/'}, PluginDesc{klass=class org.apache.kafka.connect.storage.StringConverter, name='org.apache.kafka.connect.storage.StringConverter', version='undefined', encodedVersion=undefined, type=converter, typeName='converter', location='file:/usr/share/java/confluent-control-center/'} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment