public class KafkaMessageListenerContainer.FetchTask
extends java.lang.Object
implements org.springframework.scheduling.SchedulingAwareRunnable
| Constructor and Description |
|---|
KafkaMessageListenerContainer.FetchTask(BrokerAddress brokerAddress,
com.gs.collections.api.RichIterable<Partition> initialPartitions) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
addListenedPartitionsIfActive(java.lang.Iterable<Partition> partitions) |
boolean |
isLongLived() |
void |
run() |
public KafkaMessageListenerContainer.FetchTask(BrokerAddress brokerAddress, com.gs.collections.api.RichIterable<Partition> initialPartitions)
public boolean isLongLived()
isLongLived in interface org.springframework.scheduling.SchedulingAwareRunnablepublic boolean addListenedPartitionsIfActive(java.lang.Iterable<Partition> partitions)
public void run()
run in interface java.lang.Runnable