org.springframework.integration.x.kafka

Class KafkaPartitionAllocator

java.lang.Object

org.springframework.integration.x.kafka.KafkaPartitionAllocator

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<org.springframework.integration.kafka.core.Partition[]>

public class KafkaPartitionAllocator
extends java.lang.Object
implements org.springframework.beans.factory.FactoryBean<org.springframework.integration.kafka.core.Partition[]>

Is responsible for managing the partition allocation between multiple instances of a Kafka source module deployed in a stream. As a FactoryBean it will return the partitions that the current module instance should listen to. The partitions for the given topic would be extracted from Kafka unless an explicit partition list is provided. Partitions are allocated evenly based on the number of module instances. Zero-count Kafka source modules are not supported.

Author:

Marius Bogoevici, Ilayaperumal Gopinathan

Constructor Summary

Constructors

Constructor and Description
KafkaPartitionAllocator(org.springframework.integration.kafka.core.ConnectionFactory connectionFactory, java.lang.String moduleName, java.lang.String streamName, java.lang.String topics, java.lang.String partitionList, int sequence, int count)

Method Summary

Methods

Modifier and Type	Method and Description
org.springframework.integration.kafka.core.Partition[]	getObject()
java.lang.Class<?>	getObjectType()
boolean	isSingleton()
static java.lang.Iterable<java.lang.Integer>	parseNumberList(java.lang.String numberList) Expects a String containing a list of numbers or ranges, e.g.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaPartitionAllocator

public KafkaPartitionAllocator(org.springframework.integration.kafka.core.ConnectionFactory connectionFactory,
                       java.lang.String moduleName,
                       java.lang.String streamName,
                       java.lang.String topics,
                       java.lang.String partitionList,
                       int sequence,
                       int count)

Method Detail

getObject

public org.springframework.integration.kafka.core.Partition[] getObject()
                                                                 throws java.lang.Exception

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean<org.springframework.integration.kafka.core.Partition[]>

Throws:

java.lang.Exception

parseNumberList

public static java.lang.Iterable<java.lang.Integer> parseNumberList(java.lang.String numberList)
                                                             throws java.lang.IllegalArgumentException

Expects a String containing a list of numbers or ranges, e.g. "1-10", "1,3,5", "1,5,10-20,26,100-110,145". One-sized ranges or ranges where the start is after the end are not permitted. Returns an array of Integers containing the actual numbers.

Parameters:

numberList - a string containing numbers, or ranges

Returns:

the list of integers

Throws:

java.lang.IllegalArgumentException - if the format of the list is incorrect

getObjectType

public java.lang.Class<?> getObjectType()

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<org.springframework.integration.kafka.core.Partition[]>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean<org.springframework.integration.kafka.core.Partition[]>