Spring Boot with Spring Kafka Producer Example | Tech Primers

[@manojmajumdar3815]

Wasted a whole day reading a dzone article regarding kafka, this tutorial made my day, beautifully explained!!!!

[@TechPrimers]

Glad it was helpful!

[@VANTYCSolutions]

Absolutely

[@abhishek9720]

bahut sahi bhai

[@BaluKompalli]

Yes ,dzone is waste to read. Only that author will know what he is trying to say

[@utbhargav]

Watched so many Vidoes on Kafka to understand but finally end up with this video for kafka understanding.. Thank you for serving IT community.

[@JohnnyNilsson83]

Great and simple explanation. Nothing extra, just straight on point all the time. Thank you!

[@Hufsa]

This is pure gold, the way you explained using a simple GET and showing how to pass a String and then a JSON make the example perfect, great job.

[@BaluKompalli]

Great video.. Easily understood.. I am a beginner to Kafka. Didn't understand all the theory part. But this practical example useful very much.

[@cicciopasticcio8469]

Perfect video to start playing with Kafka & spring boot

[@adilkhanabdrashov7507]

Amazing channel!!! ONE OF THE BEST I've SEEN!!! THANK YOU SO MUCH! WITH LOVE & RESPECT FROM KAZAKHSTAN!!!!

[@cleyxds]

thats exactly what i was looking for, thank you so much!

[@dac5961]

It is very useful video; I learned about Kafka from this video tutorial. Thank you so much and god bless you.

[@NgocBich-tunmiumeo]

Very straightforward explanation. Thank you so much. It's very useful for me!

[@nagarajanerode]

Very simple and straight forward explanation .... Thanks...

[@spicy2602]

Short and sweet tutorial. Thanks 😊

[@thulasikiran]

Cool !! very useful video. It's simple to understand Kafka. May I request you to make a video on multiple microservices communicating with each other using Kafka. Thank you once again for the tutorial.

[@AbhishekSingh-xx5tx]

yes sir, plz do that same.

[@mohammadzeeshan7074]

Do it do it do it

[@RohitSingh-ITProfessional]

Awesome - simple and great content

[@Srini8174]

Thank you for clear explanation along with example

[@silviafarfan2523]

Very clear explanation. Thank you

[@AI_for_funn]

glad i found this channel

[@naveenakuntalabavi3055]

Great and simple explanation if possible please share a real time use case of kafka in springboot &microservices

[@TechPrimers]

It's shared already naveena Take a look at my video on Kafka Streams

[@raghuls1469]

Really good explanation. It was working perfectly for me.

[@karthikmk9]

How do we need to work with multiple cluster nodes with zookeeper and spring boot (kafka). How it will prioritize the incoming requests, because all requests are given to nodes (1..n) and in that one node gets prioritiy. How kafka handles requests and passes to zookeeper with spring boot

[@SushilKumarBhaskar]

One of the great tutorial on Kafka clear and concise

[@ambersingh1493]

Awesome video bro. Really helpful. Thanks.

[@commonman8540]

great, very nice explanation

[@jayanareshk7566]

Thanks for simple and clear explanation

[@bcreatename]

Great explained.. please post more videos on Kafka. Thank you.

[@deepujs]

@Bean above producerFactory method is not required. right? as it is getting called from the kafkaTemplate method which has @Bean

[@Mahesh-ry9oe]

We can also configure in application.properties instead of configuration class.

[@balsubu1]

very nice...neatly explained

[@TechPrimers]

Glad you liked it

[@UmarShaikh-ck3vt]

BEST and CLEAN Thanks

[@rakeshroshan829]

Hi, can you also cover the Sync and Async producer send options with Future and Callbacks?

[@bilalhayat1]

Simple and good explanation.

[@yadd13]

Lovely explanation 👌🙏🏼

[@nabarunbhowmick1488]

Instead of the config file, we can make use of the properties file by adding two entries in application.properties spring.kafka.producer.value-serializer=org.springframework.kafka.support.serializer.JsonSerializer spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer Springboot will take care of the DI

[@EvgeniiSuvorov]

What if I want to use my own serializer like mapstruct for example?

[@chenyangwang7232]

Thank you! You solved my problem!

[@SivaPolamarasetti]

Thank you for your video I want some clarification on Kafka is it suitable for financial services like banking sector

[@TechPrimers]

If you use necessary security measures for authentication, authorization, data encryption/masking, storge, etc., then you can use it.

[@TechPrimers]

Here is a case study from Capital One bank www.confluent.io/kafka-summit-sf18/building-an-enterprise-streaming-platform-capital-one/

[@SivaPolamarasetti]

@@TechPrimers thank you for your reply

[@stephenlimb6141]

Good stuff, straight to the point. Thanks.

[@amebaos]

Thanks. It worked like charm!!!!

[@laxman20101]

I have a doubt, at 16:26, we have created a bean for producer factory but instead of autowiring in Kafka template why do we need to call the function producerFactory()?

[@MrYtkrishna]

Good and clear explanation..

[@meprajwal01]

Thanks for the video. It's very useful.

[@carlosjuliopv]

Awesome video !! Hello from Colombia

[@TechPrimers]

Hi Carlos. Great to see you. Welcome to TechPrimers

[@geekgeeks2256]

Really thankful to your videos i somehow started my journey in micro services ...One Query *where will we use kafka in real world projects ? If any of you guys could share the example it will be really helpful* Thank you..

[@TechPrimers]

Usually Kafka is used in Big Data space where huge stream of messages need to be processed. It goes well with Spark Streaming and Kafka Streams

[@geekgeeks2256]

Thank you Ajay for the instant reply

[@CarlSaptarshi]

it can also be used for general event driven programming - you may have many microservices in your project, and they may be waiting for some event to be triggered asynchronously. By putting messages onto a kafka topic, the consumer will detect that a message has been put onto that specific topic, and will consume from it immediately, and enable that flow to begin, whilst some other unrelated process continues on as part of that specific flow

[@jhonceenaskt]

Thank man, simple but detailed informative, keep it up, wish u all the best...

[@sudarsanedagotti4525]

Thank you so much.. it is very simple and I made it in 30 mins using this tutorial

[@davidemm841]

Thanks for this video. Simple and useful. it was very helpful!

[@availkrishmytube]

Great session!

[@balamurali7214]

Awesome explanation. Able to understand the concepts clearly. Thanks.

[@AryanVenkatOfficial]

Good work guys!

[@sumeshsuseelan2954]

Thank you so much, bro. This video helped me a lot :)

[@diogennesthesinope61]

Awesome xplanation, thnx! Could do some for springboot, reactive webflux.

[@HariPrasad-yt4mn]

You are my tech guru

[@na-kh5lg]

It was amazing tutorial.you have explained one way but what you think about Kafka consumer.Did you cover any video for that?

[@balajimanoharan1716]

Good tutorial. How are you reading such things . Detailed info. while you are importing package do please show the import class once you are done with the coding for the class.

[@SuurTaalSadhana]

Amazing video!

[@cafeta]

Excellent tutorial, I fallowed but the only different is I use Kafka inside a Docker container.

[@rajneeraj8247]

@cafeta can you please help me with sample code, I m new to kafka and trying to use with docker. Kafka broker and zookeeper are running in docker and I am trying to produce and consume from other docker container.

[@kashif3720]

very nice tutorial. request one thing to add is kafka test

[@diegoramos27]

super good and straightforward, only question is why are you using BOOTSTRAP_SERVER_CONFIG at port 9092 if default port is 2181? thanks

[@mahaveerkolekar3862]

Very nice and usefull video

[@amithraju830]

Can make a video on rebalancing and how to handle the rebalance at the consumer end.

[@MohammadRasoolShaik]

The way you are explaining is really good, you are making things really easy... I have one question though, In the first example when we are sending a string message to Kafka, we didn't configure anything. Configurations like which server(BootStrapServers), Serialization info(Key and Value Serializers). How does it happen, KafkaTemple by default does some magic inside? What happens info I don't send Serializers info to Kafka broker while sending publishing a message?

[@varunpanji]

Thank you TechPrimers for this video, it was helpful for me to start with it. Also i would request to explain the concepts a bit slow than the present speed which is available in this video.

[@TechPrimers]

You can leverage the speed control in KZbin to slow down the video by 0.5x or 0.25x 🤓

[@pallavimisra9753]

Thanks for the great content

[@abhiroy82]

awesome Video !!! thanks dude!

[@monalisakushwaha2517]

I am facing an issue in running the KAFKA server. My ZOOKEEPER is UP. But when I am trying to UP the KAFKA server. Nothing is displayed on the screen. Even i have checked the PATH variable in USER/SYSTEM variables.

[@sfandi1946]

very good tutorial!

[@dimimurik3970]

Great! Thanx for your effort!

[@himanshudesai17]

What if Kafka server down and we are pushing data how to handle this situation.

[@kirityrapuru]

Great. Thanks for your work, as always.

[@vishnumurali522]

clearly understanding bro.But whats my question is in my case i want to send a file content in a topic and i have to consume it.Then what kind of value serializer have to use?

[@yuriihizun7183]

Good tutorial, maybe you will make a new video about consuming kafka message with spring boot.

[@TechPrimers]

Yes. uploaded the consumption part now. check out the latest video

[@yuriihizun7183]

Ooooouu so fast.

[@suryasimhadri]

Very good video and nice explanation in simple terms. I have one query, can we publish a flat file in kafka topic. If yes, please provide the details or example on it.

[@rajkishorekumar]

Thanks very much for this video.. Simple and effective

[@kommesreelatha473]

Hi sir, am unable to print the data in console while hitting the loacalhost url In the browser it is showing puliah successfully but not publishing anything in console. Please assist me with this. Thanks in advance.

[@ChaitanyaHegde2012]

Nice video. Can you please tell me why do we need to start consumer when we are creating a producer. ?

[@TechPrimers]

That’s just for demo

[@shivammishra009]

Sweet and simple , thanks for the video :)

[@anil2009]

Sir please mention order of videos . for own learners it's too hard to follow the playlist

[@akhileshguptaakhi]

Hello Sir, how do we decide when to use messaging or when to use RestTemplate ? Can you give me some practical use cases for messaging

[@swapnilmedhe6679]

Hi i got one error when i try to publish user object kafka.controller.User cannot be cast to java.lang.String I set the configuration exactly the same way as per video

[@chenyangwang7232]

I followed exactly the same thing as yours, but why I got an error saying "cannot convert value User to class org.apache.kafka.commo.serialization.StringSerializer specified in value.serializer"

[@rakesh8265]

Add this to application.properties file spring.kafka.producer.value-serializer= org.apache.kafka.common.serialization.StringSerializer spring.kafka.producer.key-serializer= org.apache.kafka.common.serialization.StringSerializer

[@Fred_Klingon]

Nice explanation! Now I need to find how to receive a published message (serialized as json) in another spring application. What do you think about having a common module between two or more applications, containing the message templates? That would be handy, but also dangerous if somebody changes them without checking who is receiving them.

[@TechPrimers]

There is a concept of Schema Registry where the message contract is stored. Confluent Kafka provides it.

[@Fred_Klingon]

@@TechPrimers thx

[@kaikeventura3893]

Very good! Thank you friend! 🇧🇷

[@sanki555]

The kafka Topic was created on port 2181 , then why was the Producer Config Set to 9082 ? In the Consumer Video also the Config Was having the same port 9082 . The producer Should be Posting on Port 2181 and the Consumer should be listening to port 9082 right?

[@NikhilJain08]

How to work with Kafka on WIndows? It keep on throwing file access denied error

[@rutulshah2007]

What is the meaning of key.serializer config ? Is it the topic name ? Since topic name is going to be in string we provide key.serializer = StringSerializer.class ?

[@selvarajb8791]

hey pls tell yeah in kafka console its not displaying the message but localhost :8081 showing the message Published

[@santhoshmittapelly3959]

Hi can we publish XML directly to Kafka topic. If yes can you provide me an example Iam in need of it. Thanks in advance ..

[@umarulfarooqa4313]

Very good.

[@GaneshGane-sl1fi]

from localhost im not able to publish my message what can I do?

[@SameeraSenarathna]

Thank you for simple and complete explanation. :-)

[@АлексейСидорин-э9ы]

Please, how calls last song in this video?

[@karan6551]

Awesome ❤️❤️❤️🔥❤️🔥❤️❤️❤️❤️

[@Shiva-zy7jq]

How did the Spring boot initially connected to Kafka without mentioning anything?

[@rajnishsasmal]

Very Good TOPIC , but my cases it was not working for JSON format. I am getting some ClassCastException..I changed to the following code, it started working... @Autowired private KafkaTemplate kafkaTemplate; private static final String TOPIC = "Kafka_Example"; User user = new User(name, "Mechanical", 10000L) ; ObjectWriter ow = new ObjectMapper().writer().withDefaultPrettyPrinter(); String json = null; try { json = ow.writeValueAsString(user); } catch (JsonProcessingException e) { // TODO Auto-generated catch block e.printStackTrace(); } kafkaTemplate.send(TOPIC, json);

[@GURUKHAN_OG]

Very helpful videos. Do we have something that can post a Object directly to the topic?

[@TechPrimers]

Nope buddy. Not directly

[@yhariprasadreddy2949]

while running in my local same code is giving the serializationException,unable to figure it out every thing is downloaded from GIT.pls help me to resolve

[@entertainment55]

how to change port number 9092???? 9092 is default, if I use other than 9092 then its not working

[@namankumar2220]

awesome video...

[@rrafaelpaz]

That explanation was really really good mate! Cheers for explaining step by step! All the best :)

[@karthikmk9]

Good explaination

[@124estera]

Very good. Thank you

[@SHIVAKUMAR-sg2pp]

Can we use json object mapper instead of serialization class?