Open summyer opened 5 years ago
Hi @summyer, could you please explain your issue in English?
Thanks
ok,
When using this plugin to collect oracle data, it just started to collect normally. After a while, the program stops collecting, and no error is reported, but the process is still there; I changed some of the code to use json string when pushing to kafka.
Hi summyer, try setting debug or trace mode when launching flume agent. Try dumping data to file_roll, for discarding flume-sink. As you say there is no error reported, so it is hard to help. Also keep in mind that you changed code base, so anything can happen. best
改了部分代码,使其通过json字符串发送到kafka中 for(Map row:result){ String body=new Gson().toJson(row); pw.write(body+"\n"); }