From 73024136d6f509e2d27f13a19dd4c4ee61fe9a8b Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@vmware.com>
Date: Thu, 4 Mar 2021 16:09:28 +0100
Subject: [PATCH] SCF-GH-661 Fix tests to validate KafkaNull conversion

---
 pom.xml                                                |  2 +-
 .../stream/function/ImplicitFunctionBindingTests.java  | 10 ++--------
 2 files changed, 3 insertions(+), 9 deletions(-)

diff --git a/pom.xml b/pom.xml
index b96dcfcfb..0472e97ad 100644
--- a/pom.xml
+++ b/pom.xml
@@ -25,7 +25,7 @@
 		<java.version>1.8</java.version>
 		<reactor.version>2020.0.2</reactor.version>
 		<objenesis.version>2.1</objenesis.version>
-		<spring-cloud-function.version>3.1.1</spring-cloud-function.version>
+		<spring-cloud-function.version>3.1.2-SNAPSHOT</spring-cloud-function.version>
 		<maven-checkstyle-plugin.failsOnError>true</maven-checkstyle-plugin.failsOnError>
 		<maven-checkstyle-plugin.failsOnViolation>true</maven-checkstyle-plugin.failsOnViolation>
 		<maven-checkstyle-plugin.includeTestSourceDirectory>true</maven-checkstyle-plugin.includeTestSourceDirectory>
diff --git a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java
index e1b3ccedb..ba2af76c7 100644
--- a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java
+++ b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java
@@ -1178,14 +1178,8 @@ public class ImplicitFunctionBindingTests {
 		public Function<Message<Person>, String> funcMessage() {
 			return value -> {
 				Object v = value.getPayload();
-				System.out.println(v.getClass());
-				if (value.getPayload() instanceof Object) {
-					System.out.println("");
-				}
-				if (((Object) value.getPayload()).getClass() != null) {
-					System.out.println();
-				}
-				//assertThat(value.getPayload().getClass().getName()).isEqualTo("org.springframework.kafka.support.KafkaNull");
+				String className = v.getClass().getName();
+				assertThat(className).isEqualTo("org.springframework.kafka.support.KafkaNull");
 				return "NULL";
 			};
 		}