public final class ListenerUtils
extends java.lang.Object
| Modifier and Type | Method and Description |
|---|---|
static ListenerType |
determineListenerType(java.lang.Object listener) |
static java.lang.String |
recordToString(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)
Return the
ConsumerRecord as a String; either toString() or
topic-partition@offset. |
static void |
setLogOnlyMetadata(boolean onlyMeta)
Set to true to only log record metadata.
|
public static ListenerType determineListenerType(java.lang.Object listener)
public static void setLogOnlyMetadata(boolean onlyMeta)
onlyMeta - true to only log record metadata.recordToString(ConsumerRecord)public static java.lang.String recordToString(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)
ConsumerRecord as a String; either toString() or
topic-partition@offset.record - the record.setLogOnlyMetadata(boolean)