使用kafka connects3 sink时从s3路径中删除主题名

oxf4rvwz 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(303)

使用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> 谢谢您！

apache-kafka amazon-s3 apache-kafka-connect

来源：https://stackoverflow.com/questions/61229864/remove-topic-name-from-s3-paths-when-using-kafka-connect-s3-sink