-
Notifications
You must be signed in to change notification settings - Fork 31
Description
I build your project and get connect-fieldandtime-partitioner-1.1.0-SNAPSHOT.jar . Then I copy that in /usr/share/confluent-hub-components/confluentinc-kafka-connect-s3/lib/. When I run connector with these configs:
curl -X POST -H "Content-Type: application/json" --data '{
"name": "s3-sink",
"config": {
"connector.class": "io.confluent.connect.s3.S3SinkConnector",
"tasks.max": "1",
"topics": "test",
"s3.bucket.name": "backup-redis",
"s3.region": "us-east-1",
"flush.size": "50",
"storage.class": "io.confluent.connect.s3.storage.S3Storage",
"format.class": "io.confluent.connect.s3.format.parquet.ParquetFormat",
"partitioner.class": "com.canelmas.kafka.connect.FieldAndTimeBasedPartitioner",
"partition.duration.ms" : 300000,
"path.format": "'year'=YYYY/'month'=MM/'day'=dd",
"locale" : "US",
"timezone" : "UTC",
"partition.field.name": "MSISDN",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"key.converter.schemas.enable": "false",
"value.converter.schemas.enable": "true",
"aws.access.key.id": "CEGLR7TCEN471OHFPKOE",
"aws.secret.access.key": "qaSvzHlkkdzEiFRKeYu1NehTnzP1PY5FYxDOmq6e",
"store.url": "http://192.168.96.108:10049",
"timestamp.extractor": "RecordField",
"timestamp.field" : "clientCreationDate",
"name": "s3-sink"
}}' http://localhost:8083/connectors
I get this error:
<title>Error 500 Request failed.</title>HTTP ERROR 500 Request failed.
URI: | /connectors |
---|---|
STATUS: | 500 |
MESSAGE: | Request failed. |
SERVLET: | org.glassfish.jersey.servlet.ServletContainer-29d8d7a9 |
Powered by Jetty:// 9.4.33.v20201020