如果在kafka/bin目錄下用這個腳本(kafka-server-stop.sh)關閉kafka進程會發現
報錯說:No kafka server to stop
查看改腳本:vi kafka-server-stop.sh 發現:
1 #!/bin/sh 2 # Licensed to the Apache Software Foundation (ASF) under one or more 3 # contributor license agreements. See the NOTICE file distributed with 4 # this work for additional information regarding copyright ownership. 5 # The ASF licenses this file to You under the Apache License, Version 2.0 6 # (the "License"); you may not use this file except in compliance with 7 # the License. You may obtain a copy of the License at 8 # 9 # http://www.apache.org/licenses/LICENSE-2.0 10 # 11 # Unless required by applicable law or agreed to in writing, software 12 # distributed under the License is distributed on an "AS IS" BASIS, 13 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 14 # See the License for the specific language governing permissions and 15 # limitations under the License. 16 PIDS=$(ps ax | grep -i 'kafka\.Kafka' | grep java | grep -v grep | awk '{print $1}') 17 #PIDS=$(jps -lm | grep -i 'kafka.Kafka' | awk '{print $1}') 18 19 if [ -z "$PIDS" ]; then 20 echo "No kafka server to stop" 21 exit 1 22 else 23 kill -s TERM $PIDS 24 fi
此時可以把PIDS=$(ps ax | grep -i 'kafka\.Kafka' | grep java | grep -v grep | awk '{print $1}')這行代碼修改為
PIDS=$(jps -lm | grep -i 'kafka.Kafka' | awk '{print $1}')
即可成功使用它關閉kafka啦!
我們有時候寫kafka關閉腳本的時候也會調用此腳本關閉,如果不修改,也會導致你寫的腳本關閉不了kafka!!