Have you seen https://examples.javacodegeeks.com/java-basics/exceptions/java-lang-illegalmonitorstateexception-how-to-solve-illegalmonitorstateexception/ ?
You didn't include the whole code w.r.t. shadowKafkaProducer If you need more help, please consider including more of your code. Cheers On Wed, Dec 27, 2017 at 5:32 AM, Debraj Manna <subharaj.ma...@gmail.com> wrote: > Cross-posting from stackoverflow > <https://stackoverflow.com/questions/47992916/kafka-client-throwing- > illegalstateexception-on-calling-wait> > > Kafka Client 0.10.0.0 is throwing the below IllegalStateException whenever > I am calling wait() > > ERROR [2017-12-27 09:55:48] c.v.g.u.UploadHandler:[?:?:?] - [dw-199 - > POST /collectortosaasservlet] - InterruptedException in producer.wait. > for cloning > java.lang.IllegalMonitorStateException: null > at java.lang.Object.wait(Native Method) > at java.lang.Object.wait(Object.java:502) > at com.van.grid.uploadHandler.UploadHandler.stopCloning( > UploadHandler.java:481) > > The relevant code looks like below > > shadowKafkaProducer = new > KafkaProducer<>(kafkaShadowProdConf);...public void stopCloning() { > logger.info("Going to stop cloning"); > if(shadowKafkaProducer != null) { > try { > shadowKafkaProducer.wait(); > } catch (Exception e) { > logger.error("InterruptedException in producer.wait. > for cloning", e); > } > shadowKafkaProducer.close(); > shadowKafkaProducer = null; > } > logger.info("Stopped cloning"); > } > > shadowKafkaProducer.wait() is line number 481 in the above stacktrace. > > Can someone let me know why is this exception thrown & can I ignore this? >
