I want to use TimeBasePartitioner and use RecordField for partitioning.
here is my configs:
"partition.duration.ms": "86400000",
"partitioner.class": "io.confluent.connect.storage.partitioner.TimeBasedPartitioner",
"timestamp.extractor": "RecordField",
"timestamp.field": "timestamp",
"timezone": "UTC",
"locale": "US",
my input is something like this:
{
"id": 5653383,
"service_type": 1,
"speed": 7,
"status": 4,
"timestamp": 1725089735
}
but all records sink to 1970-01-20
Also I tried to use “transforms”: “TimestampConverter” with these configs:
"transforms": "TimestampConverter",
"transforms.TimestampConverter.field": "timestamp",
"transforms.TimestampConverter.target.type": "Timestamp",
"transforms.TimestampConverter.type": "org.apache.kafka.connect.transforms.TimestampConverter$Value",
"transforms.TimestampConverter.unix.precision": "milliseconds",
but it parsed all values to 1970-01-20