Implement CQRS Design Pattern with SpringBoot

[@DailyCodeBuffer]

Follow me on Twitter: twitter.com/DailyCodeBuffer

[@KIRANNARAYANA100]

Can you please provide a full length video on service mesh implementation of microservices. we are waiting for that video from long back. It would be very beneficial for many developers if you do so as your explanation looks crystal clear. Hope to see the video very soon...

[@sdash2023]

Why did you make it with Axon instead of Kafka ? Is there any specific reason ?

[@arunbhati101]

This is clean and to the point example of CQRS. You are awesome.

[@DailyCodeBuffer]

Glad that you have enjoyed 🙏

[@rakshithvp1877]

Hundreds of Spring boot developer would be in need of this video. Thanks man 😊

[@DailyCodeBuffer]

Thank you 🙏

[@amarjeetnayak7098]

The objective of cqrs is to segregate the read and write db, also important things to be note to sync the read db with write db, but in this video this part is missing, as its the crucial part of this pattern.

[@updownftw]

Maybe when we are saving the product, we can send another copy to a message queue, and from the message queue, the query microservice will fetch and store it in the database. This is just my thought, I don't know how they actually do it in the industry.

[@deeproy2719]

yes this comment can be pinned and the solution is there in the reply by @updownftw_

[@presteena]

@suresh kumar Could you please provide video url?

[@reynasebasti3635]

What r tools or frameworks, to synch data between read n write dbs? so data / system could b consistent

[@masterchief1520]

​@@updownftwmaster write and slave read replicas

[@nadimmatoussi8772]

Thanks!

[@koloyolo7629]

For everyone who get error "Parameter 0 of constructor in command.api.controller.ProductCommandController required a bean of type 'org.axonframework.commandhandling.gateway.CommandGateway' that could not be found." This is compatibility issue between axon and spring boot, consider downgrading spring boot version to 2.7.x

[@hamedabbaszadeh7536]

Greate video, thanks. but i've a question what happens if we have two databaes, one for read another for write. what we should do about data consistency? you didn't seprarate the databases and i think the whole idea is separaing them

[@mohammadfahim796]

Bro your content is awesome just do 1 favour. Arrange all the video in playlist. we have to find those

[@Scoty98]

Thanks for tutorial. Do you think about Full in depth Spring Security. Would be awesome.

[@kirankumarmovva9115]

All videos are very good and hit straight to the point without wasting the time. I like it all.

[@DailyCodeBuffer]

Thanks 🙏

[@updownftw]

Hi Shabbir, thank you for the video. But I have one question, the CQRS example you took is sharing the same database. Isn't the whole point of CQRS is to make the applications loosely coupled? How do I connect my command and query databases and make sure they are in sync? Can we achieve it by sending the product object to a message queue and then having the query microservice listen to it and thus save it in its own database? This is just my thought process, I don't know how exactly they do it in the industry.

[@syedzishan3676]

If we are updating read_db via an event or message then essentially we are performing write operation on it 🤨, then how it is any different than having a single db ? 😅 If i am to guess there must be some db replication in affect here via axon server which he forgot to explain or so , anyway if you have found a way for it please reply to this thread . I am looking for solutions 🙏🏼

[@ngantran-id4gq]

Can you answer me pls? why we need to update the properties in aggregate?

[@arghyamitra3281]

Great tutorial ... Sir can you please make event driven architecture with kafka please

[@Phani.B13]

Excellent way of explaining the concept... Found very helpful. Thanks a lot 😊

[@DailyCodeBuffer]

Glad it was helpful!

[@reactaws6603]

Hi Shabbir , My question is , where you have imolemented fault tolerance and you haven't stored events in any database as eventstore using eventsourcing repo. if any thing fails in future we can use fail safe mechanism and we come over data losss scenarion in real world . if our events willl be persisted with db event store . i can see its available with axon server but what if we rebounced axon server then we lose the data,i have tried this. can you use rdbms to use as event store. you explanantion was really cool just add above point in your CQRS video.

[@dikshaagarwal5598]

Hi DailyCodeBuffer , easy explanation and setup ,but I have one doubt here we still are not able to segregate writeDB and readDB , and this seems to be the important point to be considered for CQRS, As of now , data is getting stored to and being read from sameDB

[@ArunSingh-ql3tf]

Actually, H2 database is the read store which Query Model is using to query in. EventStore is your writeDB where events are stored in the order they are sent. EventHandler is responsible for providing event consistency to the H2 database (your readDB).

[@ashokkumar-cx6of]

Hi, Same code I’m implementing but CommandGateway bean is not creating . I tried to create bean using configuration but no luck . How can I resolve this issue ?

[@PhoenixRisingFromAshes471]

whats the difference between kafka and axon.Why we are not using kafka....Please explain

[@shubhamjumde9076]

Also, can we have video series where we implement Microservices communication with ActiveMQ. This time , let's take more than 3-4 Microservices.

[@vvendan340]

awesome viedo CQRS

[@747r7]

Good starter !. For running docker image of axon : docker run -d --name axonserver -p 8024:8024 -p 8124:8124 axoniq/axonserver

[@Pest87]

Great video, thanks. What would be the optimal way to avoid here the copying of the product properties between the different classes?

[@ambatipudimanjunath1829]

Parameter 0 of constructor in com.example.command.api.controller.ProductCommandController required a bean of type 'org.axonframework.commandhandling.gateway.CommandGateway' that could not be found. getting this error can you please help

[@hendisantika]

Why exception is occur? And why the new data is not insert into DB after We handle the exception?

[@HungPhan-bt7nq]

Thank for great example implement CQRS pattern. When I run project. In database, it generate 4 tables: saga_entry, token_entry, association_value_entry and product. How 3 tables: saga_entry, token_entry, association_value_entry generate? Thank you!

[@kanakarajuadari401]

After created the Command Controller and running the project i am getting below error: Parameter 0 of constructor in com.demo.ProductService.command.api.controller.ProductCommandController required a bean of type 'org.axonframework.commandhandling.gateway.CommandGateway' that could not be found. Action: Consider defining a bean of type 'org.axonframework.commandhandling.gateway.CommandGateway' in your configuration. Any suggestions here

[@acchutdevkule7841]

Please make video on activemq with realtime example

[@listener-000]

after exception I get this log messages: " TrackingEventProcessor : Releasing claim on token and preparing for retry in TrackingEventProcessor : Released claim " and what does it mean?

[@meryemOuyouss2002]

Please what about java 17 ,I have problem but I don't how to fix it, is it because of the version used or what????

[@armannizar3302]

can anyone know how to add configurations and which one we want to add for this project

[@nicholasmaundu2130]

Good job sir, was working CQRS but i really struggled am well informed now

[@charithjayasekara5252]

In this flow isn't the event generated before the actual product is generated?

[@reynasebasti3635]

What r tools or frameworks, to synch data between read n write dbs? so data / system could b consistent

[@mahgsvtshh5444]

Can you make video on ELK , junit5 ?

[@aakashkhatavkar7877]

I really dont understand purpose of Axon Framework here. What I understood is you are dividing one microservice into 2 parts one is command and another is query. Command Part will handle PUT/POST/DELETE request and Query part will handle GET request. As command part will store data in Database and through Events It will store in Axon Server and while fetching Data also you are fetching data first from Database and putting it in Axon classes and sending response. Why cant responses be send directly ?? If I want to fetch join queries then eventually I have to query DB for that then how does Axon is really helping here. Also for READ / Write you are using same DB instance. It's creating so much of confusion here

[@rajubhattarai3326]

exactly my point. He is using same DB. He hasn't used seperate DB for Read and Write. Need to have Seperate DB for Read and Write..and that need to be synced tooo. but while getting data..he is querying from the same database.

[@SatishKumar-yi8qi]

Can we create command api and query api has separate microservices if so the event handler and event sourcing will work or any special mechanism we need to incorporate to send data to query api from command api..

[@DailyCodeBuffer]

We can do easily using Axon server

[@SatishKumar-yi8qi]

@@DailyCodeBuffer the application you built is not using axon server then. Iam totally confused. The application you built suppose I separate command and query api as separate microservices will they work

[@murugesh1915]

how to handle Transactional Management of save to write DB and save to read DB here?

[@updownftw]

Hi Shabbir, I tried creating different Service for the query, the events created in Command service is not being handled by event handlers at Query Service. What am I doing wrong ?

[@DailyCodeBuffer]

Can you please share the Github link so I can check

[@updownftw]

@@DailyCodeBuffer Is this the correct way? Example: I'd publish an ProductCreatedEvent in the command service, and then I'll have an @EventSourcingHandler in the same microservice, but the @EventHandler would be in the query microservice. Or do I need the @EventSourcingHandler in the query micorservice as well ?

[@updownftw]

@@DailyCodeBuffer I actually already deleted the Query microservice and implement your way.

[@DailyCodeBuffer]

Event handler and event sourcing handler should be in one service

[@updownftw]

@@DailyCodeBuffer so Do I need to create the same aggregate in query service and have the event handler there ?

[@Sanchitgoel10]

We could have used autowired for dependency injection right? like you are manually injecting it by creating constructors any reason for that?

[@DailyCodeBuffer]

That is recommended way

[@Sanchitgoel10]

@@DailyCodeBuffer Thanks for the reply. I am also getting the following error after running till the commands api part - Error creating bean with name 'entityManagerFactory': Requested bean is currently in creation. Any idea why this is the case or any suggestions how to debug in such case.

[@DailyCodeBuffer]

Don’t know by looking at it, l’ll check and respond here back

[@Sanchitgoel10]

Okay Thank you so much

[@sumitsharma-xk6ig]

@@Sanchitgoel10 is your issue is resolved? because i am getting the same.

[@IvanRandomDude]

What is your Idea theme? Colors look great

[@DailyCodeBuffer]

Xcode 12 dark

[@focus15624]

@EventHandler and @QueryHandler is not working in your project in my machine. Command side is ok.

[@reynasebasti3635]

Can u pls make video with kafka, what do u think? N also video how to have consistency between reads n writes with segregated dbs how would u r update read DB after writes in write DB??

[@AmitSingh-qd2vn]

Can provide a link to this PPT?

[@hawkeyefighter8826]

I followed the same code.. i faced error - "Error creating bean with name 'entityManagerFactory': Requested bean is currently in creation: Is there an unresolvable circular reference?" >Can anyone please help?

[@anthonya880]

Is CQRS commonly used in Spring Boot Microservice projects ? Please answer anyone.

[@DailyCodeBuffer]

It is used at many places

[@nareshk329]

can you please share the google doc link for CQRS design pattern PPT.

[@ranjaninatarajasharma5917]

You have earned a subscriber... thanks a lot for all gr8. Videos

[@DailyCodeBuffer]

Thanks 🙏

[@krishnamurthysuripka6774]

Excellent Explanation bro.. keep it up..

[@DailyCodeBuffer]

Thanks 🙏

[@weixiangng8279]

@Daily Code Buffer, Hi I want to ask is this CQRS part of Eventuate Tram? I am doing a spring boot program for Eventuate Tram and wondering if your video has some relations to it. If I use Eclipse and Postgres database that would be fine right?

[@DailyCodeBuffer]

This implementation of CQRS is using Axon framework

[@luongbich3223]

please make a tutorial about gRPC!

[@mandhakarthik]

Please share CURD tutorial using axon framework

[@syedzishan3676]

Can you share a video on data replication betn read_db and write_db and how to achieve it ?

[@kumarm2885]

Excellent explanation sir thanks for for your efforts keep going.

[@DailyCodeBuffer]

Thanks 🙏🏻

[@aminetech4582]

Thank you for this awesome tuto But the most important thing on CQSR is to seperate databases But I see that you did not explain how to do so !

[@darvin3665]

Axon Server or Kafka?

[@DailyCodeBuffer]

Axon server

[@soniaengr]

So informative and so well explained each and every component with example . This is one of the best videos on cqrs. I have implemented spring boot with rest api can u pls explain in detail how and in how many ways microservices communicate with each other - synchronous/ asynchronous thanks !

[@DailyCodeBuffer]

Thanks 🙏🏻 Both part of Micro services are also covered in separate videos

[@Lets_explore51]

Very useful video. Thanks for the content..

[@DailyCodeBuffer]

Thanks 🙏

[@priyankakande3427]

Very good example and explanation I understanded basic concept How to use patch mapping in application I am unable do that

[@ayushdedhia25]

After a long time 😅😀

[@azharmobeen]

Hi, thanks for sharing but could you please why we need and when we need SQRS ?

[@shahidgheti1692]

Rock start............ great Explanation

[@DailyCodeBuffer]

Thanks buddy 🙏🏻

[@devaamujuri5998]

Nice tutorial. by the by which theme that you are using :-)

[@shubhamjumde9076]

Hi, This is helpful video. Can we have any video series for Consul and Vault with Microservices and Spring Boot please.

[@prajjwallaad]

Which keyboard do you use bro? 😬

[@DailyCodeBuffer]

Keychron K2

[@tranvanthao2193]

hi sir. I have error when run programe. Can you help me -> Connecting to AxonServer node [localhost:8124] failed.io.grpc.StatusRuntimeException: UNAVAILABLE

[@MinhTran-yb3ec]

please make a tutorial about report service in microservice..thanks in advance

[@KehindeAdeoya]

You've really tried. Your tutorial seems the best because of its simplicity. Do you have the full CRUD of this tutorial?

[@mandhakarthik]

please share the full curd tutorial

[@SatyendraSingh-ov1de]

Hi, In end you said we can propogate the error from event handler to controller. Please help us with reference to understand how its done

[@murilobarbosa5062]

Did you find out how?

[@TheVishal38]

Excellent explanation 👍

[@DailyCodeBuffer]

Thanks 🙏

[@DeepakGupta-hj2dv]

Please make on video Spring core crash course

[@adityagupta4218]

Bhyia i just want to talk something as personal could you please tell me how can i reach you

[@DailyCodeBuffer]

Ping me on Twitter or LinkedIn

[@Chauhannitin]

Noticed that you have copied the model properties across multiple layers, transforming/passing from one to another layers. Do we really need all these layers ? Can't it be made more simple ?

[@mdgufrankhan4306]

Excellent video. Keep going.

[@malicious8909]

R2DBC tutorial next pleaseeee, thank you you're awesome

[@DailyCodeBuffer]

Glad you enjoyed

[@camzpras3435]

How to delete using CRQS?

[@reancode2755]

Really great content ❤, thanks

[@DailyCodeBuffer]

Thanks 🙏🏻

[@pablourbanohernandezvizcarra]

Thanks for the great video

[@sonalnarayankar8015]

can you share code of this project

[@DailyCodeBuffer]

Link in the description

[@akhileshshende273]

Excellent !!

[@nalcow]

great content man, you have a great sense to get right to the point. Making easier learning.

[@DailyCodeBuffer]

Thanks 🙏🏻

[@felipefranco-]

You're amazing!!! 🤩😍

[@DailyCodeBuffer]

Thank you 🙏

[@pawsdev]

Thats great !!

[@fabricioaraujo7642]

great content !!

[@DailyCodeBuffer]

Thanks 🙏

[@nikhileshyoutube4924]

Bro make a video on java learning path as backend junior developer

[@DailyCodeBuffer]

I will plan for it

[@nikhileshyoutube4924]

@@DailyCodeBuffer thx bro 🙏🏻🙏🏻

[@faizan346]

@@DailyCodeBuffer please do that. Also explain how you approach new topics and master them.

[@souvikpatra2737]

Amazing just wow...

[@DailyCodeBuffer]

Thanks 🙏

[@nitishvk8598]

Superb

[@DailyCodeBuffer]

Thanks 🙏

[@koolkravi]

Goon one.

[@DailyCodeBuffer]

Thanks 🙏

[@fbsouza]

You broke "Dry" so much 😢

[@darvin3665]

Crack!! Thanks.....

[@DailyCodeBuffer]

Thanks 🙏🏻

[@josersleal]

Axon is paid, which means that the possibility to use this in real world is very limited.

[@mustafa52z]

Luckily Im working with cqrs in my project

[@DailyCodeBuffer]

Great. Hope you enjoy the tutorial. If you are using anything new in your project, I would love to learn that as well. Please Share if possible 🙏

[@mukundagaddam]

Can you do support , if required ?

[@mustafa52z]

@@DailyCodeBuffer sure bro

[@mustafa52z]

@@mukundagaddam what support you need?

[@patrykgrudzienkodey1220]

Having watched this tutorial, I'll never use the word "particular" (:

[@indreshmahor8293]

Bro your hands-on are great, but tooo much "OVER HERE" in your videos... Kindly please delete those from your dictionary, at some point of time it becomes irritating

[@DailyCodeBuffer]

Thanks Indresh. Working on that part to be better.🙏

[@sergioruyenator]

Bro, just advice. Stop said "Awyeah", this make many things confuse.

[@DailyCodeBuffer]

Thanks for the feedback. I am working on speech improvement 🙏

[@benjsoft]

Next time,. please do not speak too fast :D It looks like you are in a race :D

[@johnthompson1007]

Hey man.. u have to stop keep saying “OVER HERE”…;).. if you count that word in entire video.. that would come around 50+ times…

[@DailyCodeBuffer]

Yes 👍 Working in to improve in that Thank you so much for the feedback 🙏🏻 Keep Supporting

[@ramosespann6496]

Consider defining a bean of type 'org.axonframework.commandhandling.gateway.CommandGateway' in your configuration. ??

[@youtubegarbage4u]

i believe you use OBS studio for recording but what do you use for editing your videos?

[@DailyCodeBuffer]

Final cut pro

[@youtubegarbage4u]

@@DailyCodeBuffer doesnt that make file sizes way too big?

[@DailyCodeBuffer]

That depends on the export settings