org.thales.punch.libraries.storm.bolt.impl

Class KafkaOutputBoltPartitioner

java.lang.Object

org.thales.punch.libraries.storm.bolt.impl.KafkaOutputBoltPartitioner

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.clients.producer.Partitioner, org.apache.kafka.common.Configurable

public class KafkaOutputBoltPartitioner
extends Object
implements org.apache.kafka.clients.producer.Partitioner

The partitioner is in charge of telling the kafka producer to which partition the next message should go to. This class lets you implements some strategy, for example based on the message content. As of now, it performs a simple round robin over the number of partitions available.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
KafkaOutputBoltPartitioner()

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(Map<String,?> arg0)
int	partition(Object key, int numPartitions)
int	partition(String arg0, Object arg1, byte[] arg2, Object arg3, byte[] arg4, org.apache.kafka.common.Cluster arg5)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.clients.producer.Partitioner

onNewBatch

Constructor Detail

KafkaOutputBoltPartitioner

public KafkaOutputBoltPartitioner()

Method Detail

partition

public int partition(Object key,
                     int numPartitions)

Parameters:

key - the key

numPartitions - the partition number

Returns:

partition number

configure

public void configure(Map<String,?> arg0)

Specified by:

configure in interface org.apache.kafka.common.Configurable

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.kafka.clients.producer.Partitioner

partition

public int partition(String arg0,
                     Object arg1,
                     byte[] arg2,
                     Object arg3,
                     byte[] arg4,
                     org.apache.kafka.common.Cluster arg5)

Specified by:

partition in interface org.apache.kafka.clients.producer.Partitioner