linux – Kafka console-producer to read result of console-consumer on the fly in bash

redirect the output of [consumer topic] to [producer topic]

This is what MirrorMaker is for.

github.com/apache/kafka/tree/trunk/connect/mirror

Otherwise, Kafka Streams app can be used for the same, within the same cluster.

Using this I would be able to avoid using too much disk for consumed messages

kafka-console-consumer does not write to disk. It writes to stdout. The Kafka topic data still exists on the broker’s disks.

avoid duplication

Not really? kafka-console-producer doesn’t dedupe data on its input stream.

Read more here: Source link