rgoers commented on pull request #346: URL: https://github.com/apache/flume/pull/346#issuecomment-1068807611
I have a feeling that a minor enhancement I am adding will address your issue. I have had to customize (i.e. - replace) Flume's application class since the day I started using it. The reason why is that we have a Sink that does some internal work and then passes the result to a Source where it gets written to a channel and then is sent along downstream. To do this the Sink needs to locate the Source instance, which it can't do from a start() method since it doesn't have access to the configuration. To accommodate this I am adding an Initializable interface with a single void initialize(MaterializedConfiguration configuration) method. So in your case you could extend the HDFSEventSink and have it implement the Initialize interface and get the information from the KafkaChannel you want. -- 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
