怎么从数据库把数据导入到kafka 的消息队列

怎么把mysql数据库的数据传到KAFKA集群里面，并且消费者消费到数据。

利用etl工具或者自己写代码