[GitHub] jiazhai opened a new issue #2877: Add integration test for KafkaConnectSource

[GitBox <gi...@apache.org>]

jiazhai opened a new issue #2877: Add integration test for KafkaConnectSource
URL: https://github.com/apache/pulsar/issues/2877
 
 
   In PR #2791, @sijie suggested to add an integration test for debezium.
   KafkaConnectSource is a little not compatible with current source test framework.
   In current existing source test framework, we call produceSourceMessages: Map<String, String> kvs = tester.produceSourceMessages(numMessages) and return expected kvs to verify later, 
   But in this KafkaConnectSource, the SourceMessages is created by debezium (convert mysql binlog into KafkaConnectSource), And it seems not easy to save the content as explicit Kvs.
   To do this, we may need move some of the methods(such as  `prepareSource` and `validateSourceResult`) from `PulsarFunctionsTest` into `SourceTester` to make the SourceTester do the things more customized.
   
   This is the issue to track the integration test for KafkaConnectSource
   

----------------------------------------------------------------
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