From fe2a398b8b20910ed276f71e189dced92bbb35ae Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Wed, 21 Aug 2019 09:38:25 -0400 Subject: [PATCH] Fix mock producer.close() for latest SK snapshot --- .../cloud/stream/binder/kafka/KafkaTransactionTests.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTransactionTests.java b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTransactionTests.java index a320e9731..28e2c37e5 100644 --- a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTransactionTests.java +++ b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTransactionTests.java @@ -26,7 +26,6 @@ import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.common.TopicPartition; import org.junit.ClassRule; -import org.junit.Ignore; import org.junit.Test; import org.mockito.InOrder; @@ -70,7 +69,6 @@ public class KafkaTransactionTests { @SuppressWarnings({ "rawtypes", "unchecked" }) @Test - @Ignore public void testProducerRunsInTx() { KafkaProperties kafkaProperties = new TestKafkaProperties(); kafkaProperties.setBootstrapServers(Collections @@ -119,7 +117,7 @@ public class KafkaTransactionTests { inOrder.verify(mockProducer).beginTransaction(); inOrder.verify(mockProducer).send(any(ProducerRecord.class), any(Callback.class)); inOrder.verify(mockProducer).commitTransaction(); - inOrder.verify(mockProducer).close(); + inOrder.verify(mockProducer).close(any()); inOrder.verifyNoMoreInteractions(); assertThat(TestUtils.getPropertyValue(channel, "dispatcher.theOneHandler.useNativeEncoding", Boolean.class)).isTrue();