Как установить S3SinkConnector (Не удалось найти класс)

Question

Как настроить S3SinkConnector для потоковой передачи данных из моей темы в корзину S3? Я скачал плагин из слияния концентратора, создал файл connect-standalone.properties а также s3-sink.properties,

Когда я пытаюсь бежать ./connect-standalone.sh connect-standalone.properties s3-sink.propertiesЯ получил ошибку:

[2019-06-25 15:43:52,841] ERROR Failed to create job for s3-sink.properties (org.apache.kafka.connect.cli.ConnectStandalone:102)
[2019-06-25 15:43:52,842] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:113)
java.util.concurrent.ExecutionException: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches io.confluent.connect.s3.S3SinkConnector

Но я вижу, что этот плагин доступен:

available connectors are: PluginDesc{klass=class io.confluent.connect.s3.S3SinkConnector, name='io.confluent.connect.s3.S3SinkConnector', version='5.2.2', encodedVersion=5.2.2, type=sink, typeName='sink', location='file:/home/ec2-user/kafka-plugins/confluentinc-kafka-connect-s3-5.2.2/'}

Также я попытался экспортировать CLASSPATH, используя export CLASSPATH=/home/ec2-user/kafka-plugins и до сих пор не повезло.

Как настроить S3SinkConnector с помощью AWS MSK?

Answer 1

Вы не должны экспортировать CLASSPATH

Вы должны настроить это в свойствах connect-standalone

plugin.path=/home/ec2-user/kafka-plugins