Я пробую простой пример быстрого запуска и получаю:
Вызвано: org.apache.kafka.connect.errors.ConnectException: не удалось найти какой-либо класс, реализующий Connector и имя которого соответствует io.confluent.connect.s3.S3SinkConnector, доступные соединители: io.confluent.connect.jdbc.JdbcSinkConnector , io.confluent.connect.jdbc.JdbcSourceConnector, org.apache.kafka.connect.tools.MockSinkConnector, org.apache.kafka.connect.file.FileStreamSourceConnector, org.apache.kafka.connect.sink.Sio.Connector, .connect.elasticsearch.ElasticsearchSinkConnector, org.apache.kafka.connect.tools.MockConnector, io.confluent.connect.hdfs.HdfsSinkConnector, org.apache.kafka.connect.file.FileStreamSinkConnector.folska.apache .VerifiableSourceConnector, org.apache.kafka.connect.tools.VerifiableSinkConnector, org.apache.kafka.connect.tools.SchemaSourceConnector, org.apache.kafka.connect.source.SourceConnector, org.apache.kafka.connect.connect.tools , io.confluent.connect.hdfs.tools.SchemaSour ceConnector
Это совершенно новая виртуальная машина с последней версией Confluent Platform 3.2.0, установленной с помощью пакета Debian apt. Я вижу, что он определенно работает под управлением CP 3.2.0. Почему не будет доступен класс разъема S3?
Не уверен, связано ли это, но если да:
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
Документы ссылаются на каталог kafka-connect-s3, которого явно не существует в установке.
Я использую вариант платформы Confluent с открытым исходным кодом, но в соответствии с https://www.confluent.io/product/compare/, версия с открытым исходным кодом включает коннектор Confluent Amazon S3 Connect.
