有什么方法可以防止camus增加偏移值，让它一直读取之前的值吗？以及如何为创建的文件提供自定义名称而不是一般格式，即topic.leaderId.partitionId.partitioner.encodePartition(context,key)？ 最佳答案 映射器输出的文件名在com.linkedin.camus.etl.Patitioner类的generateFileName方法中生成。你可以实现一个自定义的Partitioner并在as中提供一个逻辑@OverridepublicStringgenerateFileName