Kafka Confluent S3 Connector „Fehlgeschlagen Klasse zu finden“

Question

Ich bin ein einfaches Beispiel quickstart versuchen, und ich bekomme:

Verursacht durch: org.apache.kafka.connect.errors.ConnectException: Fehler beim Fund jede Klasse, die Steckverbinder implementiert und die Namen übereinstimmt io.confluent.connect.s3.S3SinkConnector, verfügbar Anschlüsse sind: io.confluent.connect.jdbc.JdbcSinkConnector, io.confluent.connect.jdbc.JdbcSourceConnector, org.apache .kafka.connect.tools.MockSinkConnector, org.apache.kafka.connect.file.FileStreamSourceConnector, org.apac he.kafka.connect.sink.SinkConnector, io.confluent.connect.elasticsearch.ElasticsearchSinkConnector, org.apache.kafka.connect.tools.MockConnector, io.confluent.connect.hdfs.HdfsSinkConnector, org.apache. kafka.connect.file.FileStreamSinkConnector, org.apache.kafka.connect.tools.VerifiableSourceConnector, org.apache.kafka.connect.tools.VerifiableSinkConnector, org.apache.kafka.connect.tools.SchemaSourceConnector, org. apache.kafka.connect.source.SourceConnector, org.apache.kafka.connect.tools.MockSourceConnector, io.confluent.connect.hdfs.tools.SchemaSourceConnector

Dies ist eine brandneue VM mit der neuesten Confluent Platform 3.2.0, die über das Debian apt-Paket installiert wird. Ich kann sehen, dass CP 3.2.0 läuft. Warum sollte die S3-Konnektorklasse nicht verfügbar sein?

nicht sicher, ob dies ist verwandt, aber wenn ich tun:

ls -l /etc/ | grep kafka 
drwxr-xr-x 2 root root   4096 Apr 5 04:41 kafka 
drwxr-xr-x 2 root root   4096 Apr 5 04:39 kafka-connect-elasticsearch 
drwxr-xr-x 2 root root   4096 Apr 5 04:39 kafka-connect-hdfs 
drwxr-xr-x 2 root root   4096 Apr 5 04:39 kafka-connect-jdbc 
drwxr-xr-x 2 root root   4096 Apr 5 04:39 kafka-rest 

Die docs verweisen auf ein kafka-connect-s3-Verzeichnis, das in der Anlage eindeutig nicht existiert.

Ich verwende die Open-Source-Variante der Confluent-Plattform, aber gemäß https://www.confluent.io/product/compare/ enthält die Open-Source-Version den Confluent Amazon S3 Connect-Anschluss.

Answer 1

Das in 3.2.0 ein Verpackungsfehler war und ist in der neuesten Confluent Version, die ab heute (17. Mai 2017) festgelegt ist 3.2.1

Es mit dem S3-Anschluss auch ein Bug-Fix ist in die Version 3.2.1, also ist es besser, diese Version trotzdem zu verwenden.

Answer 2

Ich benutze CP 3.2-Version und ich habe unter dem Ordner im Download, der erforderliche jar (kafka-connect-s3-3.2.0) in Windows enthält, aber wenn installiert mit RPM ist nicht verfügbar.

Windows-enthält unter:

"konfluent-oss-3.2.0-2.11 \ konfluenten-3.2.0 \ share \ Java \ kafka-connect-s3".

Ein Problem sollte für diese RPM ausgelöst werden.

Answer 3

Als Abhilfe können Sie die Zip-oder tar-Version von http://confluent.io

herunterladen Von dort können Sie kafka-connect-s3 im etc und share/java Verzeichnis finden.