This directory contains examples of using Benthos with docker compose. Each instance of Benthos is configured using environment variables.
This config sets up a Kafka broker and a Benthos instance that accepts HTTP POST requests and sends the contents into a Kafka topic.
The HTTP port in the Benthos container is exposed, you can therefore send messages through curl:
curl http://<docker_host>:8080/post -d "example message"This config is the same as the previous except messages are sent to a Rabbit MQ instance instead. You can send messages on port 8080 using curl the same way.
This config sets up a Kafka broker, a Rabbit MQ node, and a Benthos that reads messages from the former and sends them through the latter.