Skip to main content

Kafka Outbound Channel

The Kafka outbound channel allows for configuring how an event should be produced to a Kafka topic.

Partition Provider

Kafka Outbound Partition Provider UI

Flowable provides multiple options to configure the partition for a Kafka Outbound event:

  • Default - Use the default Kafka mechanism
  • Event field - Use an event field to get the partition to which the event needs to be sent
  • Round Robin - Use a Round Robin approach to determine the partition to which the event needs to be sent to. This can be a string or an expression that resolves to a string. The string can contain a comma-delimited list of partitions, or ranges of partitions (e.g. 0-5, 7, 10-15).
  • Delegate Expression - Use a Delegate expression that resolves to an instance of org.flowable.eventregistry.spring.kafka.KafkaPartitionProvider that will provide the partition to which the event needs to be sent.