confluent
confluent copied to clipboard
Kafka process is not correctly identified in init.d script
In the /etc/init.d/kafka script, the findPid() function uses java class to identify the kafka process:
CLASS=kafka.Kafka
findPid() {
FOUND_PID=`pgrep -u $USER -f $CLASS`
}
However, the java class listed in the command line for the kafka process is:
io.confluent.support.metrics.SupportedKafka
This prevents service commands for kafka from functioning properly. Modifying the class name in the init.d script resolves this issue.
Issue identified on confluent version 4.1.1. Have not tested on other versions.