# Amazon Redshift Sink Connector for Confluent Cloud

**URL:** <https://forum.confluent.io/t/amazon-redshift-sink-connector-for-confluent-cloud/10523>\
**Category:** Managed Connectors\
**Created:** [17 April 2024 09:54 UTC](https://forum.confluent.io/t/amazon-redshift-sink-connector-for-confluent-cloud/10523 "2024-04-17T09:54:23Z")\
**Posts on this page:** 1\
**Page:** 1

<div class="post-metadata">

**Author:** ![rlapao](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/rlapao/32/3718_2.png) [@rlapao](https://forum.confluent.io/u/rlapao)\
**Post date:** [17 April 2024 09:54 UTC](https://forum.confluent.io/t/amazon-redshift-sink-connector-for-confluent-cloud/10523/1 "2024-04-17T09:54:23Z")

</div>

On the connector documentation is referred that types `Decimal` and `Timestamp` are supported ([Amazon Redshift Sink Connector for Confluent Platform | Confluent Documentation](https://docs.confluent.io/kafka-connectors/aws-redshift/current/overview.html)).

Although it’s not specified I guess this include AVRO Schemas (registered on Schema Registry).

I’m trying this connector on Clonfluent Cloud but I’m not able to understand how this type is specified on the AVRO schema.

I created a dummy topic with the following schema for the Value:

```auto
{
	"type": "record",
	"name": "AvroPayments",
	"namespace": "com.code.data.domain.generated",
	"fields": [
		.....
		{
			"name": "chargedAt",
			"type": {
				"type": "long",
				"logicalType": "timestamp-micros",
				"connect.name": "org.apache.kafka.connect.data.Timestamp"
			},
			"doc": "Charge's charge timestamp in UTC."
		},
		{
....

```

And produced a message for the topic with the connector Active.

```auto
{
...
  "chargedAt": -782801317000000,
...
}

```

Another thing that I find unexpected is that the same message on KafkaUI appears differently:

```auto
{
	...
	"chargedAt": "1945-03-12T19:11:23Z",
	...
}

```

Although the message is consumed from the topic no record is written on the database (Redshift) where the table DDL goes like this:

```auto
chargedat	bigint

```

I’m not sure that I’m specifying the type correctly but I also don’t see how to do so on the documentation.

Not sure if the connector code is accessible so I can better understand what is being done.

Thanks
