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.
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.
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..
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
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?
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
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
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.
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?
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.
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.
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()?
@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.
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 ?
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?
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.
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.
Kudos for the effort man. I have a question. Why are you using spring boot 1.5? A lot of things have changed in spring boot 2.0 and even within various versions of 2.0. It would be really great if you made your videos with the latest release. That's good for viewers as well, as they don't have to go and find why something doesn't work with versions that they are using.
Yes Ashish. Still enterprise firms haven't moved to Spring Boot 2.0 I will be starting Spring Boot 2.0 in sometime once I cover the major libraries in Spring.
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
