Могу ли я создать свой собственный каталог в s3, используя конфлюент S3SinkConnector?
Я знаю, что это создает структуру папок, к сожалению, нам нужен новый каталог strcuture.
Вы можете изменить topics.dir, за которым следует путь, извлеченный partitioner.class.
topics.dir
partitioner.class
Если вам нужна «новая структура каталогов» (указана, потому что у S3 нет каталогов), тогда вам нужно взглянуть на реализацию собственного класса Partitioner
https://docs.confluent.io/current/connect/kafka-connect-s3/index.html#s3-object-names