Open jpwmeta opened 6 years ago
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.
In the /etc/init.d/kafka script, the findPid() function uses java class to identify the kafka process:
However, the java class listed in the command line for the kafka process is:
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.