使用https://docs.confluent.io/current/connect/kafka-connect-s3/index.html
如何设置连接器,使kafka主题名不包含在输出s3路径中?
我用的是 TimeBasedPartitioner
我希望路径中有一个固定的名称,而不是主题名。因此: fixed_name/<encodedPartition>/<topic>+<kafkaPartition>+<startOffset>.<format>
而不是默认值: topics/<topic>/<encodedPartition>/<topic>+<kafkaPartition>+<startOffset>.<format>
谢谢您!
1条答案
按热度按时间tjjdgumg1#
除非编写自己的主题名,否则不能删除主题名
Partitioner
并覆盖generatePartitionedPath