public final class KafkaUtils
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
static boolean |
MICROMETER_PRESENT
True if micrometer is on the class path.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
clearConsumerGroupId()
Clear the group id for the consumer bound to this thread.
|
static java.lang.String |
getConsumerGroupId()
Get the group id for the consumer bound to this thread.
|
static boolean |
returnTypeMessageOrCollectionOf(java.lang.reflect.Method method)
Return true if the method return type is
Message or
Collection<Message<?>>. |
static void |
setConsumerGroupId(java.lang.String groupId)
Set the group id for the consumer bound to this thread.
|
public static final boolean MICROMETER_PRESENT
public static boolean returnTypeMessageOrCollectionOf(java.lang.reflect.Method method)
Message or
Collection<Message<?>>.method - the method.public static void setConsumerGroupId(java.lang.String groupId)
groupId - the group id.public static java.lang.String getConsumerGroupId()
public static void clearConsumerGroupId()