Skip to content

Error 500 Request failed #15

@arezvani

Description

@arezvani

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

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions