我可以使用融合的S3SinkConnector在s3中创建自己的目录吗?
我知道它会创建一个文件夹结构,很遗憾,我们需要一个新的目录结构。
您可以更改topics.dir
,然后更改由partitioner.class
提取的路径。
如果需要“一个新的目录结构”(因为S3没有目录而被引用,那么您将需要考虑实现自己的Partitioner类)>
https://docs.confluent.io/current/connect/kafka-connect-s3/index.html#s3-object-names