用例：使用发送到主题的消息并存储在awss3中
我使用Kafkas3连接器来实现这一点，它的工作非常好，但
每个文件编码为

topic_kafkaPartition_startOffset.format

相反，我想将消息头编码为文件名，同时存储在s3中。