Sometimes when attempting to shut down a Streaming application using '
epadmin stop node', the command hangs and does not complete. This is a known issue relating to the Kafka adapters. Thread dumps taken from the application reveal there is a deadlock:
Found one Java-level deadlock:
=============================
"runtime [tid=6904540]":
waiting to lock monitor 0x000002127d626e00 (object 0x00000004141075d0, a com.streambase.sb.adapter.kafka.KafkaSubscription),
which is held by "OperatorThread(default.Read.KafkaConsumer)"
"OperatorThread(default.Read.KafkaConsumer)":
waiting for ownable synchronizer 0x00000004142b7228, (a java.util.concurrent.locks.ReentrantLock$NonfairSync),
which is held by "runtime [tid=6904540]"