Package org.flowable.eventregistry.spring.kafka

Class RoundRobinKafkaPartitionProvider

java.lang.Object

org.flowable.eventregistry.spring.kafka.RoundRobinKafkaPartitionProvider

All Implemented Interfaces:

KafkaPartitionProvider

public class RoundRobinKafkaPartitionProvider
extends Object
implements KafkaPartitionProvider

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicInteger	counter
protected final List<Integer>	partitions

Constructor Summary

Constructors

Constructor	Description
RoundRobinKafkaPartitionProvider(List<Integer> partitions)

Method Summary

Modifier and Type	Method	Description
Integer	determinePartition(OutboundEvent<?> outboundEvent)	Determine the partition for the outbound event.

Methods inherited from class java.lang.Object

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

Field Details

partitions

protected final List<Integer> partitions

counter

protected final AtomicInteger counter

Constructor Details

RoundRobinKafkaPartitionProvider

public RoundRobinKafkaPartitionProvider(List<Integer> partitions)

Method Details

determinePartition

public Integer determinePartition(OutboundEvent<?> outboundEvent)

Description copied from interface: KafkaPartitionProvider

Determine the partition for the outbound event. Can be null if you want to use the Kafka default partitioner.

Specified by:

determinePartition in interface KafkaPartitionProvider

Parameters:

outboundEvent - the outbound event

Returns:

the partition to send to, or null if you want to use the Kafka default partioner