Geeks, please accept the hero post of 2021 Microsoft x Intel hacking contest>>>
If you use this script (Kafka server stop. SH) to close the Kafka process in the Kafka/bin directory, you will find that
No Kafka server to stop
View the modification script: VI kafka-server-stop.sh and find that:
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
At this time, you can change the PIDs = $(PS ax | grep – I ‘Kafka \. Kafka’ | grep Java | grep – V grep | awk ‘{print $1}’) to
PIDS=$(jps -lm | grep -i ‘kafka.Kafka’ | awk ‘{print $1}’)
You can use it to close Kafka successfully
Sometimes when we write the Kafka close script, we call this script to close. If we don’t modify it, the script you write will not close Kafka
Similar Posts:
- No Kafka server to stop error handling of Kafka
- [Solved] Hadoop Error: ERROR: Cannot set priority of namenode process
- [Solved] Kafka memory overflow: FATAL Fatal error during KafkaServerStartable startup. Prepare to shutdown
- [Solved] kafka Startup Error: Error: VM option ‘UseG1GC’ is experimental and must be enabled via -XX:+UnlockExperimentalVMOptions.
- Kafka startup error & problem solving
- [Solved] The J2 file in ansible template calls the variable defined in VaR error.
- [Solved] ClassNotFoundException: org.apache.storm.kafka.spout.KafkaSpoutConfig
- [Solved] Kafka 0.8.2.2 Producer:java.net.ConnectException: Connection timed out: no further information
- Kafka Start Error: Corrupt index found & org.apache.kafka.common.protocol.types.SchemaException: Error reading field ‘version’: java.nio.BufferUnderflowException
- Kafka creates topic error: org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 1 larger than available brokers: 0.