I am implementing microservices API however not planning to have any message broker. API Services will talk to each other with WebClient/web flux. Not using any message broker due to skill/budget challenges. Is there any risk of going production like this? what are the drawbacks like failover/replay?
Is there any risk in having reactive approach micro-services for API integration (direct using WebClient) ,without any message broker?
97 Views Asked by Ramneek Handa At
1
There are 1 best solutions below
Related Questions in SPRING-CLOUD-STREAM
- Java EXCEPTION_ACCESS_VIOLATION (0xc0000005) while using Eclipse / IntelliJ
- Spring Cloud DataFlow - How to use a custom TCP encoder/decoder in TCP source
- How do I (integration) test @StreamListener with RabbitMQ?
- Spring Cloud Stream Rabbit MQ fanout exchange
- Intercept incoming message of Spring Cloud Stream SubscribableChannel
- compute aggregations on event data received using Spring Cloud Stream Kafka
- How to build Spring Cloud Stream JMS ActiveMQ
- Spring cloud stream writing in two databases
- Spring Cloud Stream - Mock Source always failed (without an existing MQ instance)
- Understanding Spring Cloud Stream content types
- What is the bean scope and context holder for Spring Cloud Stream?
- How to skip the header row(first line) of the file in springcloudstream using DSL?
- Spring Cloud Stream header enricher circular reference and NPE
- Spring Cloud Dataflow server - deployed streams ended up in unknown state
- Kafka consumer in spring cloud stream dont start
Related Questions in REACTIVE
- Coursera Scala SBT submission issues
- How to delay retrying to send an HTTP request with RxJS5?
- Why does ReactiveUI have a dependency on an old version of System.Reactive?
- R Shiny reactive subsetting of data in a leaflet plot
- RxJS: How to do some clean-up before reactive search in angular 2
- why react search is so slow in angular 2
- Create ControlProperty for custom UIControl
- RxJava: OnNext Unsubscribe is not working
- R Shiny- reactive error: Warning: Error in .getReactiveEnvironment()$currentContext
- Getting an Observable that emits two types
- Does Observable.Range break The Observable Contract?
- How to change displayed table depending on the userInput
- Publish/subscribe per time interval in Meteor
- Observable returned from function never sends onNext
- ReactiveCrudRepository to use Hibernate in spring
Related Questions in MESSAGEBROKER
- Websphere Message broker multi-instance message flow
- using Message oriented middleware for communications within single web application realm
- GETTING SERIALIZING ERROR WHILE ASSIGNING VALUE TO THE DFDL PARSER IN ESQL
- How to write CHARACTER variable to file in ESQL?
- Number of messages flowed through queue
- Use of java in WMQ/WMB systems
- DFDL Parsing for x9.2 specification message
- How to print a message in broker log
- Not able to write time stamp value from WebSphere Message Broker to SQL Server 2012 database
- Paho MQTT cleanSession set to false yet not receiving messages
- Lightweight message queue to use with Celery 4.0
- RabbitMQ : Can I get latest n messages?
- What is the best style of integration considering a large volume of transactions and guaranteed delivery?
- is redis pub/sub realistic in php?
- NPE when connecting to the broker
Related Questions in SPRING-REACTIVE
- Get current logged in user in Spring AOP using Spring Webflux
- How to test HandlerFunction without RouterFunction in WebFlux using Functional API?
- How to create a generic wrapper for just any method call?
- How to get rid of the conversionServicePostProcessor bean conflict?
- Is there any risk in having reactive approach micro-services for API integration (direct using WebClient) ,without any message broker?
- Using reactor context to get back results from downstram chain
- How to use Spring WebClient to make a subsequent call with different header setting?
- Spring Reactive WebFlux - how to customize the BadRequest error message
- Spring Boot Couchbase Reactive isn't supporting Pagination
- Reactive WebFlux Publish Notifications to specific Subscriber
- How to get User object from Mono<User> without blocking it in Java?
- Generate elements applying a function to two consecutive elements of a Reactor Flux
- Spring Cloud Function and Dead Letter Exchange
- Spring Reactive WebSocket does not come up when spring-web is present
- Stream<Mono<T>> to Flux<T> in spring reactor
Related Questions in SPRING-REACTOR
- Why am I getting onComplete signal when an exception is encountered in Spring Cloud Stream reactive consumer?
- Project Reactor - Long running Reactive Kafka Consumer
- Is there any risk in having reactive approach micro-services for API integration (direct using WebClient) ,without any message broker?
- WebFlux - Reactor Http Epoll threads
- transform vs transformDeferred
- Generate elements applying a function to two consecutive elements of a Reactor Flux
- Stream<Mono<T>> to Flux<T> in spring reactor
- For spring data reactive cassandra when repository methods are called is the entire result of the query loaded to memory before returning a flux
- org.springframework.boot.web.reactive.error.DefaultErrorAttributes is not getting called anymore in org.springframework.boot:2.3.1.RELEASE
- Spring Gateway AsyncPredicate not working with reactor and flux
- retryWhen used with flatMap throws exception
- How can I flatMapMany with multiple web calls and conditionally signal complete?
- Schdulers.elastic not creating new threads in Reactor
- How to bridge between a non-reactive Spring EventListener and a reactive Flux
- return Mono/Flux with 2 nested subscriptions
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
It really depends on your requirements. A message broker is well suited to asynchronous, event driven applications. For request -response, I recommend http. A message broker provides additional capabilities. For instance, you get guaranteed delivery, partitioning, which is important if you require strict ordering, and a dead letter queue can be used to track and remediate failed requests. And as you mentioned, replay.