xin.manong.weapon.base.kafka

类 KafkaConsumeConfig

java.lang.Object

xin.manong.weapon.base.kafka.KafkaConsumeConfig

public class KafkaConsumeConfig
extends Object

kafka消费配置

作者:

frankcl

字段概要

字段

限定符和类型	字段和说明
KafkaAuthConfig	authConfig
Integer	consumeThreadNum
String	groupId
Long	maxFetchWaitTimeMs
String	name
String	servers
List<String>	topics

构造器概要

构造器

构造器和说明
KafkaConsumeConfig()

方法概要

限定符和类型	方法和说明
boolean	check() 检测配置有效性

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

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

字段详细资料

consumeThreadNum

public Integer consumeThreadNum

maxFetchWaitTimeMs

public Long maxFetchWaitTimeMs

name

public String name

servers

public String servers

groupId

public String groupId

topics

public List<String> topics

authConfig

public KafkaAuthConfig authConfig

构造器详细资料

KafkaConsumeConfig

public KafkaConsumeConfig()

方法详细资料

check

public boolean check()

检测配置有效性

返回:

有效返回true，否则返回false