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()
    .setDeliveryStrategy()
    .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.

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