public class ConsumerPropertiesBuilder extends Object
| Constructor and Description |
|---|
ConsumerPropertiesBuilder() |
| Modifier and Type | Method and Description |
|---|---|
Properties |
build() |
ConsumerPropertiesBuilder |
withAutoOffsetReset(AutoOffsetReset autoOffsetReset) |
ConsumerPropertiesBuilder |
withBootstrapServers(String bootstrapServers) |
ConsumerPropertiesBuilder |
withEnableAutoCommit(boolean enableAutoCommit) |
ConsumerPropertiesBuilder |
withGroupID(String groupID) |
ConsumerPropertiesBuilder |
withKeyDeserializer(Class keyDeserializer) |
ConsumerPropertiesBuilder |
withValueDeserializer(Class valueDeserializer) |
public ConsumerPropertiesBuilder withBootstrapServers(String bootstrapServers)
public ConsumerPropertiesBuilder withEnableAutoCommit(boolean enableAutoCommit)
public ConsumerPropertiesBuilder withGroupID(String groupID)
public ConsumerPropertiesBuilder withAutoOffsetReset(AutoOffsetReset autoOffsetReset)
public ConsumerPropertiesBuilder withKeyDeserializer(Class keyDeserializer)
public ConsumerPropertiesBuilder withValueDeserializer(Class valueDeserializer)
public Properties build() throws RemotingKafkaConfigurationException
Copyright © 2004–2018. All rights reserved.