What is Benthos for?

Benthos is a stream processor that solves seemingly complex tasks with simple, chained, stateless processing steps. It implements transaction based resiliency with back pressure, so when connecting to at-least-once sources and sinks it's able to guarantee at-least-once delivery without needing to persist messages during transit.

This, combined with the wide range of inputs, processors and outputs that it offers makes it a rather tasty dish for processing important data (or junk data as well actually) for event sourcing, ETL or any other brand of real time data processing.

Benthos is ready to commit to this relationship, are you?

Get Started

Components

Inputs


Processors

Processors that specialize in restructuring messages.

awkbloblangjmespathjqjson_schema

Outputs