Удалить имя topi c из путей S3 при использовании Kafka Connect S3 Sink

Question

Использование https://docs.confluent.io/current/connect/kafka-connect-s3/index.html

Как настроить соединитель так, чтобы имена Kafka topi c не включались в пути выхода S3?

Я использую TimeBasedPartitioner и хотел бы иметь фиксированное имя в пути вместо имени topi c. Итак, это:

fixed_name/<encodedPartition>/<topic>+<kafkaPartition>+<startOffset>.<format>

Вместо значения по умолчанию:

topics/<topic>/<encodedPartition>/<topic>+<kafkaPartition>+<startOffset>.<format>

Спасибо!

Answer 1

Вы не можете удалить имя topi c, если не напишите свое собственное Partitioner и не перезапишите generatePartitionedPath