smallrye-reactive-messaging icon indicating copy to clipboard operation
smallrye-reactive-messaging copied to clipboard

Published 20 hours ago • verified publisher icon smallrye

Request for Synchronous KafkaResponse

Open thomasandre84 opened this issue 4 years ago • 6 comments

With Message Communication we want to prevent direct communication between the services. Sometimes there is the case where we need inforamtion from a service and need to continue working on with the response.

Would sth. similar to the KafkaReplyTemplate be an option to be part of Smallrye Reactive Messaging?

thomasandre84 avatar Feb 09 '21 14:02 thomasandre84

I believe it could be done. I've started to look at that a long time ago, but priorities changed.

cescoffier avatar Feb 09 '21 15:02 cescoffier

I could provide my protytype for this, if it helps. It's not nice code. I just made it working.

thomasandre84 avatar Feb 10 '21 08:02 thomasandre84

Yes please!

On Wed 10 Feb 2021 at 09:23, Thomas Andre [email protected] wrote:

I could provide my protytype for this, if it helps. It's not nice code. I just made it working.

— You are receiving this because you commented.

Reply to this email directly, view it on GitHub https://github.com/smallrye/smallrye-reactive-messaging/issues/988#issuecomment-776531226, or unsubscribe https://github.com/notifications/unsubscribe-auth/AADCG7PUDWUIJ2KL6GZNFLTS6I7BNANCNFSM4XLDCTWQ .

cescoffier avatar Feb 10 '21 10:02 cescoffier

https://github.com/thomasandre84/quarkus-tryouts/blob/master/quarkus-kafka/src/main/java/org/acme/commandmode/ProdConsService.java

I've put it all in one package: https://github.com/thomasandre84/quarkus-tryouts/tree/master/quarkus-kafka/src/main/java/org/acme/commandmode

thomasandre84 avatar Feb 10 '21 16:02 thomasandre84

Thanks!

On Wed 10 Feb 2021 at 17:54, Thomas Andre [email protected] wrote:

https://github.com/thomasandre84/quarkus-tryouts/blob/master/quarkus-kafka/src/main/java/org/acme/commandmode/ProdConsService.java

I've put it all in one package: https://github.com/thomasandre84/quarkus-tryouts/tree/master/quarkus-kafka/src/main/java/org/acme/commandmode

— You are receiving this because you commented.

Reply to this email directly, view it on GitHub https://github.com/smallrye/smallrye-reactive-messaging/issues/988#issuecomment-776856153, or unsubscribe https://github.com/notifications/unsubscribe-auth/AADCG7P6BNFKCF26XHXI3PLS6K23JANCNFSM4XLDCTWQ .

cescoffier avatar Feb 10 '21 17:02 cescoffier

Hello, I've improved the readability a bit: https://github.com/thomasandre84/quarkus-tryouts/tree/feature/kafka-response/quarkus-kafka

thomasandre84 avatar Apr 10 '21 16:04 thomasandre84