From 8d15b9582a94d48d4b6ca2bd6d2a24195f5882ba Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Mon, 24 Jul 2017 17:19:15 -0400
Subject: [PATCH] Upgrade to SK 2.0 M3, Gradle 4.0.1

---
 .../config/xml/KafkaOutboundAdapterParserTests.java      | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java b/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java
index 4c1b8b525f..9b418f64e3 100644
--- a/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java
+++ b/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java
@@ -90,7 +90,14 @@ public class KafkaOutboundAdapterParserTests {
 	public void testSyncMode() {
 		@SuppressWarnings("resource")
 		MockProducer<Integer, String> mockProducer =
-				new MockProducer<>(false, new IntegerSerializer(), new StringSerializer());
+				new MockProducer<Integer, String>(false, new IntegerSerializer(), new StringSerializer()) {
+
+					@Override
+					public void close() {
+						// To avoid non transactional closes.
+					}
+
+				};
 		KafkaTemplate<Integer, String> template = new KafkaTemplate<>(() -> mockProducer);
 		KafkaProducerMessageHandler<Integer, String> handler = new KafkaProducerMessageHandler<>(template);
 		handler.setBeanFactory(mock(BeanFactory.class));