Producer - publish data to a Rabbit queue: Supplier< Flux < Object1 > > publish() { ... }
Processor - process the data coming from Rabbit queue and publish it into another Rabbit queue: Function<KStream<?, Object1>, KStream<?, Object2>> process() { ... }
Consumer - consume data from the new Rabbit queue: Consumer< Object2 > consume() { ... }
Hello,
Could be used Kafka Streams with RambbitMQ only?
I mean something like this:
If so, how should be the configuration?
I tried somethig like this, but doesn't work:
Thank you