kafka-relay

To run:

docker-compose up

In one terminal (source):

docker-compose exec kafka /opt/kafka/bin/kafka-console-producer.sh --topic source --broker-list localhost:9092

In another terminal (destination):

docker-compose exec kafka /opt/kafka/bin/kafka-console-consumer.sh --topic destination --bootstrap-server localhost:9092

This will relay all messages you type into source terminal into destination.

Examples to write:

{"id": 1, "foo": "bar"}
{"id": "2", "bar": "foo"}