From 9768586145505d10c7287d1d91620e6a097296b8 Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@vmware.com>
Date: Wed, 15 Jun 2022 11:50:43 +0200
Subject: [PATCH] Fix batching test

---
 .../cloud/stream/function/FunctionBatchingTests.java            | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/FunctionBatchingTests.java b/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/FunctionBatchingTests.java
index 14a4cd355..c83ec89d1 100644
--- a/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/FunctionBatchingTests.java
+++ b/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/FunctionBatchingTests.java
@@ -287,7 +287,7 @@ public class FunctionBatchingTests {
 		public Function<Message<List<Person>>, Person> func() {
 			return x -> {
 				Object o = x.getPayload().get(2);
-				assertThat(o).isInstanceOf(KafkaNull.class);
+				assertThat(o).isNull();
 				return (Person) x.getPayload().get(0);
 			};
 		}