imtiny commented on issue #320:
URL:
https://github.com/apache/camel-kafka-connector-examples/issues/320#issuecomment-854495663
Hi @oscerd
I have the following configs for camel hdfs connector
```
camel.sink.endpoint.fileType: NORMAL_FILE
camel.sink.endpoint.namedNodes: mars-hdfs-namenode:8020
camel.sink.endpoint.owner: hdfs
camel.sink.endpoint.valueType: BYTES
camel.sink.path.hostName: mars-hdfs
camel.sink.path.path: user/kafka/test5
```
When I use kafka console producer send messages to kafka, I noticed that
there are two files(`/user/kafka/test5.opened` and
`/user/kafka/test5/test5.opened`) created by connector.
And the file `/user/kafka/test5.opened` always keep one line of message,
which is the newest one, while the file `/user/k afka/test5/test.opened` always
keep the first message.
I can confirm that if I send a new message, it will be saved to the file
`/user/kafka/test5.opened`, so the connector can fetch and save messages from
kafka.
But where is the other messages? can you please give some explanations or
config suggestions ?
Thank you!
--
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:
[email protected]
