Можете ли вы добавить файл, используя HDFS-разъем alpakka? - PullRequest
0 голосов
/ 11 сентября 2018

Я пытаюсь использовать этот разъем для извлечения сообщений из Кафки и записи их в HDFS. Работает нормально, если файл еще не существует, но если он существует, он генерирует исключение FileAlreadyExistsException. Есть ли способ добавить к уже существующему файлу с помощью этого соединителя? Я использую поток HdfsFlow.dataWithPassThrough, и он требует HdfsWritingSettings, но это только позволяет установить логическое значение overwrite; append вариант отсутствует.

...