From 4f705bdba48f73dc4df4538056a466869f51462d Mon Sep 17 00:00:00 2001 From: Eric Shen Date: Fri, 26 Nov 2021 09:41:30 +0800 Subject: [PATCH] feat(cli): support autorecovery service in pulsar cli Signed-off-by: Eric Shen --- bin/pulsar | 4 ++++ bin/pulsar-daemon | 4 ++++ 2 files changed, 8 insertions(+) diff --git a/bin/pulsar b/bin/pulsar index 3f009caae78a6..9fcb4b358e3fd 100755 --- a/bin/pulsar +++ b/bin/pulsar @@ -141,6 +141,7 @@ where command is one of: sql-worker Run a sql worker server sql Run sql CLI standalone Run a broker server with local bookies and local zookeeper + autorecovery Run an autorecovery service initialize-cluster-metadata One-time metadata initialization delete-cluster-metadata Delete a cluster's metadata @@ -347,6 +348,9 @@ elif [ $COMMAND == "functions-worker" ]; then elif [ $COMMAND == "standalone" ]; then PULSAR_LOG_FILE=${PULSAR_LOG_FILE:-"pulsar-standalone.log"} exec $JAVA $LOG4J2_SHUTDOWN_HOOK_DISABLED $OPTS ${ZK_OPTS} -Dpulsar.log.file=$PULSAR_LOG_FILE org.apache.pulsar.PulsarStandaloneStarter --config $PULSAR_STANDALONE_CONF $@ +elif [ ${COMMAND} == "autorecovery" ]; then + PULSAR_LOG_FILE=${PULSAR_LOG_FILE:-"pulsar-autorecovery.log"} + exec $JAVA $OPTS -Dpulsar.log.file=$PULSAR_LOG_FILE org.apache.bookkeeper.replication.AutoRecoveryMain --conf $PULSAR_BOOKKEEPER_CONF $@ elif [ $COMMAND == "initialize-cluster-metadata" ]; then exec $JAVA $OPTS org.apache.pulsar.PulsarClusterMetadataSetup $@ elif [ $COMMAND == "delete-cluster-metadata" ]; then diff --git a/bin/pulsar-daemon b/bin/pulsar-daemon index 824bb98915071..05ee12a9385a6 100755 --- a/bin/pulsar-daemon +++ b/bin/pulsar-daemon @@ -30,6 +30,7 @@ where command is one of: functions-worker Run a functions worker server standalone Run a standalone Pulsar service proxy Run a Proxy Pulsar service + autorecovery Run an autorecovery service where argument is one of: -force (accepted only with stop command): Decides whether to stop the server forcefully if not stopped by normal shutdown @@ -102,6 +103,9 @@ case $command in (proxy) echo "doing $startStop $command ..." ;; + (autorecovery) + echo "doing $startStop $command ..." + ;; (*) echo "Error: unknown service name $command" usage