标签：sinkTask

kafka

kafka之七 sinkTask

使用kafka connector 功能实现一个数据从kafka到 MySQL 的sinkTask一：实现 JdbcSinkConnector 类public class JdbcSinkConnector extends SinkConnector{ private String url; private String d……