Seems pretty obvious to me. You are using a class that doesn't exist httpagent1.sources.http-source.type = org.apache.flume.source.http.testHTTPSource
You should use: httpagent1.sources.http-source.type = org.apache.flume.source.http.HTTPSource which can be shortcutted to just "http" You'll also have a problem with org.apache.flume.source.http.testHandler if you intend to use a custom class then you need to install the jar in the plugin directory Regards, Gonzalo On 21 December 2015 at 07:24, zaenal rifai <[email protected]> wrote: > Hi all, > > i make some topology flume which collect data from nginx and write to > hdfs... > > first is top agent ---> mid agent ---> hdfs agent > > top agent = http source which collect data from nginx > mid agent = which will forward the source to hdfs agent > hdfs agent = which will write the data to hdfs > > but when i'll run the top agent, there is some problem > > http://tempel.blankon.in/1628710 > > and this is my conf top agent > > http://tempel.blankon.in/1628711 > >
