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?
