我想在mysql上执行sql，每10分钟获取一次数据。然后我想为每一行构造消息并发布到kafka主题。这是我可以/应该对Kafka做的事吗？我想在我的kafka producer中打开一个mysql连接。使用者（可能是通过广域网）将消息（或行）取出，并对数据执行任何操作。