Skip to main content

Apache Kafka Connectors for LittleHorse

The core of LittleHorse Connect is a series of three Apache Kafka Sink Connectors, which read records (or events) from Kafka topics and trigger actions in the LittleHorse Kernel:

  1. io.littlehorse.connect.WfRunSinkConnector, which runs a WfRun for each record in Kafka.
  2. io.littlehorse.connect.ExternalEventSinkConnector, which posts an ExternalEvent for each record in Kafka.
  3. io.littlehorse.connect.CorrelatedEventSinkConnector, which posts a CorrelatedEvent for each record in Kafka.
A depiction of the WfRunSinkConnector, ExternalEventSinkConnector, and CorrelatedEventSinkConnector, which run workflows, post external events, and post correlated events (respectively).
Kafka Connectors for LittleHorse Connect