Spring Boot + Apache Kafka Tutorial - #9 - Create Kafka Consumer

Welcome to Spring Boot + Apache Kafka Tutorial series.
In this lecture, we will create Kafka Consumer and will have an end-to-end demo.
#springboot #kafka #javaguides
Complete playlist at • Spring Boot + Apache K...
GitHub link: github.com/Ram...

[@JavaGuides]

Complete playlist at kzbin.info/aero/PLGRDMO4rOGcNLwoack4ZiTyewUcF6y6BU

[@lllAlxzlll]

Hi I'm from Brazil, thanks for this course

[@Andrzej3935]

Thanks, teacher

[@s.sibasankarreddy4539]

After running the application , I'm not geeting all the messages , what all initially we sent through using restAPI .And after application runned if im sending any message to that topic that only im getting in logger , Can you please help

[@shubhamrajput9363]

thank you sir

[@Das.Kleine.Krokodil]

Thanks!

[@terencechia9986]

For every message I'm sending, my consumer seems to be reading two of the same message. ie duplicate message is being read. Anyone know why this might be?

[@ramosespann6496]

Hi for.this course do You gonna intégrate JWT ?

[@azadsingh2143]

Why are you making KafkaConsumer class as a bean?

[@JavaGuides]

We inject spring bean in another class and use it's methods.

[@muthuramasundarasivam4000]

Got this error

[@muthuramasundarasivam4000]

(Re-)joining group 2024-04-28T12:38:28.520+05:30 INFO 10908 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-myGroup2-1, groupId=myGroup2] Group coordinator LAPTOP-3DVH5AED:9092 (id: 2147483647 rack: null) is unavailable or invalid due to cause: error response NOT_COORDINATOR. isDisconnected: false. Rediscovery will be attempted. 2024-04-28T12:38:28.520+05:30 INFO 10908 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-myGroup2-1, groupId=myGroup2] Requesting disconnect from last known coordinator LAPTOP-3DVH5AED:9092 (id: 2147483647 rack: null) 2024-04-28T12:38:28.521+05:30 INFO 10908 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-myGroup2-1, groupId=myGroup2] JoinGroup failed: This is not the correct coordinator. Marking coordinator unknown. Sent generation was Generation{generationId=-1, memberId='', protocol='null'} 2024-04-28T12:38:28.521+05:30 INFO 10908 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-myGroup2-1, groupId=myGroup2] Client requested disconnect from node 2147483647 2024-04-28T12:38:28.522+05:30 INFO 10908 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-myGroup2-1, groupId=myGroup2] Discovered group coordinator LAPTOP-3DVH5AED:9092 (id: 2147483647 rack: null) 2024-04-28T12:38:28.522+05:30 INFO 10908 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-myGroup2-1, groupId=myGroup2] Group coordinator LAPTOP-3DVH5AED:9092 (id: 2147483647 rack: null) is unavailable or invalid due to cause: coordinator unavailable. isDisconnected: false. Rediscovery will be attempted. 2024-04-28T12:38:28.522+05:30 INFO 10908 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-myGroup2-1, groupId=myGroup2] Requesting disconnect from last known coordinator LAPTOP-3DVH5AED:9092 (id: 2147483647 rack: null) 2024-04-28T12:38:28.628+05:30 INFO 10908 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-myGroup2-1, groupId=myGroup2] Discovered group coordinator LAPTOP-3DVH5AED:9092 (id: 2147483647 rack: null) 2024-04-28T12:38:28.629+05:30 INFO 10908 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-myGroup2-1, groupId=myGroup2] Request joining group due to: rebalance failed due to 'This is not the correct coordinator.' (NotCoordinatorException)

[@Lupo150]

kaPka...

[@JavaGuides]

Captions are not edited Sir.

[@nstha8848]

@@JavaGuides 🤣🤣🤣😆😆😆

[@saurabhdwivedi6927]

[ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : Consumer exception