public class KafkaMessageListenerContainer.FetchTask
extends java.lang.Object
implements org.springframework.scheduling.SchedulingAwareRunnable
| Constructor and Description |
|---|
KafkaMessageListenerContainer.FetchTask(BrokerAddress brokerAddress) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
isLongLived() |
void |
run() |
public KafkaMessageListenerContainer.FetchTask(BrokerAddress brokerAddress)