public interface MessageListenerContainer
extends org.springframework.context.SmartLifecycle
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.util.Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric>> |
metrics()
Return metrics kept by this container's consumer(s), grouped by
client-id . |
void |
setupMessageListener(java.lang.Object messageListener)
Setup the message listener to use.
|
void setupMessageListener(java.lang.Object messageListener)
IllegalArgumentException
if that message listener type is not supported.messageListener
- the object
to wrapped to the MessageListener
.java.util.Map<java.lang.String,java.util.Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric>> metrics()
client-id
.client-id
Consumer.metrics()