Package org.flowable.eventregistry.spring.kafka

Interface KafkaPartitionProvider

All Known Implementing Classes:
EventPayloadKafkaPartitionProvider, RoundRobinKafkaPartitionProvider
public interface KafkaPartitionProvider
This interface provides a way to determine the partition that needs to be sent to a particular topic.
Author:
Filip Hrisafov

  • Method Summary

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

  • Method Details

    • determinePartition

      Integer determinePartition(OutboundEvent<?> outboundEvent)
      Determine the partition for the outbound event. Can be null if you want to use the Kafka default partitioner.
      Parameters:
      outboundEvent - the outbound event
      Returns:
      the partition to send to, or null if you want to use the Kafka default partioner