org.springframework.kafka.support.serializer

Class SerializationUtils

java.lang.Object

org.springframework.kafka.support.serializer.SerializationUtils

public final class SerializationUtils
extends java.lang.Object

Utilities for serialization.

Since:

2.5

Author:

Gary Russell

Method Summary

Modifier and Type	Method and Description
static <P,T> java.util.function.BiFunction<P,org.apache.kafka.common.header.Headers,T>	propertyToMethodInvokingFunction(java.lang.String methodProperty, java.lang.Class<P> payloadType, java.lang.ClassLoader classLoader) Convert a property value (FQCN.methodName) to a BiFunction that takes a payload and headers and returns some value.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

propertyToMethodInvokingFunction

public static <P,T> java.util.function.BiFunction<P,org.apache.kafka.common.header.Headers,T> propertyToMethodInvokingFunction(java.lang.String methodProperty,
                                                                                                                               java.lang.Class<P> payloadType,
                                                                                                                               java.lang.ClassLoader classLoader)

Convert a property value (FQCN.methodName) to a BiFunction that takes a payload and headers and returns some value. The method must have parameters (P, Headers) or (P) and be declared as static.

Type Parameters:

P - The BiFunction first parameter type.

T - The BiFunction return type.

Parameters:

methodProperty - the method name property.

payloadType - the BiFunction first parameter type.

classLoader - the class loader.

Returns:

the function.