The Producer and Consumer

The producer

There is always a producer stage at the beginning of a data processing pipeline since the producer is the source of data that flows into the pipeline. It’s responsible for producing events for all other stages that follow. An event is simply something we wish to use. Later on, it could be a map or a struct. We can use any valid Elixir data type. Here is an example of a two-stage data pipeline: