imtiny commented on issue #320: URL: https://github.com/apache/camel-kafka-connector-examples/issues/320#issuecomment-856391029
Thank you ! It works if I already have the file `/user/kafka/test5.opened` created by user `kafka`. If I use command line create a new directory `user/kafka/test6` for new hdfs connector by user hdfs, then create a new hdfs connector with the settings ``` camel.sink.endpoint.overwrite=false camel.sink.endpoint.append=true ``` And set the `camel.sink.path.path=user/kafka/test6` Then run `kubect apply ...` to start the new connector It will move the `/user/kafka/test6`(owner hdfs) to `/user/kafka/test6.opened`(owner hdfs) And I can see the error log shows that `/user/kafka/test6.opened` already exists, failed to sink message. So I have to set `camel.sink.endpoint.append=false` first, after the file `/user/kafka/test6.opened` created by kafka, change the config `camel.sink.endpoint.append=true`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
