[KAFKA-3926] Transient failures in org.apache.kafka.streams.integration.RegexSourceIntegrationTest

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.10.1.0
• Component/s: streams, unit tests
• Assignee: Bill Bejeck
• Reporter: Guozhang Wang
• Created: 04/Jul/16 00:53
• Updated: 06/Jul/16 19:32
• Resolved: 06/Jul/16 19:32

Description

org.apache.kafka.streams.integration.RegexSourceIntegrationTest > testRegexMatchesTopicsAWhenDeleted FAILED
    java.lang.AssertionError: 
    Expected: <[TEST-TOPIC-A, TEST-TOPIC-B]>
         but: was <[TEST-TOPIC-A]>
        at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
        at org.junit.Assert.assertThat(Assert.java:956)
        at org.junit.Assert.assertThat(Assert.java:923)
        at org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted(RegexSourceIntegrationTest.java:211)

I think it is due to the fact that some times the rebalance takes much longer than the specified 60 seconds.

One example: https://builds.apache.org/job/kafka-trunk-jdk8/730/consoleFull

Issue Links

• links to: GitHub Pull Request #1590