From 930d33aeba99013877df10b6b57c11ce74e66d76 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Wed, 21 Aug 2019 09:46:17 -0400 Subject: [PATCH] Fix ConsumerProducerTransactionTests with SK snap --- .../integration2/ConsumerProducerTransactionTests.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration2/ConsumerProducerTransactionTests.java b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration2/ConsumerProducerTransactionTests.java index b8813161b..41bc6f818 100644 --- a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration2/ConsumerProducerTransactionTests.java +++ b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/integration2/ConsumerProducerTransactionTests.java @@ -21,11 +21,9 @@ import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; -import kafka.server.KafkaConfig; import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.ClassRule; -import org.junit.Ignore; import org.junit.Test; import org.junit.runner.RunWith; @@ -47,9 +45,12 @@ import org.springframework.messaging.MessageChannel; import org.springframework.messaging.support.GenericMessage; import org.springframework.test.annotation.DirtiesContext; import org.springframework.test.context.junit4.SpringRunner; +import org.springframework.util.backoff.FixedBackOff; import static org.assertj.core.api.Assertions.assertThat; +import kafka.server.KafkaConfig; + /** * @author Gary Russell * @since 3.0 @@ -95,7 +96,6 @@ public class ConsumerProducerTransactionTests { } @Test - @Ignore public void testProducerRunsInConsumerTransaction() throws InterruptedException { assertThat(this.config.latch.await(10, TimeUnit.SECONDS)).isTrue(); assertThat(this.config.outs).containsExactlyInAnyOrder("ONE", "THREE"); @@ -138,7 +138,7 @@ public class ConsumerProducerTransactionTests { @Bean public ListenerContainerCustomizer> customizer() { return (container, dest, group) -> container - .setAfterRollbackProcessor(new DefaultAfterRollbackProcessor<>(0)); + .setAfterRollbackProcessor(new DefaultAfterRollbackProcessor<>(new FixedBackOff(0L, 1L))); } }