Как мне настроить 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?