Package org.flowable.eventregistry.spring.kafka

Class EventPayloadKafkaPartitionProvider

java.lang.Object

org.flowable.eventregistry.spring.kafka.EventPayloadKafkaPartitionProvider

All Implemented Interfaces:

KafkaPartitionProvider

public class EventPayloadKafkaPartitionProvider
extends Object
implements KafkaPartitionProvider

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	eventField

Constructor Summary

Constructors

Constructor	Description
EventPayloadKafkaPartitionProvider(String eventField)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

eventField

protected final String eventField

Constructor Details

EventPayloadKafkaPartitionProvider

public EventPayloadKafkaPartitionProvider(String eventField)

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

parseValue

protected Integer parseValue(Object value)