public class KafkaMessageListenerContainer.FetchTask
extends java.lang.Object
implements java.lang.Runnable
Constructor and Description |
---|
KafkaMessageListenerContainer.FetchTask(BrokerAddress brokerAddress) |
Modifier and Type | Method and Description |
---|---|
void |
run() |
public KafkaMessageListenerContainer.FetchTask(BrokerAddress brokerAddress)