KafkaConsumeConfig (weapon-base 0.2.0 API)

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