Content-Based Routing

Implement content-based routing. Given messages with types: "ORDER:laptop", "LOG:debug info", "ORDER:phone", "LOG:error info". Route ORDER messages to an orders stream and LOG messages to a logs stream. Use groupBy() operator and print with appropriate labels.

Expected: "Orders: laptop", "Logs: debug info", etc.

Expected

Orders: laptop
Orders: phone
Logs: debug info
Logs: error info

Previous Next

Main.kt

Content-Based Routing

hard⏱ 15 minkotlinreactorchallengekafka-messaging

Expected: "Orders: laptop", "Logs: debug info", etc.

Why this works

groupBy() splits a Flux into multiple GroupedFlux based on a key. Each group can be processed independently, enabling content-based routing. This is how Kafka consumers might route messages to different processing pipelines.

Expected output

Orders: laptop
Orders: phone
Logs: debug info
Logs: error info

Content-Based Routing

Expected: "Orders: laptop", "Logs: debug info", etc.

Expected

Orders: laptop Orders: phone Logs: debug info Logs: error info

Content-Based Routing

hard⏱ 15 minkotlinreactorchallengekafka-messaging

Expected: "Orders: laptop", "Logs: debug info", etc.

Why this works

Expected output

Orders: laptop Orders: phone Logs: debug info Logs: error info