Consumer Configurations
ConsumerConfig
Package: io.axual.client.config
Use this class when you want to build a configuration for a non-AVRO consumer.
Usage
ConsumerConfig.builder()
.setKeyDeserializerClassName()
.setValueDeserializerClassName()
.setStream()
.setConsumerStrategy()
.setMaximumPollSize()
.build();
All configurations are defined below:
Configuration | Default Value | Description |
---|---|---|
keyDeserializerClassName |
N/A |
A fully qualified class name as String to deserialize key. |
valueDeserializerClassName |
N/A |
A fully qualified class name as String to deserialize value. |
consumerStrategy |
N/A |
Strategy to handle consume and processing behaviour. More details at ConsumerStrategy. |
stream |
N/A |
The stream to consume records from. |
maximumPollSize |
100 |
Sets the number of messages to be retrieved by a single poll command. |
GenericAvroConsumerConfig
Package: io.axual.client.config
Use this class when you want to build a configuration for a generic AVRO consumer.
GenericAvroConsumerConfig.builder() {
.setKeyDeserializerClassName()
.setValueDeserializerClassName()
.setStream()
.setConsumerStrategy()
.setMaximumPollSize()
.build();
}
SpecificAvroConsumerConfig
Package: io.axual.client.config
Use this class when you want to build a configuration for a specific AVRO consumer.
SpecificAvroConsumerConfig.builder() {
.setKeyDeserializerClassName()
.setValueDeserializerClassName()
.setStream()
.setConsumerStrategy()
.setMaximumPollSize()
.build();
}