amazon-s3 - Confluent 云 S3 接收器连接器 - S3 对象的自定义对象名称
问题描述
我的Kafka消息将包含 UUID，它将成为所有未来通信的标识符。我为我的主题配置了一个s3-sink-connector使用默认命名约定（即<topic>+<kafkaPartition>+<startOffset>.<format>）将所有摄取的消息写入我的 S3 存储桶的主题。使用这些名称，很难识别给定消息 UUID 对应的 s3 对象。
有没有办法用原始消息的字段值之一定义 S3 对象名称？
提前致谢。
解决方案
您可以使用FieldPartitioner创建包含s3://bucket/uuid=xxx-yyy-zzz/topic.format文件的路径
推荐阅读
- sql - 如何在 MS SQL Server 中使用正则表达式（或等效）来解决这个问题？
- excel - 将 Excel 图表粘贴到 Word 的宏可以工作，但在作为加载项运行时会出错
- r - Modeltime.resample - 为什么 modeltime_fit_resamples() 不接受“未拟合”的 modeltime_table 作为输入？
- python-3.x - Python3如何在触发异常时在for循环中的项目处恢复
- powershell - 循环 Powershell 脚本以每小时重新提示用户或直到达到超时限制
- sql - HIVE 选择日期之间的位置，但它是字符串 YYYYMMDD，而不是数字日期格式？
- mongodb - Spring-Boot：如何检查 Mongock 是否已完成？
- react-native - react-native-gifted-chat 上的渲染方法上未填充上一条消息
- android - 更新位置时 Android Studio 出错
- javascript - 如何在不使用 java 脚本在边缘浏览器中打开打印对话框的情况下进行打印？