Skip to content

Commit

Permalink
KAFKA-2857; MINOR: Follow up to
Browse files Browse the repository at this point in the history
MINOR: Fix ResetIntegrationTest test failures

KAFKA-2857 follow-up.

Author: Vahid Hashemian <vahidhashemian@us.ibm.com>

Reviewers: Jason Gustafson <jason@confluent.io>, Ismael Juma <ismael@juma.me.uk>

Closes #2636 from vahidhashemian/minor/kafka-2857-followup
  • Loading branch information
vahidhashemian authored and ijuma committed Mar 4, 2017
1 parent 4b1415c commit d2792e3
Showing 1 changed file with 2 additions and 4 deletions.
Expand Up @@ -22,7 +22,7 @@
import kafka.utils.MockTime;
import kafka.utils.ZkUtils;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.common.errors.GroupCoordinatorNotAvailableException;
import org.apache.kafka.common.errors.TimeoutException;
import org.apache.kafka.common.security.JaasUtils;
import org.apache.kafka.common.serialization.LongDeserializer;
import org.apache.kafka.common.serialization.LongSerializer;
Expand Down Expand Up @@ -122,9 +122,7 @@ public void cleanup() throws Exception {
try {
TestUtils.waitForCondition(consumerGroupInactive, TIMEOUT_MULTIPLIER * CLEANUP_CONSUMER_TIMEOUT,
"Test consumer group active even after waiting " + (TIMEOUT_MULTIPLIER * CLEANUP_CONSUMER_TIMEOUT) + " ms.");
} catch (GroupCoordinatorNotAvailableException e) {
continue;
} catch (IllegalArgumentException e) {
} catch (TimeoutException e) {
continue;
}
break;
Expand Down

0 comments on commit d2792e3

Please sign in to comment.