KafkaMQConsumer.ConsumerPropBuilder

public static class KafkaMQConsumer.ConsumerPropBuilder
extends java.lang.Object

构造器
构造器和说明
`ConsumerPropBuilder()`

所有方法静态方法实例方法具体方法
限定符和类型	方法和说明
`KafkaMQConsumer.ConsumerPropBuilder`	`auth(java.lang.String userName, java.lang.String password)`
`KafkaMQConsumer.ConsumerPropBuilder`	`authIgnore()`
`KafkaMQConsumer.ConsumerPropBuilder`	`autoCommit(boolean flag)`
`KafkaMQConsumer.ConsumerPropBuilder`	`bootstrapServers(java.lang.String servers)`
`java.util.Properties`	`build()`
`static KafkaMQConsumer.ConsumerPropBuilder`	`create()`
`KafkaMQConsumer.ConsumerPropBuilder`	`groupId(java.lang.String groupId)`
`KafkaMQConsumer.ConsumerPropBuilder`	`maxPollRecords(int limit)`
`KafkaMQConsumer.ConsumerPropBuilder`	`put(java.lang.String key, java.lang.Object value)`

从类继承的方法 java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

public static KafkaMQConsumer.ConsumerPropBuilder create()

public KafkaMQConsumer.ConsumerPropBuilder groupId(java.lang.String groupId)

public KafkaMQConsumer.ConsumerPropBuilder maxPollRecords(int limit)

public KafkaMQConsumer.ConsumerPropBuilder bootstrapServers(java.lang.String servers)

public KafkaMQConsumer.ConsumerPropBuilder autoCommit(boolean flag)

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

public KafkaMQConsumer.ConsumerPropBuilder authIgnore()

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

类 KafkaMQConsumer.ConsumerPropBuilder