Package org.apache.kafka.clients.producer.internals

Class RecordAccumulator.PartitionerConfig

java.lang.Object

org.apache.kafka.clients.producer.internals.RecordAccumulator.PartitionerConfig

Enclosing class:

RecordAccumulator

public static final class RecordAccumulator.PartitionerConfig
extends Object

Partitioner config for built-in partitioner

Constructor Summary

Constructors

Constructor	Description
PartitionerConfig()
PartitionerConfig(boolean enableAdaptivePartitioning, long partitionAvailabilityTimeoutMs)	Partitioner config

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PartitionerConfig

public PartitionerConfig(boolean enableAdaptivePartitioning,
 long partitionAvailabilityTimeoutMs)

Partitioner config

Parameters:

enableAdaptivePartitioning - If it's true, partition switching adapts to broker load, otherwise partition switching is random.

partitionAvailabilityTimeoutMs - If a broker cannot process produce requests from a partition for the specified time, the partition is treated by the partitioner as not available. If the timeout is 0, this logic is disabled.

PartitionerConfig

public PartitionerConfig()