Consumer Configurations

ConsumerConfig

Package: io.axual.client.config

Use this class to build a configuration for a non-AVRO consumer.

Usage

ConsumerConfig.builder()
    .setKeyDeserializer()
    .setValueDeserializer()
    .setStream()
    .setDeliveryStrategy()
    .setMaximumPollSize()
    .build();

All configurations are defined below:

Configuration Default Value Description

Configuration	Default Value	Description
keyDeserializer	N/A	A fully qualified class name as String to deserialize key OR A instance of deserialize key.
valueDeserializer	N/A	A fully qualified class name as String to deserialize value OR A instance of deserialize value.
deliveryStrategy	`AT_LEAST_ONCE`	Strategy to handle consume and processing behavior. More details at Delivery Strategy.
stream	N/A	The stream to consume records from.
maximumPollSize	100	Sets the number of messages to be retrieved by a single poll command.

keyDeserializer

N/A

A fully qualified class name as String to deserialize key

A instance of deserialize key.

valueDeserializer

N/A

A fully qualified class name as String to deserialize value

A instance of deserialize value.

deliveryStrategy

AT_LEAST_ONCE

Strategy to handle consume and processing behavior. More details at Delivery Strategy.

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() {
    .setKeyDeserializer()
    .setValueDeserializer()
    .setStream()
    .setDeliveryStrategy()
    .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() {
    .setKeyDeserializer()
    .setValueDeserializer()
    .setStream()
    .setDeliveryStrategy()
    .setMaximumPollSize()
    .build();
}