Я пытаюсь использовать этот коннектор для получения сообщений от Kafka и записи их в HDFS. Работает нормально, пока файл еще не существует, но если это так, возникает исключение FileAlreadyExistsException. Есть ли способ добавить к уже существующему файлу с помощью этого коннектора? Я использую поток HdfsFlow.dataWithPassThrough
, и он принимает HdfsWritingSettings
, но это позволяет вам установить только логическое значение overwrite
; нет опции append
.
Спасибо за предложение! github.com/akka/alpakka/issues/1236
Пожалуйста, создайте тикет - или еще лучше PR :) - для этой функции в трекере проблем alpakka.