Basant sir, can you also cover the Sync and Async send options with Future and Callbacks? Your way of explanation is very easy to grasp. Keep up the good work.
Hey man.... U r very knowledgeable.. Can u create some. Complex apps... Using spring boot.. Kafka.. Multi threading n all.... Like handling huge traffics of request... Apart from this simple crud apps
Thanks for this vide helps to understand. Can u make a video on real time application as u already done the project video on microservices. Where exactly we use this kafka in microservices. In the interview this question is asked again and again.
@@Javatechie understood but i would request if u include one video in spring cloud project , it helps to explain in the interview, when we are explaining the architecture in the interview. Hope u understand
Hi Basant nice video. Can you please tell Here 1st time while producing string object we didn't configure Kafka producer factory. that time how did spring application connected with Kafka broker.
Really very thankful to you ,this is the exact that i searched on you tube .I have one query here how I picked status of based on orderid in topic ,suppose i publish orderid 101,order id 102 so after payment service task done and publish ,now order need to status of orderid 101 so how it filter .
Hi besant, nice video but just want to know one thing like what is avro role in Kafka can you please use avro serialization/de-serialization in next tutorial. Thanks
where are we configuring the kafka server details for spring boot, how the spring boot application knows the details of the kafka server. if i want to connect with the kafka server that is not running on my local, where should i configure them?
@@Javatechie Now I am able to see video content.Thanks for your support Sir. We are preferring your videos only. Upload gradle related projects also. Wish u Happy and safe Diwali Sir 🎉🎉 🎉
Hi Besant, delayed in my response. The actual requirement is by using Spring Batch, read data from DB and prepare JSON object to it. And then write the data into another DB. This implementation needs to be in a Scheduler approach. Could you please suggest the approach.
Hi sir, I tried kafka producer code, but I don't see my msg getting printed on consumer console... do I need to write consumer code also to get them printed, my code has no exception where as isdone method returns me false does that mean my msg is not produced ?
Hi Basant , I really like all your video. Is there a UI dashboard for apache kafka like we have one for rabbit MQ ? if there is then how do i access it ?
Hi when i am using thiszookeeper-server-start.bat C:\javajars\kafka\kafka-1.0.1-src\kafka-1.0.1-src\kafka-1.0.1-src\config\zookeeper.properties command getting issue like class path is empty please build the project first. plse help on this issue
Hi Sir, Can you tell me about this.On trying to up the zookeeper server, i am getting this message. C:\Users\ADMIN\Desktop\kafka-1.0.1-src\bin\windows>zookeeper-server-start.bat C:\Users\ADMIN\Desktop\kafka-1.0.1-src\config\zookeeper.properties Classpath is empty. Please build the project first e.g. by running 'gradlew jarAll'
@@Javatechie i downloaded binary version now..Now I am to start the zookeeper server. But I am not able to start the Kafka server. When I am trying to start it, I am not getting any output. C:\Users\ADMIN\Desktop\kafka\bin\windows>kafka-server-start.bat C:\Users\ADMIN\Desktop\kafka\config\server.properties C:\Users\ADMIN\Desktop\kafka\bin\windows>
Kafka will loose messages if they are not delivered as compared to JMS JMS has redeliver functionality too If there are more than 1 topics how will you configure the same ?
No add one sopln statement to check when Kafka template bean is getting initialised . Usually while starting application everything will be pre configured
Hiii, im getting following error. This application has no explicit mapping for /error, so you are seeing this as a fallback. Tue Jul 31 22:04:17 IST 2018 There was an unexpected error (type=Internal Server Error, status=500). Can't serialize data [com.anusoft.spring.kafka.api.User@2b80adb0] for topic [test-topic]
GEtting below error while running zookeeper- G:\Softwares\kafka-2.8.0\bin\windows>zookeeper-server-start.bat G:\Softwares\kafka-2.8.0\config\zookeeper.properties Classpath is empty. Please build the project first e.g. by running 'gradlew jarAll'
if someone facing issues in starting his kafka server then please downgrade your kafka. i face the same issue and downgrade my version of kafka and the problem is resolved.
I am getting an error when I run - >kafka-console-consumer.bat --bootstrap-server localhost:9091 --topic infy error - java.lang.OutOfMemoryError: Java heap space. [Consumer clientId=console-consumer, groupId=console-consumer-53782] Error connecting to node DESKTOP-G555I86.lan:9092 (id: 0 rack: null) (org.apache.kafka.clients.NetworkClient) java.net.UnknownHostException: DESKTOP-G555I86.lan
D:\kafka\kafka_2.13-3.1.0\bin\windows>zookeeper-server-start.bat D:\kafka\kafka_2.13-3.1.0\config\server.properties [2023-01-15 19:30:27,993] INFO Reading configuration from: D:\kafka\kafka_2.13-3.1.0\config\server.properties (org.apache.zookeeper.server.quorum.QuorumPeerConfig) [2023-01-15 19:30:27,998] ERROR Invalid config, exiting abnormally (org.apache.zookeeper.server.quorum.QuorumPeerMain) org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException: Error processing D:\kafka\kafka_2.13-3.1.0\config\server.properties at org.apache.zookeeper.server.quorum.QuorumPeerConfig.parse(QuorumPeerConfig.java:198) at org.apache.zookeeper.server.quorum.QuorumPeerMain.initializeAndRun(QuorumPeerMain.java:124) at org.apache.zookeeper.server.quorum.QuorumPeerMain.main(QuorumPeerMain.java:90) Caused by: java.lang.IllegalArgumentException: dataDir is not set at org.apache.zookeeper.server.quorum.QuorumPeerConfig.parseProperties(QuorumPeerConfig.java:444) at org.apache.zookeeper.server.quorum.QuorumPeerConfig.parse(QuorumPeerConfig.java:194) ... 2 more Invalid config, exiting abnormally [2023-01-15 19:30:28,004] INFO ZooKeeper audit is disabled. (org.apache.zookeeper.audit.ZKAuditProvider) [2023-01-15 19:30:28,006] ERROR Exiting JVM with code 2 (org.apache.zookeeper.util.ServiceUtils)