Add maven-publish plugin (#392)

app/build.gradle

@@ -2,6 +2,7 @@ plugins {
     // Apply the application plugin to add support for building a CLI application in Java.
     id 'application'
     id 'com.github.johnrengelman.shadow' version '7.1.0'
+    id 'maven-publish'
 }
 
 repositories {
@@ -66,3 +67,21 @@ tasks.named('test') {
     minHeapSize = "512m"
     maxHeapSize = "2048m"
 }
+
+publishing {
+    publications {
+        mavenJava(MavenPublication) {
+            groupId = 'org.astraea'
+            from components.java
+        }
+    }
+    repositories {
+        maven {
+            url = "https://maven.pkg.github.com/skiptests/astraea"
+            credentials {
+                username = System.getenv("GITHUB_ACTOR")
+                password = System.getenv("GITHUB_TOKEN")
+            }
+        }
+    }
+}

app/src/main/java/org/astraea/App.java → app/src/main/java/org/astraea/app/App.java

@@ -1,18 +1,18 @@
-package org.astraea;
+package org.astraea.app;
 
 import com.beust.jcommander.ParameterException;
 import java.lang.reflect.InvocationTargetException;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Map;
-import org.astraea.admin.ReplicaCollie;
-import org.astraea.admin.ReplicaSyncingMonitor;
-import org.astraea.admin.TopicExplorer;
-import org.astraea.automation.Automation;
-import org.astraea.cost.topic.PartitionScore;
-import org.astraea.metrics.MetricExplorer;
-import org.astraea.performance.Performance;
-import org.astraea.web.WebService;
+import org.astraea.app.admin.ReplicaCollie;
+import org.astraea.app.admin.ReplicaSyncingMonitor;
+import org.astraea.app.admin.TopicExplorer;
+import org.astraea.app.automation.Automation;
+import org.astraea.app.cost.topic.PartitionScore;
+import org.astraea.app.metrics.MetricExplorer;
+import org.astraea.app.performance.Performance;
+import org.astraea.app.web.WebService;
 
 public class App {
   private static final Map<String, Class<?>> MAIN_CLASSES =

app/src/main/java/org/astraea/admin/Admin.java → app/src/main/java/org/astraea/app/admin/Admin.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import java.io.Closeable;
 import java.util.Collection;

app/src/main/java/org/astraea/admin/Builder.java → app/src/main/java/org/astraea/app/admin/Builder.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import java.util.ArrayList;
 import java.util.Collection;
@@ -33,7 +33,7 @@
 import org.apache.kafka.common.quota.ClientQuotaEntity;
 import org.apache.kafka.common.quota.ClientQuotaFilter;
 import org.apache.kafka.common.quota.ClientQuotaFilterComponent;
-import org.astraea.common.Utils;
+import org.astraea.app.common.Utils;
 
 public class Builder {
 

app/src/main/java/org/astraea/admin/Compression.java → app/src/main/java/org/astraea/app/admin/Compression.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import java.util.Locale;
 

app/src/main/java/org/astraea/admin/Config.java → app/src/main/java/org/astraea/app/admin/Config.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import java.util.Collection;
 import java.util.Map;

app/src/main/java/org/astraea/admin/ConsumerGroup.java → app/src/main/java/org/astraea/app/admin/ConsumerGroup.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import java.util.List;
 import java.util.Map;

app/src/main/java/org/astraea/admin/Member.java → app/src/main/java/org/astraea/app/admin/Member.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import java.util.Objects;
 import java.util.Optional;

app/src/main/java/org/astraea/admin/Offset.java → app/src/main/java/org/astraea/app/admin/Offset.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 public final class Offset {
   private final long earliest;

app/src/main/java/org/astraea/admin/ProducerState.java → app/src/main/java/org/astraea/app/admin/ProducerState.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import java.util.Objects;
 

app/src/main/java/org/astraea/admin/Quota.java → app/src/main/java/org/astraea/app/admin/Quota.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import java.util.Arrays;
 import java.util.Collection;

app/src/main/java/org/astraea/admin/QuotaCreator.java → app/src/main/java/org/astraea/app/admin/QuotaCreator.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 /**
  * Kafka quota APIs are too incomprehensible to use, so we re-design quota APIs to builder pattern.

app/src/main/java/org/astraea/admin/Replica.java → app/src/main/java/org/astraea/app/admin/Replica.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import java.util.Objects;
 

app/src/main/java/org/astraea/admin/ReplicaCollie.java → app/src/main/java/org/astraea/app/admin/ReplicaCollie.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import com.beust.jcommander.Parameter;
 import java.io.IOException;
@@ -10,9 +10,9 @@
 import java.util.Set;
 import java.util.TreeMap;
 import java.util.stream.Collectors;
-import org.astraea.argument.BooleanField;
-import org.astraea.argument.IntegerSetField;
-import org.astraea.argument.StringSetField;
+import org.astraea.app.argument.BooleanField;
+import org.astraea.app.argument.IntegerSetField;
+import org.astraea.app.argument.StringSetField;
 
 public class ReplicaCollie {
   static final String UNKNOWN = "unknown";
@@ -287,7 +287,7 @@ static Map<TopicPartition, MigratorInfo> execute(Admin admin, Argument args) {
   }
 
   public static void main(String[] args) throws IOException {
-    var argument = org.astraea.argument.Argument.parse(new Argument(), args);
+    var argument = org.astraea.app.argument.Argument.parse(new Argument(), args);
 
     try (var admin = Admin.of(argument.bootstrapServers())) {
       execute(admin, argument)
@@ -309,7 +309,7 @@ public static void main(String[] args) throws IOException {
     }
   }
 
-  static class Argument extends org.astraea.argument.Argument {
+  static class Argument extends org.astraea.app.argument.Argument {
     @Parameter(
         names = {"--topics"},
         description = "Those topics' partitions will get reassigned. Empty means all topics",

app/src/main/java/org/astraea/admin/ReplicaMigrator.java → app/src/main/java/org/astraea/app/admin/ReplicaMigrator.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import java.util.List;
 import java.util.Map;

app/src/main/java/org/astraea/admin/ReplicaSyncingMonitor.java → app/src/main/java/org/astraea/app/admin/ReplicaSyncingMonitor.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import com.beust.jcommander.Parameter;
 import java.time.Duration;
@@ -16,17 +16,17 @@
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 import org.apache.kafka.common.TopicPartitionReplica;
-import org.astraea.argument.DurationField;
-import org.astraea.argument.NonEmptyStringField;
-import org.astraea.common.DataRate;
-import org.astraea.common.DataSize;
-import org.astraea.common.DataUnit;
-import org.astraea.common.Utils;
+import org.astraea.app.argument.DurationField;
+import org.astraea.app.argument.NonEmptyStringField;
+import org.astraea.app.common.DataRate;
+import org.astraea.app.common.DataSize;
+import org.astraea.app.common.DataUnit;
+import org.astraea.app.common.Utils;
 
 public class ReplicaSyncingMonitor {
 
   public static void main(String[] args) {
-    Argument argument = org.astraea.argument.Argument.parse(new Argument(), args);
+    Argument argument = org.astraea.app.argument.Argument.parse(new Argument(), args);
     try (Admin topicAdmin = Admin.of(argument.bootstrapServers())) {
       execute(topicAdmin, argument);
     }
@@ -297,7 +297,7 @@ static String replicaDescriptor(Replica replica) {
         .collect(Collectors.joining(", ", "[", "]"));
   }
 
-  static class Argument extends org.astraea.argument.Argument {
+  static class Argument extends org.astraea.app.argument.Argument {
 
     @Parameter(
         names = {"--topics"},

app/src/main/java/org/astraea/admin/TopicCreator.java → app/src/main/java/org/astraea/app/admin/TopicCreator.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import java.time.Duration;
 import java.util.Map;

app/src/main/java/org/astraea/admin/TopicExplorer.java → app/src/main/java/org/astraea/app/admin/TopicExplorer.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import com.beust.jcommander.Parameter;
 import java.io.IOException;
@@ -17,10 +17,10 @@
 import java.util.stream.Collectors;
 import java.util.stream.IntStream;
 import java.util.stream.Stream;
-import org.astraea.argument.NonEmptyStringField;
-import org.astraea.argument.StringSetField;
-import org.astraea.common.DataSize;
-import org.astraea.common.DataUnit;
+import org.astraea.app.argument.NonEmptyStringField;
+import org.astraea.app.argument.StringSetField;
+import org.astraea.app.common.DataSize;
+import org.astraea.app.common.DataUnit;
 
 public class TopicExplorer {
 
@@ -109,7 +109,7 @@ static Result execute(Admin admin, Set<String> topics) {
   }
 
   public static void main(String[] args) throws IOException {
-    var argument = org.astraea.argument.Argument.parse(new Argument(), args);
+    var argument = org.astraea.app.argument.Argument.parse(new Argument(), args);
     try (var admin = Admin.of(argument.bootstrapServers())) {
       var result = execute(admin, argument.topics.isEmpty() ? admin.topicNames() : argument.topics);
       TreeOutput.print(result, System.out);
@@ -446,7 +446,7 @@ static String descriptor(Replica replica) {
     }
   }
 
-  static class Argument extends org.astraea.argument.Argument {
+  static class Argument extends org.astraea.app.argument.Argument {
     @Parameter(
         names = {"--topics"},
         description = "the topics to show all offset-related information. Empty means all topics",

app/src/main/java/org/astraea/admin/TopicPartition.java → app/src/main/java/org/astraea/app/admin/TopicPartition.java

@@ -1,4 +1,4 @@
-package org.astraea.admin;
+package org.astraea.app.admin;
 
 import java.util.Objects;
 

app/src/main/java/org/astraea/argument/Argument.java → app/src/main/java/org/astraea/app/argument/Argument.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 import com.beust.jcommander.JCommander;
 import com.beust.jcommander.Parameter;

app/src/main/java/org/astraea/argument/BooleanField.java → app/src/main/java/org/astraea/app/argument/BooleanField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 import com.beust.jcommander.ParameterException;
 

app/src/main/java/org/astraea/argument/CompressionField.java → app/src/main/java/org/astraea/app/argument/CompressionField.java

@@ -1,10 +1,10 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 import com.beust.jcommander.ParameterException;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 import org.apache.kafka.common.record.CompressionType;
-import org.astraea.admin.Compression;
+import org.astraea.app.admin.Compression;
 
 public class CompressionField extends Field<Compression> {
   /**

app/src/main/java/org/astraea/argument/DurationField.java → app/src/main/java/org/astraea/app/argument/DurationField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 import com.beust.jcommander.ParameterException;
 import java.time.Duration;

app/src/main/java/org/astraea/argument/Field.java → app/src/main/java/org/astraea/app/argument/Field.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 import com.beust.jcommander.IParameterValidator;
 import com.beust.jcommander.IStringConverter;

app/src/main/java/org/astraea/argument/IntegerSetField.java → app/src/main/java/org/astraea/app/argument/IntegerSetField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 import java.util.Set;
 import java.util.stream.Collectors;

app/src/main/java/org/astraea/argument/NonEmptyStringField.java → app/src/main/java/org/astraea/app/argument/NonEmptyStringField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 public class NonEmptyStringField extends Field<String> {
   @Override

app/src/main/java/org/astraea/argument/NonNegativeDoubleField.java → app/src/main/java/org/astraea/app/argument/NonNegativeDoubleField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 public class NonNegativeDoubleField extends NonNegativeNumberField<Double> {
   @Override

app/src/main/java/org/astraea/argument/NonNegativeIntegerField.java → app/src/main/java/org/astraea/app/argument/NonNegativeIntegerField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 public class NonNegativeIntegerField extends NonNegativeNumberField<Integer> {
   @Override

app/src/main/java/org/astraea/argument/NonNegativeLongField.java → app/src/main/java/org/astraea/app/argument/NonNegativeLongField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 public class NonNegativeLongField extends NonNegativeNumberField<Long> {
   @Override

app/src/main/java/org/astraea/argument/NonNegativeNumberField.java → app/src/main/java/org/astraea/app/argument/NonNegativeNumberField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 import com.beust.jcommander.ParameterException;
 

app/src/main/java/org/astraea/argument/NonNegativeShortField.java → app/src/main/java/org/astraea/app/argument/NonNegativeShortField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 public class NonNegativeShortField extends NonNegativeNumberField<Short> {
   @Override

app/src/main/java/org/astraea/argument/PathField.java → app/src/main/java/org/astraea/app/argument/PathField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 import java.nio.file.FileSystems;
 import java.nio.file.Path;

app/src/main/java/org/astraea/argument/PositiveDoubleField.java → app/src/main/java/org/astraea/app/argument/PositiveDoubleField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 public class PositiveDoubleField extends PositiveNumberField<Double> {
   @Override

app/src/main/java/org/astraea/argument/PositiveIntegerField.java → app/src/main/java/org/astraea/app/argument/PositiveIntegerField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 public class PositiveIntegerField extends PositiveNumberField<Integer> {
   @Override

app/src/main/java/org/astraea/argument/PositiveLongField.java → app/src/main/java/org/astraea/app/argument/PositiveLongField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 public class PositiveLongField extends PositiveNumberField<Long> {
   @Override

app/src/main/java/org/astraea/argument/PositiveNumberField.java → app/src/main/java/org/astraea/app/argument/PositiveNumberField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 import com.beust.jcommander.ParameterException;
 

app/src/main/java/org/astraea/argument/PositiveShortField.java → app/src/main/java/org/astraea/app/argument/PositiveShortField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 public class PositiveShortField extends PositiveNumberField<Short> {
   @Override

app/src/main/java/org/astraea/argument/SetField.java → app/src/main/java/org/astraea/app/argument/SetField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 import com.beust.jcommander.ParameterException;
 import java.util.Set;

app/src/main/java/org/astraea/argument/StringMapField.java → app/src/main/java/org/astraea/app/argument/StringMapField.java

@@ -1,4 +1,4 @@
-package org.astraea.argument;
+package org.astraea.app.argument;
 
 import com.beust.jcommander.ParameterException;
 import java.util.Arrays;