Hi folks, I couldn't find any tests related to KafkaIO-SDF implementation in the KafkaIO project besides Unit tests ReadFromKafkaDoFnTest <https://github.com/apache/beam/blob/master/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java>
Is there any test related for testing the pipeline flow with the SDF implementation in KafkaIOTest <https://github.com/apache/beam/blob/master/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java> ? Thanks in advance -- *Marco Robles* *|* WIZELINE Software Engineer [email protected] -- *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.*
