原文链接：https://blog.csdn.net/xiaoxaoyu/article/details/115315577 文章目录 1、主要思路： 2、实现步骤 2.1、消息接口Dbinfo 2.2、KafkaConnector 2.3、CustomkafkaProducer 2.4、测试类App 1、主要思路： 把producer配置信息进行封装 使用LineNumberReader获取文件总行数和对应行的起始字节位置，并存入map里，方便不同线程从不同行读取和写入kafka 继承Thread类，重写run方法并执行 2、实现步骤 2.1、消息接口Dbinfokafka消息对象 Kafk...