Looking for KafkaIO/SDF Tests

[Marco Robles <ma...@wizeline.com>]

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

marco.robles@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.*

Re: Looking for KafkaIO/SDF Tests

[Chamikara Jayalath <ch...@google.com>]

We don't have a running Jenkins test currently since the previous test had
to be disabled due to flakiness. Tracked here:
https://issues.apache.org/jira/browse/BEAM-9482

Pipeline is here
<https://github.com/apache/beam/blob/master/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOIT.java>
(SDF
version should be the default).

Thanks,
Cham

On Wed, Dec 1, 2021 at 5:17 PM Marco Robles <ma...@wizeline.com>
wrote:

> 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
>
> marco.robles@wizeline.com
>
>
>
>
>
>
>
>
> *This email and its contents (including any attachments) are being sent
> toyou on the condition of confidentiality and may be protected by
> legalprivilege. Access to this email by anyone other than the intended
> recipientis unauthorized. If you are not the intended recipient, please
> immediatelynotify the sender by replying to this message and delete the
> materialimmediately from your system. Any further use, dissemination,
> distributionor reproduction of this email is strictly prohibited. Further,
> norepresentation is made with respect to any content contained in this
> email.*