程序包 com.sh.wf.mq.kafka

类 KafkaMQConsumer.ConsumerPropBuilder

java.lang.Object

com.sh.wf.mq.kafka.KafkaMQConsumer.ConsumerPropBuilder

封闭类:

KafkaMQConsumer

public static class KafkaMQConsumer.ConsumerPropBuilder
extends Object

构造器概要

构造器

构造器	说明
ConsumerPropBuilder()

方法概要

修饰符和类型	方法	说明
KafkaMQConsumer.ConsumerPropBuilder	auth(String userName, String password)
KafkaMQConsumer.ConsumerPropBuilder	authIgnore()
KafkaMQConsumer.ConsumerPropBuilder	autoCommit(boolean flag)
KafkaMQConsumer.ConsumerPropBuilder	bootstrapServers(String servers)
Properties	build()
static KafkaMQConsumer.ConsumerPropBuilder	create()
KafkaMQConsumer.ConsumerPropBuilder	groupId(String groupId)
KafkaMQConsumer.ConsumerPropBuilder	maxPollRecords(int limit)
KafkaMQConsumer.ConsumerPropBuilder	put(String key, Object value)

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

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

构造器详细资料

ConsumerPropBuilder

public ConsumerPropBuilder()

方法详细资料

create

public static KafkaMQConsumer.ConsumerPropBuilder create()

groupId

public KafkaMQConsumer.ConsumerPropBuilder groupId(String groupId)

maxPollRecords

public KafkaMQConsumer.ConsumerPropBuilder maxPollRecords(int limit)

bootstrapServers

public KafkaMQConsumer.ConsumerPropBuilder bootstrapServers(String servers)

autoCommit

public KafkaMQConsumer.ConsumerPropBuilder autoCommit(boolean flag)

auth

public KafkaMQConsumer.ConsumerPropBuilder auth(String userName,
 String password)

authIgnore

public KafkaMQConsumer.ConsumerPropBuilder authIgnore()

put

public KafkaMQConsumer.ConsumerPropBuilder put(String key,
 Object value)

build

public Properties build()