写了个kafka读插件往mysql写没有反应，也没有报错，请大侠们指导下！！！

[lingzhy]

@Override public void startRead(RecordSender recordSender) { ........ while (flag) { ........ oneRecord = buildOneRecord(recordSender, value); //如果返回值不等于null表示不是异常消息。 if (oneRecord != null) { System.out.println("oneRecord::::::::::::" + oneRecord.toString()); recordSender.sendToWriter(oneRecord); recordSender.flush(); } } }

打印如下： oneRecord::::::::::::{"data":[{"byteSize":1,"rawData":"2","type":"STRING"},{"byteSize":2,"rawData":"21","type":"STRING"},{"byteSize":2,"rawData":"22","type":"STRING"},{"byteSize":2,"rawData":"23","type":"STRING"}],"size":4}

[sunchongwei]

这么多年了解决了吗