From 21600a275dd0465647424019b4355498000efe8f Mon Sep 17 00:00:00 2001
From: Gamal <gamateo@hotmail.com>
Date: Thu, 24 Sep 2015 15:51:28 -0500
Subject: [PATCH] convertPayloadIfNecessary change to use Value Class Type

convertPayloadIfNecessary is using getProducerMetadata().getKeyClassType() when it should use getProducerMetadata().getValueClassType()
---
 .../integration/kafka/support/ProducerConfiguration.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/ProducerConfiguration.java b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/ProducerConfiguration.java
index 5d47afea58..3a8eca19d0 100644
--- a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/ProducerConfiguration.java
+++ b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/support/ProducerConfiguration.java
@@ -125,7 +125,7 @@ public class ProducerConfiguration<K, V> {
 
 	private V convertPayloadIfNecessary(Object messagePayload) {
 		if (messagePayload != null) {
-			if (getProducerMetadata().getKeyClassType().isAssignableFrom(
+			if (getProducerMetadata().getValueClassType().isAssignableFrom(
 					messagePayload.getClass())) {
 				return getProducerMetadata().getValueClassType().cast(messagePayload);
 			}