I want to use the flume is obtaining data in a mysql to kafka, this is about to use the flume - ng - SQL - source the jar package, I downloaded version 1.5.2, from making the flume is used version 1.9.0, also according to the online configuration, also put the jar package flum2/lib here, but it has been reported the wrong

My own configuration conf following

I also changed after flume1.8 and SQL - source1.5.0 version, or to the same error

CodePudding user response:

Plug-in jar in $FLUME_HOME/plugin. D/directory
Put in $FLUME_HOME/lib/mysql driver

CodePudding user response:

reference 1st floor LinkSe7en response:

plug-in jar in $FLUME_HOME/plugin. D/directory
Mysql driver put in $FLUME_HOME/lib/

Solved my mistake, I put in, is I the conf file source, type, at the end of a more Spaces, I throw up