From 6b27ebc50daae4057e6e8fba0c8179bc468f4ccd Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Thu, 30 Nov 2017 15:06:03 -0500
Subject: [PATCH] Polishing for EnableKafkaIntegrationTests

https://build.spring.io/browse/SK-MAS-292
---
 .../kafka/annotation/EnableKafkaIntegrationTests.java         | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java b/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java
index 590a923c..f4aa622e 100644
--- a/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java
+++ b/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java
@@ -45,6 +45,7 @@ import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.mockito.Mockito;
 
+import org.springframework.beans.DirectFieldAccessor;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -319,8 +320,7 @@ public class EnableKafkaIntegrationTests {
 		Object messageListener = container.getContainerProperties().getMessageListener();
 		DefaultJackson2JavaTypeMapper typeMapper = KafkaTestUtils.getPropertyValue(messageListener,
 				"messageConverter.typeMapper", DefaultJackson2JavaTypeMapper.class);
-		new DirectFieldAccessor(typeMapper).setPropertyValue("typePrecedence",
-				Jackson2JavaTypeMapper.TypePrecedence.TYPE_ID);
+		typeMapper.setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence.TYPE_ID);
 		assertThat(container).isNotNull();
 		Foo foo = new Foo();
 		foo.setBar("bar");