sunxiaojian opened a new pull request, #152: URL: https://github.com/apache/rocketmq-connect/pull/152
一. 增加kafka connect source适配，做record到 rocketmq的转换 二. 让 kafka 原有的 transform可以执行 三. 适配debezium所有的支持的插件，主要适配offset和 db history的处理方式 四. mysql测试通过，流程无误 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
