SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix mock producer.close() for latest SK snapshot

Browse Source
This commit is contained in:
Gary Russell
2019-08-21 09:38:25 -04:00
parent 24e1fc9722
commit fe2a398b8b
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaTransactionTests.java
View File

@@ -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();