Package org.flowable.eventregistry.spring.kafka

Interface KafkaMessageKeyProvider<K>

Type Parameters:
K - The type of the record key
All Known Implementing Classes:
EventPayloadKafkaMessageKeyProvider
public interface KafkaMessageKeyProvider<K>
This interface provides a way to determine the record key that needs to be sent for a particular message
Author:
Roman Saratz

  • Method Summary

    Modifier and Type
    Method
    Description
    K
    determineMessageKey(OutboundEvent<?> outboundEvent)
    Determine the record key for the outbound event.

  • Method Details

    • determineMessageKey

      K determineMessageKey(OutboundEvent<?> outboundEvent)
      Determine the record key for the outbound event. Can be null if you do not want to use a specific value.
      Parameters:
      outboundEvent - the outbound event
      Returns:
      the record key to use