Spring Kafka #4: Kafka consumer application with Spring boot (Step-By-Step)

preview_player
Показать описание
#Kafka #Springboot #Consumer

Spring Kafka #3: Build a Kafka consumer application with Spring boot

This is the 4th video of the Spring Kafka series.
In this, we are going to see how to build a Spring boot application that consumes messages from Kafka topic.

_____________________________________________________________________________________
You can find all the demo code here -

_____________________________________________________________________________________

0:00 Overview
0:15 Consumer Concepts
2:36 Steps in brief
3:25 Step 1: Verify Kafka setup
3:58 Step 2: Generate Spring project
4:52 Step 3: Create KakfaConsumerService
8:59 Step 4: Test with multiple consumers
____________________________________________________________________________________
Links to tools used in the video:

Рекомендации по теме
Комментарии
Автор

Thanks you very Much!The series is very helpful!

calebmbugua
Автор

this is helpful, but you also add one video on message idempotancy. How Kafka template implements message idempotency

kumarvikrant
Автор

Thanks for the explanation. Can you please cover more on Kafka? If you can create real time kafka project, it would be wonderful.

pranavmahajan
Автор

Thanks for the explanations, my question is in relation to the concurrency, how to know whats is better... have only one instance with concurrency=5 or have five instances with concurrency=1 to processes events in one topic with five partitions.

andrescorrea
Автор

Nice explanation. Thanks for this. Can u make a video for real time usage of kafka and how to build the project for real time usages

pratheeban
Автор

if the producer sent 10 messages and consumer died after reading 3 messages.
1) When the consumer comes back, does it read from where it left (starting from 4th message)?
2) Does broker remember the offset and decides from which message it has to send to the consumer after it is up?
3) Internally spring kakfa listener when connected to broker it constantly polls the partition for new messages ?
4) Do you know the frequency of listener polling the partition?

chrispure