Spring Boot + Apache Kafka Tutorial - #13 - Create Kafka Consumer to Consume JSON Message

Рет қаралды 32,345

Java Guides

Күн бұрын

Пікірлер: 29

@Das.Kleine.Krokodil 2 жыл бұрын

best series on kafka!

@vamshikrishnapatha9857 2 жыл бұрын

best series on kafka

@m0naco608 6 ай бұрын

This is the best videos about kafka, thank you so much!

@techneis Жыл бұрын

Hi Ramesh, thanks for sharing such a nice series of Kafka tutorial. I am also trying hands-on with these videos. However, I am facing issues while consuming the published events. I have pushed my code to the git, and have added you as collaborator. Kindly have a look, and suggest, If I overlooked something.

@naeemrmaity5760 Жыл бұрын

Am facing also problem with the consumer did u find a solution?

@abulsyed4851 Жыл бұрын

How comes Kafka keeps the message in the broker even after it's been consumed? Looks like by default acts as a event store. How can I make the broker remove the message once it's been consumed, similar to RabbitMQ?

@jim2062 6 ай бұрын

I think you have to add timestamp

@adnane222 Жыл бұрын

Very good tutorial. I had an error : cannot construct instance of User (no creators like default constructor exist) The mistake i did was that i had created a constructor for the User class ( with id, firstName & lastName ) If you have the same error, just create an empty constructor and everything should work fine public User() { }

@Nikhil-mu9ol 2 жыл бұрын

Hi,how many videos will be released for kafka

@javatechnology4481 2 жыл бұрын

Great video

@Modi_In_Canada Жыл бұрын

Hi Ramesh, Since we have consumed all the messages using JSON consumer from intellij, why all those messages again came when you consume from cmd. Ideally messages should be removed as soon as consumer consume it.

@riteshhraj8033 2 жыл бұрын

Sir,i could not undestand the use of that key serializer and key deserialiser and why it is set as string and not json..what is the key for the message??please explain

@JavaGuides 2 жыл бұрын

kafka by default manages the key for a message, we can focus on message content (value). Key is in string format. Key should be always in string format unless you explicitly configure it.

@riteshhraj8033 2 жыл бұрын

@@JavaGuides Thanks for the reply..i got it..it is very tough to create a content of technology that is quite complicated..i apppreciate that :)..keep creating these kinds of videos.

@devyaniwagh1565 2 жыл бұрын

My program keeps running...can u give the solution @javaguides

@riteshhraj8033 2 жыл бұрын

@@devyaniwagh1565 hi devyani kindly tag java guides properly..otherwise he will not be able to see your message..

@devyaniwagh1565 2 жыл бұрын

@@JavaGuides My program keeps running...can u give the solution

@manindersingh6371 Жыл бұрын

Hi Bro, Thanks for making this wonderful series. I am following your code to consume the message however I am getting Cannot convert from [java.lang.String] to [com.optum.labs.kafka.model.User] for GenericMessage [payload={"id":1,"firstName":"Robin2","lastName":"Bajaj2"}. Followed every steps as described by you. Seems like producer is sending the String to consumer but my producer is sending user model object. public void sendMessage(User data){ Message message= MessageBuilder .withPayload(data) .setHeader(KafkaHeaders.TOPIC,topicName) .build(); kafkaTemplate.send(message); log.info("***** Json Message sent ***** :{}",data); }

@anxiousdev555 Жыл бұрын

I had to create KafkaConsumerConfig to get it to work, which created two beans ConsumerFactory and ConcurrentKafkaListenerContainerFactory

@kalpeshpatil811 Жыл бұрын

I also had the same issue, because of the wrong import of the user class. Check if you have imported user class of payload package only.