diff --git a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/ConsumerConfiguration.java b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/ConsumerConfiguration.java
index 047ba70..0e77998 100644
--- a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/ConsumerConfiguration.java
+++ b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/ConsumerConfiguration.java
@@ -182,10 +182,11 @@ public class ConsumerConfiguration {
 
 	@SuppressWarnings("unchecked")
 	public Map<String, List<KafkaStream<byte[], byte[]>>> getConsumerMapWithMessageStreams() {
-		if (consumerMetadata.getValueDecoder() != null) {
+		if (consumerMetadata.getValueDecoder() != null &&
+		    consumerMetadata.getKeyDecoder()   != null) {
 			return getConsumerConnector().createMessageStreams(
 					consumerMetadata.getTopicStreamMap(),
-					consumerMetadata.getValueDecoder(),
+					consumerMetadata.getKeyDecoder(),
 					consumerMetadata.getValueDecoder());
 		}