Kafka Implementation with Producer and Consumer example in Spring boot | tutorial | Code Decode

[@kanishkkumar8272]

Thankyou so so so much for this. I saw this video just before my interview and cracked the interview. Kafka was asked for 20 minutes. Really, thanks a lot. Got a hike of 160 percent . Interviewer was so impressed by the answers. Thank you once again. Really appreciate it. Please never stop these.

[@CodeDecode]

Many congratulations Kanishk. Well deserved Man 👍👍🎊🎊🎊 keep learning keep shining👏👏

[@syedaqib2912]

Congrats man !!

[@prerna3404]

Which company?

[@GauravSharma-up9gs]

Thanks for simplifying everything at one place. One day you must go famous for your videos in your playlist of your channel.

[@CodeDecode]

🙏🙏thanks a lot for these beautiful words Gaurav. These comments means a lot to us. It keeps us motivated to upload more content 🙏🙏🙂

[@johnnybreathe]

Thanks for the implementation. I have done synchronous microservices till now. It's totally new concept to learn asynchronous also. 🧑‍💻 Thank you so much. And please continue what ever is important these days and in coming future as a java developer. 🤗 TQ for the videos

[@CodeDecode]

Thanks a lot 🙂🙂 sure we will cover grpc next soon

[@geethufrancis6988]

@@CodeDecode thank uu

[@ajitpeshane8311]

very simplified and working poc on kafka, Thank you so much. In my case i struggled while executing the command @ 12.06 minutes error: The input line is too long. The syntax of the command is incorrect. Solution: I have renamed the folder to kafka and moved that to D drive directly. worked for me. Might help others.

[@kasperamkumar5489]

I didn't went through this video bcoz your videos always rockzz I will go through all your video in a few days. All the best 👍

[@CodeDecode]

Hehe sure 👍👍 keep learning keep shining Man👍👍👍👍

[@ankitgiri6874]

Thanks you so much for all of your videos, The way you explain, every concept becomes very easy to understand.

[@CodeDecode]

Thanks Ankit 😊👍

[@joshinim.n9863]

Thank you so much for this series of videos. I feel so grateful for it. This is so useful. You're really imparting great knowledge in people!

[@CodeDecode]

Thanks joshini for the nice words

[@RupsiKumari-r8c]

This was very helping in completing my assignments. Looking forward for more basic video. Thanks much.

[@CodeDecode]

Sure we will create more soon

[@aman_deep21]

Very nice demo for getting started with Kafka, thank you

[@CodeDecode]

you're welcome aman deep

[@ithisrinu9593]

you are best among all you tuber channels tq madam

[@CodeDecode]

😊❤️🙏🙏

[@sreeramsarath5188]

It's very good and way of telling so .. easy to understand.

[@CodeDecode]

Thanks Sreeram🙂

[@PranitKothari]

Wow! Awesome. This can't be explained any better, this can't be explained easier.

[@CodeDecode]

Thanks a lot Pranit 🙂🙂

[@pranjalsingh1099]

Thanks for up to the point explanation. Please continue this series to for explanation of individual components.

[@CodeDecode]

Thanks Pranjal. Sure 👍🙂

[@nitinvnk3975]

Simple, Crisp and to the point thank you for this content.

[@CodeDecode]

You’re welcome

[@rishisharma3569]

Please please please continue this series. I have subscribed and liked and shared.

[@CodeDecode]

Thanks Rishi. 🙂sure we will continue this series

[@SampritiChowdhury-m8m]

Extreme Helpful and helped me to give a valuable KT -session to all my colleagues and make a worthful presentation of it . Thanks a lot mam for boosting Confidence .😇

[@PankhuriSinghChauhan-vr9se]

Loved the explanantion.. clear and crisp. Thank you :)

[@CodeDecode]

You're welcome

[@chetankhandave]

It's my humble request, please make a playlist for Apache Kafka, so that we can go through each video one by one. It will be very easy for every one. And again you have done a fantastic job. Thank you so much.

[@CodeDecode]

We have one Chetan : kzbin.info/aero/PLyHJZXNdCXset6tBB1aY5aEY77YhbxWLo

[@CodeDecode]

We will add more videos to this playlist 👍

[@chetankhandave]

@@CodeDecode Thank you so much for your reply. It will be very useful for every one of us.

[@chetankhandave]

@@CodeDecode In this example, consumer and producer are in this same application, but what if Consumer is in one application and producer in another application ? How can we handle it ?

[@sheiksahil7209]

Great video...loved the way you explained .... Please make a series on Event-Driven Microservices concepts also. Thank you in Advance.

[@CodeDecode]

Sure Sahil. 👍🙂 thanks for the nice suggestion

[@sourabhjinde8191]

Thanks for the detailed video 🙏. Please continue with the architecture video

[@CodeDecode]

Sure thanks Sourabh 🙂👍

[@bhaumikpatel5932]

Thanks for explaining apache Kafka. Please upload more videos on kafka streams and interview questions

[@CodeDecode]

sure bhaumik we will create it soon

[@tanveersyed1049]

Thank u so much for uploading one more kafka video

[@CodeDecode]

🙂🙂👍👍

[@AshishYadav-se4db]

Thank you so much for creating Kafka video 😊,and explanation is amazing 🔥.

[@CodeDecode]

Thanks Ashish 🙂👍

[@siddharthpandey835]

Super! continue more videos on Kafka.

[@CodeDecode]

Sure Siddharth 👍👍

[@shrutik1863]

Thanks for the video. Please continue series

[@CodeDecode]

Sure Thanks Shruti👍🙂

[@sagarsonawane3888]

Thanks, very helpful video to understand kafka messaging

[@CodeDecode]

You're welcome Sagar

[@dipaliyadav-koli1060]

Thanks for your hard work on this.. As usual best explanation.. ❤️❤️❤️

[@CodeDecode]

Thanks Dipali ❤

[@surpriser2292]

Can you please continue the series and provide more information regarding the Kafka Architecture. Kudos for all the efforts in compiling such great video.

[@aishurajas2507]

Thanks alot to you and your fabulous content for java developers! God bless you

[@akashsaha9366]

Thanks maam, for the great explanation

[@CodeDecode]

Thanks Akash 🙂🙂👍👍

[@jampanisuresh4457]

Thank you so much, very help for us. good job

[@CodeDecode]

You are welcome

[@vengateshm2122]

Very informative hands on tutorial.

[@CodeDecode]

Thanx 🙂👍

[@umamaheswarreddy9204]

i loved your energy , TQ for the video. 😊

[@CodeDecode]

Thanks Uma 🙂👍

[@lohir446]

Very useful concept 👌 keep doing

[@CodeDecode]

Thanks a lot ☺ And thanks for the previous comment too 😊

[@arjunyelkachenu]

Great content covered and Im ready to work my Jira story

[@CodeDecode]

Thanks

[@aayanksinghai8242]

Very Well Explained! Thank you

[@CodeDecode]

🙂👍

[@siddhilalabobo3597]

Excellent video for beginners,

[@CodeDecode]

thanks siddhi

[@ARUNKUMAR-mb1dy]

thank you for the information madam, Please continue the video…

[@gudiya1491]

You are a very good teacher i would say 😊, really..very well explained i was struggling with this kafka topic from so long thanks for providing this video.. earlier i watched exception handler ,i understood everything in one go , didn't watch any other videos to understand it better ...can you please provide videos on bamboo and veracode...also aws🙏

[@CodeDecode]

Sure Thanks Gudiya 👍👍

[@lukemagnotta6823]

How Eloquently was the explanation!

[@CodeDecode]

Thanks a lot 👍🙃🙃

[@karamjitsinghsehdev3451]

Nice and Simple. Please try to make real scenario based videos also for experienced. That will help crack interviews. Thankyou.

[@CodeDecode]

Next is too implement kafka in microservices application

[@RishavKumar28]

Very well explained!! Please make videos on streams too. Thanks.

[@CodeDecode]

sure we will create it soon

[@bpani]

Great session mam, thank you!

[@CodeDecode]

Most welcome!

[@Sedhu_17]

Yes mam we need kafka streams tutorial

[@charanm4871]

Thank you so much, this video helps a lot.

[@CodeDecode]

Thanks 😊😊👍

[@user-sapdev]

Thank you so much for for your great efforts and time for getting this content in a simple and clear way. It would be great and useful if you can continue the series..advanced topics like kafka stream API as well.. Thanks once again for your continuous efforts

[@ianuragtripathi]

I have little doubt when you say - “broker is a topic” and “consumer will subscribe to broker”. It conflicts with my understanding that broker is not a topic instead it is a kind of container which have multiple partitions from different topics. And consumer subscribes to topic rather than the broker. Please correct me if I am wrong.

[@fakruu]

The best video beginner friendly video on kafka + spring boot !

[@CodeDecode]

Thanks

[@jayjoshi1366]

It is always worth learning from your videos and this Kafka implementation was really nice one which is even more than MQ. Kindly create next part as well where we can learn about asynchronous communication between multiple micro services. Thanks!

[@karthikeyanrm3446]

Please continue this series. If possible make a series on Event driven Microservices. Not sure if you remember - but I have been asking for so long to cover centralized logging, API gateway, Distributed tracing, ELK, docker-kubernetes also (all companies expect this) and then atlast deploy into cloud - AWS/Azure.

[@CodeDecode]

Yeah all in pipeline Karthikeyan 🙂

[@karthikeyanrm3446]

@@CodeDecode thank you so much. Please do. You guys are awesome 😊

[@cheshvikaraj7769]

nice Explanation. Thank you

[@CodeDecode]

😊👍

[@mukulmangla632]

nice video.. please continue this series. Also can you talk about offset and streams and taking a more complex and practical example

[@CodeDecode]

True. Real beauty of kafka is in streams 👍

[@mukulmangla632]

yes but can also explain offset please

[@d.sharshith3763]

Thank you, I have question Why have you not deserialized while consuming the message?

[@puneetgahlot3556]

Superb , Wooww amazing.

[@CodeDecode]

Thanks 🙂🙂

[@saranyavivekanandan9044]

Hi, Thank you so much for your amazing videos. Could you create a video on different microservice listening to this kafka topic, please? I'm quite confused.

[@kalyanimvn]

U r rocking mam.asm

[@CodeDecode]

Thanks a lot Kalyani 🙂👍

[@unemployedcse3514]

Awesome 😍

[@CodeDecode]

Thanks

[@rahulkhot3290]

Thanks for this Nice Video. I could not find the video for kafka streams, could you please let me know the link

[@MrGoodLuck]

Mam can you show using docker also? 🤔I tried searching for it but playlist doesn’t have that and also can you please make a video nd explain if I am using okta then how to authenticate only once for all the services 😅or any other method is also fine like how will we apply security for it I have seen the okta video but wanted to know how it will be done in microservices architecture

[@rahultripathi1602]

please make Kafka Streams video too and if possible Interview questions video too. Thanks!

[@priyangapinki5715]

Thank you so much. Can you please implement kafka with your vaccination center and citizen project. It will be helpful for understanding real time projects

[@bhavyar4983]

Hi mam plz do cover the interview questions thanks a lot for ur time

[@ourworldofknowledge5542]

Excellent video

[@CodeDecode]

Thanks

[@geethufrancis6988]

Ma'm Thank you soooo much for this playlist. Can you please create a video on setting the kafka messages to Redis db...

[@CodeDecode]

Sure 👍👍

[@vidhiagarwal9370]

But how to get kafka communicate in different microservices? Would this work? because I see you have done the communication in the same service

[@pariveshkurmi3736]

How in kafka, topic codeDecode_topic got created just after start of zookeeper and kafka as per video we have not created it manually ?

[@atulpatil7472]

Thanks for this wonderful video..I was practicing this code and able to consume my message..after all message consumed. I stop kafka and zookeeper server .once again I have started both server and I am again getting same messages in my consumer. How we can avoid that , as I have already read it before and don't want to read it again as it's duplicate for me

[@ajithkumar-xo5gj]

Great video !

[@CodeDecode]

Thanks!

[@kanchankatkar5226]

When will be next video of which you said in last in video, please do keep posting

[@sushilmadankar53]

why in properties file configuration not added for spring.kafka.consumer.......?? like producer??

[@DhruvSharmax]

Can you please let us know how to handle objects instead of string as message. Also how to use kafka streams.

[@abhishekchaudhari2344]

Can plz you clear why consumer not require deserializer there? when we use deserializer in Consumer?

[@chetankhandave]

In this example, consumer and producer are in this same application, but what if Consumer is in one application and producer in another application ? How can we handle it ?

[@UmmakaJagadish]

madam please do more videos on microservices

[@CodeDecode]

Sure Jagadish 🙂👍

[@abhinavgoel4358]

Can you please explain serialisation and deserialisation in Java with practical example

[@doctorag1135]

I am getting error group id is not found in exceptation, SO group id can be custom any thing hardcode right?

[@Cherryhorse]

Please create kafka streams video also

[@CodeDecode]

Sure Anupam 👍👍

[@prateetisingha6729]

Hi , thank you for your videos it's realy helps a lots. Is it possible to share some videos regarding cicd pipeline.

[@CodeDecode]

sure we will upload it soon

[@giridharkumar8176]

I know this is a basic demo, but I have a question, here you did not create topic inside kafka cluster, and no where you added your topic name in any properties file that is being used in two commands u ran in cmd, u added in ur application's properties file but not in kafka application or zookeeper aplication, so then in enterprise application, any one can create as many topic as they want as it does not required kafka broker permission, so how to restrict it then?

[@priyanktiwary1067]

Please post video on rabbit mq implementation also

[@CodeDecode]

Sure Priyank 🙂

[@sayanbiswas8847]

Helpful

[@CodeDecode]

Thanks 👍🙂

[@agusp1951]

What about JsonSerializer or CustomSerializer

[@CodeDecode]

We will add them in playlist soon 👍

[@abdulrehaman4462]

am facing problem in running zookeeper server , input is too long ,syntax error .... what should i do...

[@resikas.b.5511]

you have to create a topic in the terminal. That is not shown in the video

[@CodeDecode]

Not needed

[@dipeekadeshmukh263]

zookeper and kafka both are not running, giving an error as The input line is too long and The syntax of the command is incorrect.

[@nikhilpawar7876]

awesome

[@CodeDecode]

Thanks

[@SudhaBasavaraja-i1r]

Hello Maa'm. I tried to create and execute above code and i am getting error like "Got error produce response with correlation id 46 on topic-partition CodeDecode_topic-0, retrying (2147483626 attempts left). Error: NOT_LEADER_OR_FOLLOWER" . Could you please help ?. TIA

[@deepsarandeepu]

Installing kafka and Zookeeper means, Just downloading it from the URL mentioned ?, Some one can explain ?

[@NainaPriya-s9g]

MA'm, i a getting logs in infinite loop in console

[@Brainvenus]

Good

[@akshayvishwanath2591]

Crazy❤

[@CodeDecode]

😊😊👍👍

[@satishsali5571]

Can you give the link of Kafka with Stream video?

[@smehta344]

Hi, I have one question In one interview they asked me What is the Kafka consumer group name? Please can you help me with this question.

[@CodeDecode]

Already gave an example in demo Sanjeev. What I can think of is consumer id here. We can have multiple consumer insame group by giving common group id/ name

[@smehta344]

@@CodeDecode thanks

[@CodeDecode]

🙂👍

[@souvikasus2903]

I am unable to Install Kafka binary. tgz file in my windows 11. Please help me out.

[@mash6066]

Hi sister, I have one doubt . In springboot In service class for saving books we will use @Autowired Bookrepository br ; We will use br.save(); Bookrepository is an interface Can u explain ,how it will work . @Autowired we will use for object creation But here Bookrepository is an interface

[@mash6066]

I have already commented , regarding this sister

[@CodeDecode]

This interface must extend some existing interface right? It calls internal api to save your data to db

[@venki1437]

Hai medam, Could please create one video on how to work with jsonb type data in postgress and how to integrate that data with spring boot jpa like how to insert jsonb data in Db using jpa create entity class store data in Db retrieve data from db. Note : there is no videos on KZbin related this concept ,could you Create ASAP. it is helpful to programers

[@sivareddy50]

Nice question, please do a video on jpa concept

[@nareshk329]

Please attach PPT as well for information purpose or notes to remember.

[@sureshkamble1526]

Initially title was "KAKA" suddenly wonderd ☺

[@CodeDecode]

🙊our bad. Sorry that was typo 🙊

[@pradeepgupta2089]

Partition key is missing in sample code

[@start1learn-n171]

Tq