Spring Boot + Apache Kafka Tutorial - #8 - Create REST API to Send Message

[@JavaGuides]

Complete playlist at kzbin.info/aero/PLGRDMO4rOGcNLwoack4ZiTyewUcF6y6BU

[@sambhav07]

Hi, I think a small change is required here. kafkaTemplate.send is an aynchronous call so /publish endpoint will return ok response even before kafka message gets produced/published to the topic. Also in case of failure also endpoint will return ok. Future object should be handled and returned as response of endpoint.

[@hendrapurwanto23]

thank you master for sharing your knowledge, success always master..

[@bugrae9341]

This serie is perfect. Thanks a lot for your efforts. Sometimes I hear your baby voice and I hope best and healty life for your baby :)

[@JavaGuides]

Thanks a lot. Your comment made my day.

[@bollapraveen9270]

Hi sir,your teaching is phenomenal....if you don't mind can you post the videos on springboot microservces(1demo project)..

[@ravindrabangalore2990]

nice presentation , thank you

[@aibardulatov]

I have error when hit url: Whitelabel Error Page This application has no explicit mapping for /error, so you are seeing this as a fallback. Tue Apr 09 12:49:00 QYZT 2024 There was an unexpected error (type=Internal Server Error, status=500).

[@Andrzej3935]

Thank you very much

[@Vithal_Nivargi]

Amazing series ❤️ thanks

[@sleeksilk497]

Why are we using Constructor-based injection?

[@raj_kundalia]

Shouldn't the publish call semantically be POST? Note: Oh got it, you kept it for simplicity to hit the endpoint from browser.

[@patronBln28]

Same thought here, its worth to mention it, so that beginners are not confused. You would always use a POST request, if you want to send data.

[@shubhampatel5804]

Superb!

[@ghostnull6407]

i am getting below error when i try to read messages from kafka Cmd: .\bin\windows\kafka-console-consumer.bat --topic test --from-beginning --bootstrap-server localhost:9092 The syntax of the command is incorrect.

[@Das.Kleine.Krokodil]

Very good!

[@sowjanyapuppala5299]

I have tried this tutorial step by step. Now the Apache Kafka version is moved to a higher version 3.7.0. From spring boot application, I am able to create javaguides topic. But When I try to send message to this topic from rest endpoint or console-consumer, I get erorr "Kafka Error org.apache.kafka.common.errors.NotLeaderOrFollowerException NOT_LEADER_OR_FOLLOWER". Kindly let me know how to debug what is missing in broker/topic/partition config. Is there any blog / message gropu / stackoverflow thread where I can see solutions to the problmes faced

[@deepjay9472]

Hello sir, the webpage is showing whitelabel error ... How to fix it

[@gaurirahul2145]

Hello Sir I am using Eclipse IDE , application running smoothly but when I am running your API its showing me error Whitelabel Error Page This application has no explicit mapping for /error, so you are seeing this as a fallback.

[@deepjay9472]

Same here, did you find solution

[@scitechplusexplorer2484]

start zookeeper, then broker, then fire msg. ensure url is right syntax.

[@naglakshmimekala6033]

me also facing same Problem, did you find any solution

[@bhanuPrakash-yo5wd]

did you got solution? facing same issue , got struck@@naglakshmimekala6033

[@nitingakhar7751]

Some of the things to check, make sure URL is correct : localhost:8080/api/v1/kafka/publish?message=hello world, Also, did you check with some tool like postman?

[@vjs1730]

Does this SpringBootApplication runs the zookeeper at the background?

[@newtanagmukhopadhyay4716]

yes.

[@AnuragAnkit-t8k]

I am getting this error :- when I run my application: - org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has exited. Call: fetchMetadata when I tried to hit url : - org.apache.kafka.common.errors.TimeoutException: Topic javaguides not present in metadata after 60000 ms. Any Solution for that?

[@azadsingh2143]

Hi Sir, Can you please explain, what is getting injected in KafkaTemplate? As per my understanding, KafkaTemplate requires KafkaFactory, and KafkaFactory requires properties. How KafkaTemplate is getting properties, directly from Application.properties?

[@JavaGuides]

Spring boot auto configuration will configure kafka template automatically. We don't have do it manually. I have explained this while configuring kafka in spring boot application

[@azadsingh2143]

@@JavaGuides thank you, got it.

[@I_am_nus]

Kafka producer is producing duplicate message, how to deal with that?

[@patronBln28]

Consume the messages double time 😁 or just google and you will find something on stackoverflow in most cases.

[@nareshyadav5716]

Sir can u please send me application.property file

[@Shubham_Kumar_Sahu]

spring.kafka.consumer.bootstrap-servers:localhost:9092 spring.kafka.consumer.group.id:myGroup spring.kafka.consumer.auto-offset-reset: earliest spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer spring.kafka.producer.bootstrap-servers:localhost:9092 spring.kafka.producer.key-serializer:org.apache.kafka.common.serialization.StringSerializer spring.kafka.producer.value-serializer:org.apache.kafka.common.serialization.StringSerializer