Glad to know Kafka tutorial on Java helped you to learn. I would recommend please watch Kafka Spark Streaming Integration video for more knowledge in this technologies.
Thank you so much sir. Really appreciate your efforts. Thanks again for this wonderful video. Please make such more videos on Distributed Systems side.
Hello Bin, Thank you for all nice words, it means a lot for me to motivate myself and make many more videos. Glad to know this Kafka Tutorial for Java Video helped to learn. Noted down your nice suggestion. Keep Learning !!
I have installed the anaconda & jupyter by watching your video.but I am getting error in starting the zookeeper,sh is not recognised this is the error,how to resolve it.
Nice to know this Kafka Tutorial on Java video helped you. Using this below command, you can get all message from topic since beginning: ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning We can restrict number of old message also using below command: ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning --max-messages 100 Here test is the Topic name. How to implement same in Java code: Please add below configuration in Kafka properties set. properties.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG,offsetReset); Setting it to the earliest means Consumer will start reading messages from the beginning of that topic. Hope this is your answer, let me know if I can provide more details.
I'm facing an error while converting my java project to maven project called"Errors running builder 'Maven Project Builder' on project " can you help me please?
I see there were a lot command lines we have to prep to properly start Kafka with zookeeper. Is there any alternative way like config or just use Java to do that other than shell script.....
Thanks for explaining Kafka in java
Glad to know Kafka tutorial on Java helped you to learn. I would recommend please watch Kafka Spark Streaming Integration video for more knowledge in this technologies.
Good videos very helpful
Thanks for such detailed explanation
Thank you Sir
Thank you so much sir. Really appreciate your efforts. Thanks again for this wonderful video. Please make such more videos on Distributed Systems side.
Hello Bin, Thank you for all nice words, it means a lot for me to motivate myself and make many more videos. Glad to know this Kafka Tutorial for Java Video helped to learn. Noted down your nice suggestion. Keep Learning !!
Great work sir. 😊😊
superb ....
Thank you so much sir
Great explanation.. Thank you
I have installed the anaconda & jupyter by watching your video.but I am getting error in starting the zookeeper,sh is not recognised this is the error,how to resolve it.
Nice explanation sir, how can we read all the old message from the topic, kindly explain.
Nice to know this Kafka Tutorial on Java video helped you. Using this below command, you can get all message from topic since beginning:
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
We can restrict number of old message also using below command:
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning --max-messages 100
Here test is the Topic name.
How to implement same in Java code:
Please add below configuration in Kafka properties set.
properties.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG,offsetReset);
Setting it to the earliest means Consumer will start reading messages from the beginning of that topic.
Hope this is your answer, let me know if I can provide more details.
Thank you for you time sir
Thanks buddy
Sir in mentioned link Kafka sparks integration is dere not this code pls share
I'm facing an error while converting my java project to maven project called"Errors running builder 'Maven Project Builder' on project " can you help me please?
hi, is there any UI to see messages in kafa?like dashboard to see queue and topics?
Use Kafka Tool
I see there were a lot command lines we have to prep to properly start Kafka with zookeeper.
Is there any alternative way like config or just use Java to do that other than shell script.....
You can use docker.
Watch at 1.75x
We are looking for someone who can develop a JDBC producer connector for Kafka Connect. Let me know if anyone is interested
binod