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