# Kafka connect s3 sink not able to create connectors

**URL:** <https://forum.confluent.io/t/kafka-connect-s3-sink-not-able-to-create-connectors/3768>\
**Category:** Kafka Connect\
**Created:** [28 December 2021 03:33 UTC](https://forum.confluent.io/t/kafka-connect-s3-sink-not-able-to-create-connectors/3768 "2021-12-28T03:33:44Z")\
**Posts on this page:** 4\
**Page:** 1

<div class="post-metadata">

**Author:** ![Pramodniralakeri](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/pramodniralakeri/32/1437_2.png) [@Pramodniralakeri](https://forum.confluent.io/u/Pramodniralakeri)\
**Post date:** [28 December 2021 03:33 UTC](https://forum.confluent.io/t/kafka-connect-s3-sink-not-able-to-create-connectors/3768/1 "2021-12-28T03:33:44Z")

</div>

I’ve a dockerfile

```auto
FROM confluentinc/cp-kafka-connect:5.4.6-1-ubi8
RUN confluent-hub install --no-prompt confluentinc/kafka-connect-s3:10.0.4

ENV CONNECT_PLUGIN_PATH='/usr/share/java,/usr/share/confluent-hub-components/,/connectors/'
ENV CONNECT_BOOTSTRAP_SERVERS=kafka-ip:9092
ENV CONNECT_REST_ADVERTISED_HOST_NAME="kafka-connect"
ENV CONNECT_REST_PORT=8083
ENV CONNECT_REST_LISTENERS="http://localhost:8083"
ENV CONNECT_GROUP_ID=kafka-connect
ENV CONNECT_CONFIG_STORAGE_TOPIC=__connect-config
ENV CONNECT_OFFSET_STORAGE_TOPIC=__connect-offsets
ENV CONNECT_STATUS_STORAGE_TOPIC=__connect-status
ENV CONNECT_KEY_CONVERTER=org.apache.kafka.connect.json.JsonConverter
ENV CONNECT_VALUE_CONVERTER=org.apache.kafka.connect.json.JsonConverter
ENV CONNECT_INTERNAL_KEY_CONVERTER="org.apache.kafka.connect.json.JsonConverter"
ENV CONNECT_INTERNAL_VALUE_CONVERTER="org.apache.kafka.connect.json.JsonConverter"
ENV CONNECT_LOG4J_LOGGERS="org.apache.kafka.connect.runtime.rest=WARN,org.reflections=ERROR"
ENV CONNECT_CONFIG_STORAGE_REPLICATION_FACTOR="1"
ENV CONNECT_OFFSET_STORAGE_REPLICATION_FACTOR="1"
ENV CONNECT_STATUS_STORAGE_REPLICATION_FACTOR="1"
ENV AWS_ACCESS_KEY_ID=1234
ENV AWS_SECRET_ACCESS_KEY=1234

```

container starts but when I try to create a s3 sink connector getting error.

If I use PUT

```auto
curl -i -X PUT -H "Accept:application/json" \
    -H "Content-Type:application/json" http://localhost:8083/connectors/sink/config \
    -d '
 {
        "connector.class": "io.confluent.connect.s3.S3SinkConnector",
        "key.converter":"org.apache.kafka.connect.storage.StringConverter",
        "tasks.max": "1",
        "topics": "cats",
        "s3.region": "eu-west-1",
        "s3.bucket.name": "snowplow-kafka-s3-sink-test",
        "flush.size": "65536",
        "storage.class": "io.confluent.connect.s3.storage.S3Storage",
        "format.class": "io.confluent.connect.s3.format.avro.AvroFormat",
        "schema.generator.class": "io.confluent.connect.storage.hive.schema.DefaultSchemaGenerator",
        "schema.compatibility": "NONE",
        "partitioner.class": "io.confluent.connect.storage.partitioner.DefaultPartitioner",
        "transforms": "AddMetadata",
        "transforms.AddMetadata.type": "org.apache.kafka.connect.transforms.InsertField$Value",
        "transforms.AddMetadata.offset.field": "_offset",
        "transforms.AddMetadata.partition.field": "_partition"
    }
'

```

I get below error

```auto
HTTP/1.1 500 Internal Server Error
Date: Tue, 28 Dec 2021 03:18:51 GMT
Content-Type: application/json
Content-Length: 48
Server: Jetty(9.4.43.v20210629)

{"error_code":500,"message":"Request timed out"}

```

If I use POST, get

```auto
HTTP/1.1 405 Method Not Allowed
Date: Tue, 28 Dec 2021 03:20:57 GMT
Content-Length: 58
Server: Jetty(9.4.43.v20210629)

{"error_code":405,"message":"HTTP 405 Method Not Allowed"}

```

[http://localhost:8083/](http://localhost:8083/) works and returns 200 OK  
[http://localhost:8083/connectors](http://localhost:8083/connectors) returns (empty array)

Kafka and S3 bucket all works fine, AWS key also verified and it’s correct

---

<div class="post-metadata">

**Author:** ![Pramodniralakeri](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/pramodniralakeri/32/1437_2.png) [@Pramodniralakeri](https://forum.confluent.io/u/Pramodniralakeri)\
**Post date:** [28 December 2021 05:19 UTC](https://forum.confluent.io/t/kafka-connect-s3-sink-not-able-to-create-connectors/3768/2 "2021-12-28T05:19:32Z")

</div>

Logged in container, but within container also not worked

---

<div class="post-metadata">

**Author:** ![rick](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/rick/32/49_2.png) [@rick](https://forum.confluent.io/u/rick)\
**Post date:** [28 December 2021 16:23 UTC](https://forum.confluent.io/t/kafka-connect-s3-sink-not-able-to-create-connectors/3768/3 "2021-12-28T16:23:52Z")

</div>

@Pramodniralakeri Some debugging steps I would try:

- Check the log file in the running container to try and ascertain more information about the exception message `Request timed out`.
- If I understand correctly, `POST`ing to `localhost:8083/connectors/name/config` is not supported, so the `405` for that seems appropriate. If you’d like to try a `POST`, use the `connectors` route directly with a payload that contains the `name` wrapper, here is an example: [Connect REST Interface | Confluent Documentation](https://docs.confluent.io/platform/current/connect/references/restapi.html#post--connectors)

I think your best bet may be to evaluate the log files and try and determine if the `Request timed out` is a result of a failure related to the connection to S3.

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/flex019/uploads/confluentcommunity/original/1X/c49438c90c9df282e9996fdf6971be890c71b65a.svg) [@system](https://forum.confluent.io/u/system)\
**Post date:** [27 January 2022 16:24 UTC](https://forum.confluent.io/t/kafka-connect-s3-sink-not-able-to-create-connectors/3768/4 "2022-01-27T16:24:30Z")

</div>

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.