From 9208f743478a94cbbc4f17a6cccc61879a1fe17c Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Tue, 17 Nov 2015 17:01:59 -0500
Subject: [PATCH] Fix deprecation warning

---
 .../kafka/inbound/KafkaHighLevelConsumerMessageSource.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaHighLevelConsumerMessageSource.java b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaHighLevelConsumerMessageSource.java
index 4cdb0af336..348330f819 100644
--- a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaHighLevelConsumerMessageSource.java
+++ b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaHighLevelConsumerMessageSource.java
@@ -20,7 +20,6 @@ import java.util.Map;
 
 import org.springframework.integration.context.IntegrationObjectSupport;
 import org.springframework.integration.core.MessageSource;
-import org.springframework.integration.kafka.support.KafkaConsumerContext;
 import org.springframework.messaging.Message;
 
 /**
@@ -29,11 +28,12 @@ import org.springframework.messaging.Message;
  * @deprecated since 1.3 in favor of {@link KafkaMessageDrivenChannelAdapter}
  */
 @Deprecated
+@SuppressWarnings("deprecation")
 public class KafkaHighLevelConsumerMessageSource<K,V> extends IntegrationObjectSupport implements MessageSource<Map<String, Map<Integer, List<Object>>>> {
 
-	private final KafkaConsumerContext<K,V> kafkaConsumerContext;
+	private final org.springframework.integration.kafka.support.KafkaConsumerContext<K,V> kafkaConsumerContext;
 
-	public KafkaHighLevelConsumerMessageSource(final KafkaConsumerContext<K,V> kafkaConsumerContext) {
+	public KafkaHighLevelConsumerMessageSource(final org.springframework.integration.kafka.support.KafkaConsumerContext<K,V> kafkaConsumerContext) {
 		this.kafkaConsumerContext = kafkaConsumerContext;
 	}