我需要在filestreamsink连接器中使用文件分区。但我尝试使用下面提到的时间戳。但我没有得到。请纠正我的实现或建议替代方法
Kafka Connect Sink连接器配置

name=your-file-sink-connector
connector.class=FileStreamSink
tasks.max=1

字符串
Kafka主题和输出目录

topics=your-kafka-topic
file=/path/to/output/directory/data

型
基于消息时间戳对文件进行分区

transforms=TimestampRouter
transforms.TimestampRouter.type=org.apache.kafka.connect.transforms.TimestampRouter
transforms.TimestampRouter.topic.format=your-topic-${timestamp:yyyy-MM-dd}
transforms.TimestampRouter.timestamp.format=yyyy-MM-dd

型