VishalMCF commented on issue #4548: URL: https://github.com/apache/eventmesh/issues/4548#issuecomment-1807021131
Hello @yanrongzhen I found the implementation of the test for the RedisSinkConnector. There I found the methodology for unit testing a Sink Connector which can be summarised as follows:- 1. Create an instance of SinkConnector 2. Extract the storage part (in case of RedisSinkConnector it is RTopic but in case of OpenFunction it will become its BlockingQueue) 3. Start the connector 4. Create multiple objects of ConnectorRecords and put it inside the storage of the SinkConnector. 5. Add a listener to the storage that can consume the events/records from it and that should match as exactly the ones which were put inside the storage. But in case of RedisSinkConnector we are able to test it by using a mock Redis Server. How can I do the same in case of OpenFunction? I really like this issue as it is teaching me a lot of concepts. Hope you can provide some guidance. :) -- 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] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
