public final class ListenerUtils
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static ListenerType |
determineListenerType(java.lang.Object listener) |
static DeserializationException |
getExceptionFromHeader(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record,
java.lang.String headerName,
org.springframework.core.log.LogAccessor logger)
Extract a
DeserializationException from the supplied header name, if
present. |
public static ListenerType determineListenerType(java.lang.Object listener)
@Nullable public static DeserializationException getExceptionFromHeader(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, java.lang.String headerName, org.springframework.core.log.LogAccessor logger)
DeserializationException
from the supplied header name, if
present.record
- the consumer record.headerName
- the header name.logger
- the logger for logging errors.