Kafka connect s3 bucket文件夹

问题描述 投票:0回答:1

我可以使用融合的S3SinkConnector在s3中创建自己的目录吗?

我知道它会创建一个文件夹结构,很遗憾,我们需要一个新的目录结构。

amazon-s3 apache-kafka apache-kafka-connect confluent
1个回答
0
投票

您可以更改topics.dir,然后更改由partitioner.class提取的路径。

如果需要“一个新的目录结构”(因为S3没有目录而被引用,那么您将需要考虑实现自己的Partitioner类)>

https://docs.confluent.io/current/connect/kafka-connect-s3/index.html#s3-object-names

© www.soinside.com 2019 - 2024. All rights reserved.