基于Kafka Connect的数据双向复制组件及方法

本发明公开了基于Kafka Connect的数据双向复制组件及方法，属于数据传输技术领域，要解决的技术问题为：如何实现Kafka与KaiwuDB之间高效双向数据复制。KaiwuDB Source Connector插件用于对读取的数据进行处理转换，并将处理转换后的数据推送至kafka的指定Topic中；KaiwuDB Sink Connector插件用于监听kafka中指定Topic的数据，根据用户在配置文件中指定的数据协议格式要求对数据进行解析，并处理KaiwuDB支持的语法，通过执行写入命令、批量实时的将数据写入KaiwuDB中。