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).
Last updated
Core Platform
These runners are based on Samza library, receiving requests from Samza consumers (e.g. Kafka) and returning results on Samza producers (e.g. Kinesis).
Last updated
All Samza configurations are applicable, and can be passed on to these runners using global runner elements.
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.
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.
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.
