Class ListenerUtils
- java.lang.Object
-
- org.springframework.kafka.listener.ListenerUtils
-
public final class ListenerUtils extends java.lang.ObjectListener utilities.- Since:
- 2.0
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static ListenerTypedetermineListenerType(java.lang.Object listener)static DeserializationExceptiongetExceptionFromHeader(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, java.lang.String headerName, org.springframework.core.log.LogAccessor logger)Extract aDeserializationExceptionfrom the supplied header name, if present.static java.lang.StringrecordToString(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)Return theConsumerRecordas a String; eithertoString()ortopic-partition@offset.static java.lang.StringrecordToString(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, boolean meta)Return theConsumerRecordas a String; eithertoString()ortopic-partition@offset.static voidsetLogOnlyMetadata(boolean onlyMeta)Set to true to only log record metadata.
-
-
-
Method Detail
-
determineListenerType
public static ListenerType determineListenerType(java.lang.Object listener)
-
getExceptionFromHeader
@Nullable public static DeserializationException getExceptionFromHeader(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, java.lang.String headerName, org.springframework.core.log.LogAccessor logger)
Extract aDeserializationExceptionfrom the supplied header name, if present.- Parameters:
record- the consumer record.headerName- the header name.logger- the logger for logging errors.- Returns:
- the exception or null.
- Since:
- 2.3
-
setLogOnlyMetadata
public static void setLogOnlyMetadata(boolean onlyMeta)
Set to true to only log record metadata.- Parameters:
onlyMeta- true to only log record metadata.- Since:
- 2.2.14
- See Also:
recordToString(ConsumerRecord)
-
recordToString
public static java.lang.String recordToString(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)
Return theConsumerRecordas a String; eithertoString()ortopic-partition@offset.- Parameters:
record- the record.- Returns:
- the rendered record.
- Since:
- 2.2.14
- See Also:
setLogOnlyMetadata(boolean)
-
recordToString
public static java.lang.String recordToString(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, boolean meta)Return theConsumerRecordas a String; eithertoString()ortopic-partition@offset.- Parameters:
record- the record.meta- true to log just the metadata.- Returns:
- the rendered record.
- Since:
- 2.5.4
-
-