scala - 您可以使用 alpakka HDFS 连接器附加到文件吗？

Question

我正在尝试使用此连接器从 Kafka 中提取消息并将它们写入 HDFS。只要文件不存在就可以正常工作，但如果存在则抛出 FileAlreadyExistsException。有没有办法使用这个连接器附加到一个已经存在的文件？我正在使用一个HdfsFlow.dataWithPassThrough流程，它需要一个HdfsWritingSettings, 但这只允许您设置一个overwrite布尔值；没有append选择。