Samza Runners

These runners are based on Samza library, receiving requests from Samza consumers (e.g. Kafka) and returning results on Samza producers (e.g. Kinesis).

All Samza configurations are applicable, and can be passed on to these runners using global runner elements.

Sync Samza Event Runner

SyncSamzaEventRunner(com.rierino.runner.samza.SyncSamzaEventRunner) guarantees message order, with blocking properties for each message received.

Name of the input topic is used as the stream and the messages are used as the full event contents.

Async Samza Event Runner

AsyncSamzaEventRunner(com.rierino.runner.samza.AsyncSamzaEventRunner) does not guarantee message order, as it provides certain level of parallelization.

Name of the input topic is used as the stream and the messages are used as the full event contents.

Samzahttps://samza.apache.org

Samza Page

Samza runners can also communicate with Restful event runners (e.g. as a step inside a Saga flow), which results in synchronous event exchange with the remote runner.