It's again a great work. Just one question, how to validate the consumer has received the data. I can see in the log but need to call the consumer method for actual assertion.
Consumer method type is void so just change its return type and validate it otherwise store events in some db and validate again it depends on the use case how you want to play with events
by using auto-offset-reset: latest my test failed because listener did not pick up the message. I have to use earlist for it. could you tell me why I have this issue?
Great content as always. I have a question pls: can Kafka be used to schedule recurring events let's say, hourly, daily, weekly, or even monthly just like the way these auto monthly subscription work. I've heard about cron jobs, but can Kafka be used for the same purpose?
Very informative video on "Kafka Integration Testing". Appreciate your efforts, Basant. God bless you. 🙂
Very good info sir ..thanks lot .
Thank you very much... when ever I try new subject. I will come to your video only. 👌
I am waiting since long time. Thank you sir
Great tutorials so far... If you can also cover topics like Avro serialization/deserialization and Schema Registry, That would be great.
I will do that buddy
bro you are the best. I learned many things with youand all worked perfectly
Nice video, thanks for valuable information ❤️
Awesome ❤😊
Thank you so much sir 🙏
It's again a great work. Just one question, how to validate the consumer has received the data. I can see in the log but need to call the consumer method for actual assertion.
Consumer method type is void so just change its return type and validate it otherwise store events in some db and validate again it depends on the use case how you want to play with events
Long awaited....❤
Thank you so much 😊 but I am wondering that How did you watch this video buddy? I haven't made it public yet ?
@@Javatechie just saw the notification and it made me happy .Reserved it for my weekend ......not yet seen .
Nice concept
by using auto-offset-reset: latest my test failed because listener did not pick up the message. I have to use earlist for it. could you tell me why I have this issue?
i have an error running the test : /tmp/testcontainers_start.sh: line 3: /etc/kafka/docker/run: No such file or directory
Great content as always. I have a question pls: can Kafka be used to schedule recurring events let's say, hourly, daily, weekly, or even monthly just like the way these auto monthly subscription work.
I've heard about cron jobs, but can Kafka be used for the same purpose?
Yes but you must need to use the cron job to schedule this automation task using Kafka
Will it work if system don’t have docker installed?
No it won’t
Thank you.
💯👍