[ https://issues.apache.org/jira/browse/BEAM-4420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857867#comment-16857867 ]
Alexey Romanenko commented on BEAM-4420: ---------------------------------------- [~ŁukaszG] Do you know if someone is working on this? Also, it would be great to test KafkaIO against different major kafka-client version, > Add KafkaIO Integration Tests > ----------------------------- > > Key: BEAM-4420 > URL: https://issues.apache.org/jira/browse/BEAM-4420 > Project: Beam > Issue Type: Test > Components: io-java-kafka, testing > Reporter: Ismaël Mejía > Assignee: Lukasz Gajowy > Priority: Minor > > It is a good idea to have ITs for KafkaIO. > There are two possible issues: > 1. The tests should probably invert the pattern to be readThenWrite given > that Unbounded IOs block on Read and ... > 2. Until we have a way to do PAsserts on Unbounded sources we can rely on > withMaxNumRecords to ensure this test ends. -- This message was sent by Atlassian JIRA (v7.6.3#76005)