Package org.flowable.eventregistry.spring.kafka.payload

Class EventPayloadKafkaMessageKeyProvider

java.lang.Object

org.flowable.eventregistry.spring.kafka.payload.EventPayloadKafkaMessageKeyProvider

All Implemented Interfaces:

KafkaMessageKeyProvider<Object>

public class EventPayloadKafkaMessageKeyProvider
extends Object
implements KafkaMessageKeyProvider<Object>

Author:

Roman Saratz

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	eventField

Constructor Summary

Constructors

Constructor	Description
EventPayloadKafkaMessageKeyProvider(String eventField)

Method Summary

Modifier and Type	Method	Description
Object	determineMessageKey(org.flowable.eventregistry.api.OutboundEvent<?> eventInstance)	Determine the record key for the outbound event.

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

EventPayloadKafkaMessageKeyProvider

public EventPayloadKafkaMessageKeyProvider(String eventField)

Method Details

determineMessageKey

public Object determineMessageKey(org.flowable.eventregistry.api.OutboundEvent<?> eventInstance)

Description copied from interface: KafkaMessageKeyProvider

Determine the record key for the outbound event. Can be null if you do not want to use a specific value.

Specified by:

determineMessageKey in interface KafkaMessageKeyProvider<Object>

Parameters:

eventInstance - the outbound event

Returns:

the record key to use