[ https://issues.apache.org/jira/browse/BEAM-4420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17027701#comment-17027701 ]
Alexey Romanenko edited comment on BEAM-4420 at 1/31/20 5:56 PM: ----------------------------------------------------------------- [~mwalenia] Can we close this issue since KafkaIOIT jenkins job has been already added? was (Author: aromanenko): [~mwalenia] Could we close this issue since KafkaIOIT jenkins job has been already added? > 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 > Priority: Minor > Time Spent: 8h 10m > Remaining Estimate: 0h > > 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 (v8.3.4#803005)