Fix batching test

This commit is contained in:
Oleg Zhurakousky
2022-06-15 11:50:43 +02:00
parent 2b914cd0f7
commit 9768586145

View File

@@ -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);
};
}