Hi, I am looking for *integration tests for SDF implementation* (testing the pipeline) for unbounded-stream that may help me as an *example* to validate some expected behaviors in my current implementation for the SDF tests for PulsarIO connector.
I was using KafkaIO as an example for the testing, but it seems the SDF version for the testing is not being used (Pipeline tests <https://github.com/apache/beam/blob/master/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOIT.java> ). Thanks in advance -- *Marco Robles* *|* WIZELINE Software Engineer marco.rob...@wizeline.com -- *This email and its contents (including any attachments) are being sent to you on the condition of confidentiality and may be protected by legal privilege. Access to this email by anyone other than the intended recipient is unauthorized. If you are not the intended recipient, please immediately notify the sender by replying to this message and delete the material immediately from your system. Any further use, dissemination, distribution or reproduction of this email is strictly prohibited. Further, no representation is made with respect to any content contained in this email.*
