Skip to content

Commit

Permalink
feat(automq-kafka-admin.sh): Optimize command line standard output me…
Browse files Browse the repository at this point in the history
…ssages (#1178)
  • Loading branch information
amos201600 committed Apr 26, 2024
1 parent a592523 commit bd1dc99
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -146,7 +146,7 @@ public static ArgumentParser addArguments(Subparser parser) {
}

public String run() {
System.out.println("############ Ping s3 ####################");
System.out.println("############ Ping s3 ########################");
System.out.println();

// precheck
Expand All @@ -160,13 +160,13 @@ public String run() {
S3Utils.checkS3Access(context);

String s3Url = buildS3Url();
System.out.println("############ string of s3url ############");
System.out.println("############ String of s3url ################");
System.out.println();
System.out.println("Your s3url is: \n");
System.out.println(s3Url);
System.out.println("\n");

System.out.println("############ s3url usage ################");
System.out.println("############ Usage of s3url ################");
System.out.println("To start AutoMQ, generate the start commandline using s3url.");
//tips: Not add whitespace after \\
System.out.println(String.format("bin/automq-kafka-admin.sh %s \\%n"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -105,11 +105,10 @@ public void run() throws IOException {
ServerGroupConfig controllerGroupConfig = ConfigParserUtil.genControllerConfig(parameter.controllerList, parameter.controllerOnlyMode);
ServerGroupConfig brokerGroupConfig = ConfigParserUtil.genBrokerConfig(parameter.brokerList, controllerGroupConfig);

System.out.println("############## START CMD LIST ###########");
System.out.println("You can copy the command to where your AutoMQ tgz located and run following command to start a AutoMQ kafka server: \n");
System.out.println("Ensure that your compute instance already have JDK17 installed. Execute 'java -version' to check.");
System.out.println("############ Start Commandline ##############");
System.out.println("To start an AutoMQ Kafka server, please navigate to the directory where your AutoMQ tgz file is located and run the following command. \n");
System.out.println("Before running the command, make sure that JDK17 is installed on your host. You can verify the Java version by executing 'java -version'.");
System.out.println();
System.out.println("------------------------ COPY ME ------------------");

for (int controllerNodeId : controllerGroupConfig.getNodeIdList()) {
if (parameter.controllerOnlyMode) {
Expand Down

0 comments on commit bd1dc99

Please sign in to comment.