You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2018/10/18 01:25:24 UTC

[GitHub] jiazhai edited a comment on issue #2791: Debezium: integrate KafkaConnectSource with MySqlConnectorTask

jiazhai edited a comment on issue #2791: Debezium: integrate KafkaConnectSource with MySqlConnectorTask
URL: https://github.com/apache/pulsar/pull/2791#issuecomment-430639442
 
 
   @sijie, Yes, I planed to add a test for this, But this source is a little not compatible with currently currently source test framework. 
   In current source test, we call produceSourceMessages: `Map<String, String> kvs = tester.produceSourceMessages(numMessages)`  and return expected kvs to verify later, But in this source, the SourceMessages is created by debezium (convert mysql binlog into KafkaConnectSource), And it seems not easy to save the content as explicit Kvs.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services