sunxiaojian commented on PR #247: URL: https://github.com/apache/rocketmq-connect/pull/247#issuecomment-1212965320
> @sunxiaojian debezium适配的时候好像有适配kafka source端，看一下能不能融合到一起。 @oudb 非常好的想法，期待这个特性可以尽快合入，一起把这个特性做的更好。 ok ， 大概review了一下功能，非常不错的能力，和debezium中的source 和 sink 兼容实现有所不同； 当前PR实现，应该是为了满足 kafka source -> rocketmqConnect -> kafka sink 这一种场景, source和sink限制在必须是kafka connect的插件，debezium中的实现是 希望做到 kafka connect source -> RocketMQ Connect -> kafka connect sink 或者 kafka connect source -> RocketMQ Connect -> RocketMQ Connect sink 或者 RocketMQ connect source -> RocketMQ Connect ->Kafka connect sink 这三种形式兼容，当然，这完全可以作为两种能力来提供，只为了满足用户可以无缝将kafka connect的插件迁移到 rocketmq connect而无需做任何适配， 持续兼容和维护下去，会是一个突出的功能 -- 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]
