Message streaming application

Technologies

• Golang
• Redis streams
• Docker & Docker Compose

This application demonstrates a simple producer / consumer stream.

Run with docker.

docker compose up --build

By default this is running with one producer and one consumer.

To increase the number of consumers just change replicas number on consumer service at docker-compose.yml file.

deploy:
  replicas: 1

Graph representation

flowchart LR;
    A[Producer]-->B[Redis];
    C[Consumer]-->B[Redis];
    D[Consumer]-->B[Redis];
    E[Consumer]-->B[Redis];

Loading

Producing messages

You can publish messages by doing POST requests on localhost:8000/produce

Example:

curl -X POST localhost:8000/produce -d '{"message": "Hello from terminal"}'