rgoers commented on pull request #346: URL: https://github.com/apache/flume/pull/346#issuecomment-1067398437
I am still not understanding. "When I need to use any kafka-related attributes in sink, I currently can't get them.". For the life of me I simply don't understand why you need information regarding the Kafka Channel in an HDFSEventSink. What could that possibly have to do with the file name. @tmgstevens The example you cite makes a bit more sense since that topic is where the event Flume is managing was published to - so it originated with the producer of the event. The topic used for the file channel is published to and consumed by Flume (although I know it is possible to use a KafkaChannel as if it was a sink, it still wouldn't make sense to add the topic since the consumer must already know that to consume it). If this is really about enhancing the way the HDFSEventSink constructs the file name perhaps that would make more sense. -- 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. To unsubscribe, e-mail: dev-unsubscr...@flume.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
