我正在使用 confluent 的 kafka-connect-s3 https://www.confluent.io/hub/confluentinc/kafka-connect-s3将我的 kafka 主题备份到 s3 。我希望能够使用 Athena 轻松查询这些数据，并将其正确分区以实现廉价/快速读取。
我想按（年/月/日/主题）元组进行分区。我已经通过使用每日分区器https://docs.confluent.io/kafka-connect-s3-sink/current/index.html#partitioning-records-into-s3-objects解决了年/月/日部分。现在 year=YYYY/month=MM/day=DD 已进入路径，因此任何基于配置单元的查询都会按时优化/分区。查看 msck 解释，注意使用示例userid=
https://docs.aws.amazon.com/athena/latest/ug/msck-repair-table.html
但是，根据这些文档https://docs.confluent.io/kafka-connect-s3-sink/current/index.html#s3-object-names我在路径中得到 {topic} 但无法修改它到主题={主题}。我可以将其添加到前缀中（而不是 env={env}，前缀将是 env={env}/topic={topic}），但这对于它下面的另一个唯一子目录 {topic} 来说似乎是多余的。
我还注意到主题名称在由 + 分隔的消息名称中（以及分区和起始偏移量）。
我的问题 。. . 如何在我的路径中获取 topic={topic} 以便基于配置单元的查询自动创建该分区？或者我是否已经通过在路径中（没有主题=）或消息名称（再次，没有主题=）中免费获得它