Class KafkaNullAwarePayloadArgumentResolver
java.lang.Object
org.springframework.messaging.handler.annotation.support.PayloadMethodArgumentResolver
org.springframework.kafka.annotation.KafkaNullAwarePayloadArgumentResolver
- All Implemented Interfaces:
org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolver
public class KafkaNullAwarePayloadArgumentResolver
extends org.springframework.messaging.handler.annotation.support.PayloadMethodArgumentResolver
PayloadMethodArgumentResolver that can properly decode KafkaNull
payloads, returning null. When using a custom
MessageHandlerMethodFactory,
add this resolver if you need to handle tombstone records with null values.- Since:
- 2.7.4
-
Method Summary
Modifier and TypeMethodDescriptionprotected booleanisEmptyPayload(Object payload) resolveArgument(org.springframework.core.MethodParameter parameter, org.springframework.messaging.Message<?> message) Methods inherited from class org.springframework.messaging.handler.annotation.support.PayloadMethodArgumentResolver
resolveTargetClass, supportsParameter, validate
-
Method Details
-
resolveArgument
public Object resolveArgument(org.springframework.core.MethodParameter parameter, org.springframework.messaging.Message<?> message) throws Exception - Specified by:
resolveArgumentin interfaceorg.springframework.messaging.handler.invocation.HandlerMethodArgumentResolver- Overrides:
resolveArgumentin classorg.springframework.messaging.handler.annotation.support.PayloadMethodArgumentResolver- Throws:
Exception
-
isEmptyPayload
- Overrides:
isEmptyPayloadin classorg.springframework.messaging.handler.annotation.support.PayloadMethodArgumentResolver
-