KafkaMQConsumer.ConsumerPropBuilder |
KafkaMQConsumer.ConsumerPropBuilder.auth(java.lang.String userName,
java.lang.String password) |
KafkaMQConsumer.ConsumerPropBuilder |
KafkaMQConsumer.ConsumerPropBuilder.authIgnore() |
KafkaMQConsumer.ConsumerPropBuilder |
KafkaMQConsumer.ConsumerPropBuilder.autoCommit(boolean flag) |
KafkaMQConsumer.ConsumerPropBuilder |
KafkaMQConsumer.ConsumerPropBuilder.bootstrapServers(java.lang.String servers) |
static KafkaMQConsumer.ConsumerPropBuilder |
KafkaMQConsumer.ConsumerPropBuilder.create() |
KafkaMQConsumer.ConsumerPropBuilder |
KafkaMQConsumer.ConsumerPropBuilder.groupId(java.lang.String groupId) |
KafkaMQConsumer.ConsumerPropBuilder |
KafkaMQConsumer.ConsumerPropBuilder.maxPollRecords(int limit) |
KafkaMQConsumer.ConsumerPropBuilder |
KafkaMQConsumer.ConsumerPropBuilder.put(java.lang.String key,
java.lang.Object value) |