程序包 io.github.wooenrico.kafka.consumer

类 ExecutorConsumerProperties

java.lang.Object

io.github.wooenrico.kafka.consumer.ConsumerProperties

io.github.wooenrico.kafka.consumer.ExecutorConsumerProperties

直接已知子类:

RateLimitExecutorConsumerProperties

public class ExecutorConsumerProperties
extends ConsumerProperties

线程池消费者配置

构造器概要

构造器

构造器	说明
ExecutorConsumerProperties()

方法概要

修饰符和类型	方法	说明
ExecutorConf	getExecutor()
void	setExecutor(ExecutorConf executor)

从类继承的方法 io.github.wooenrico.kafka.consumer.ConsumerProperties

addCommonProperties, addProperties, getCloseTimeout, getConcurrency, getPollTimeout, getProperties, getTopic, isEnabled, setCloseTimeout, setConcurrency, setEnabled, setPollTimeout, setProperties, setTopic, toString

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

构造器详细资料

ExecutorConsumerProperties

public ExecutorConsumerProperties()

方法详细资料

getExecutor

public ExecutorConf getExecutor()

setExecutor

public void setExecutor(ExecutorConf executor)