[COMMON] rename skiptests to opensource4you

.github/workflows/ci.yml

@@ -11,7 +11,7 @@ jobs:
   container-test-job:
     runs-on: ubuntu-latest
     container:
-      image: ghcr.io/skiptests/astraea/deps
+      image: ghcr.io/opensource4you/astraea/deps
       options: --cpus 2
     steps:
       - uses: actions/checkout@v2

README.md

@@ -42,12 +42,12 @@
 
 `Astraea` 鼓勵貢獻者參與研討會做技術發表，各年度的發表請見下列連結：
 
-[2022 年度](https://github.com/skiptests/astraea/issues/238)
+[2022 年度](https://github.com/opensource4you/astraea/issues/238)
 
-上述報告和測試所使用的硬體詳細資訊：[Astraea 測試用硬體](https://github.com/skiptests/astraea/issues/130)
+上述報告和測試所使用的硬體詳細資訊：[Astraea 測試用硬體](https://github.com/opensource4you/astraea/issues/130)
 
 # 社群活動
 
 `Astraea` 定時舉辦線下活動，各年度活動請見下方連結
 
-[2022 聖誕節](https://github.com/skiptests/astraea/issues/830)
+[2022 聖誕節](https://github.com/opensource4you/astraea/issues/830)

app/src/main/java/org/astraea/app/performance/Performance.java

@@ -451,7 +451,7 @@ else if (specifiedByBroker) {
       }
     }
 
-    // replace DataSize by DataRate (see https://github.com/skiptests/astraea/issues/488)
+    // replace DataSize by DataRate (see https://github.com/opensource4you/astraea/issues/488)
     @Parameter(
         names = {"--throughput"},
         description =

app/src/main/java/org/astraea/app/web/QuotaHandler.java

@@ -73,8 +73,8 @@ public CompletionStage<Response> post(Channel channel) {
                       .thenApply(Quotas::new));
     }
 
-    // TODO: use DataRate#Field (traced https://github.com/skiptests/astraea/issues/488)
-    // see https://github.com/skiptests/astraea/issues/490
+    // TODO: use DataRate#Field (traced https://github.com/opensource4you/astraea/issues/488)
+    // see https://github.com/opensource4you/astraea/issues/490
     if (postRequest.producer.isPresent()) {
       var producerQuota = postRequest.producer.get();
       return admin

app/src/main/java/org/astraea/app/web/RecordHandler.java

@@ -331,7 +331,7 @@ private static org.astraea.common.producer.Record<byte[], byte[]> createRecord(
     var builder = org.astraea.common.producer.Record.builder().topic(topic);
 
     // TODO: Support headers
-    // (https://github.com/skiptests/astraea/issues/422)
+    // (https://github.com/opensource4you/astraea/issues/422)
     var keySerializer = SerDe.ofAlias(postRecord.keySerializer).serializer;
     var valueSerializer = SerDe.ofAlias(postRecord.valueSerializer).serializer;
     postRecord.key.ifPresent(

app/src/main/java/org/astraea/app/web/ThrottleHandler.java

@@ -306,7 +306,7 @@ private Set<TopicPartitionReplica> toReplicaSet(String topic, String throttledRe
     if (throttledReplicas.isEmpty()) return Set.of();
 
     // TODO: support for wildcard throttle might be implemented in the future, see
-    // https://github.com/skiptests/astraea/issues/625
+    // https://github.com/opensource4you/astraea/issues/625
     if (throttledReplicas.equals("*"))
       throw new UnsupportedOperationException("This API doesn't support wildcard throttle");
 

common/build.gradle

@@ -92,7 +92,7 @@ publishing {
     }
     repositories {
         maven {
-            url = "https://maven.pkg.github.com/skiptests/astraea"
+            url = "https://maven.pkg.github.com/opensource4you/astraea"
             credentials {
                 username = System.getenv("GITHUB_ACTOR")
                 password = System.getenv("GITHUB_TOKEN")

common/src/main/java/org/astraea/common/assignor/Assignor.java

@@ -56,7 +56,7 @@ public abstract class Assignor implements ConsumerPartitionAssignor, Configurabl
   HasPartitionCost costFunction = HasPartitionCost.EMPTY;
   // TODO: metric collector may be configured by user in the future.
   // TODO: need to track the performance when using the assignor in large scale consumers, see
-  // https://github.com/skiptests/astraea/pull/1162#discussion_r1036285677
+  // https://github.com/opensource4you/astraea/pull/1162#discussion_r1036285677
   protected MetricStore metricStore = null;
 
   protected Admin admin = null;
@@ -72,7 +72,7 @@ protected abstract Map<String, List<TopicPartition>> assign(
       Map<String, SubscriptionInfo> subscriptions, ClusterInfo clusterInfo);
 
   // TODO: replace the topicPartitions by ClusterInfo after Assignor is able to handle Admin
-  // https://github.com/skiptests/astraea/issues/1409
+  // https://github.com/opensource4you/astraea/issues/1409
 
   /**
    * Parse config to get JMX port and cost function type.

common/src/main/java/org/astraea/common/cost/HasBrokerCost.java

@@ -30,7 +30,7 @@ public interface HasBrokerCost extends CostFunction {
   static HasBrokerCost of(Map<HasBrokerCost, Double> costAndWeight) {
     // the temporary exception won't affect the smooth-weighted too much.
     // TODO: should we propagate the exception by better way? For example: Slf4j ?
-    // see https://github.com/skiptests/astraea/issues/486
+    // see https://github.com/opensource4you/astraea/issues/486
     var sensor =
         MetricSensor.of(costAndWeight.keySet().stream().map(CostFunction::metricSensor).toList());
     return new HasBrokerCost() {

common/src/main/java/org/astraea/common/cost/NetworkCost.java

@@ -64,7 +64,7 @@
  *       bandwidth is correct and steadily reflect the actual resource usage. This is generally true
  *       when the broker has reach its steady state, but to reach that state might takes awhile. And
  *       based on our observation this probably won't happen at the early broker start (see <a
- *       href="https://github.com/skiptests/astraea/issues/1641">Issue #1641</a>). We suggest use
+ *       href="https://github.com/opensource4you/astraea/issues/1641">Issue #1641</a>). We suggest use
  *       this cost with metrics from the servers in steady state.
  * </ol>
  */
@@ -182,7 +182,7 @@ public ClusterCost clusterCost(ClusterInfo clusterInfo, ClusterBean clusterBean)
     var maxEgress = brokerEgressRate.values().stream().mapToDouble(x -> x).sum();
     var maxRate = Math.max(maxIngress, maxEgress);
     // the score is measured as the ratio of targeting network throughput related to the maximum
-    // ingress or egress throughput. See https://github.com/skiptests/astraea/issues/1285 for the
+    // ingress or egress throughput. See https://github.com/opensource4you/astraea/issues/1285 for the
     // reason to do this.
     double score = (summary.getMax() - summary.getMin()) / (maxRate);
 
@@ -193,7 +193,7 @@ public ClusterCost clusterCost(ClusterInfo clusterInfo, ClusterBean clusterBean)
   public MetricSensor metricSensor() {
     // TODO: We need a reliable way to access the actual current cluster info. To do that we need to
     //  obtain the replica info, so we intentionally sample log size but never use it.
-    //  https://github.com/skiptests/astraea/pull/1240#discussion_r1044487473
+    //  https://github.com/opensource4you/astraea/pull/1240#discussion_r1044487473
     return (client, clusterBean) ->
         Stream.of(
                 List.of(HostMetrics.jvmMemory(client)),
@@ -270,7 +270,7 @@ Map<TopicPartition, Long> estimateRate(
   private long ingress(CachedCalculation calculation, TopicPartition topicPartition) {
     var value = calculation.partitionIngressRate.get(topicPartition);
     if (value == null) {
-      // Maybe the user run into this bug: https://github.com/skiptests/astraea/issues/1388
+      // Maybe the user run into this bug: https://github.com/opensource4you/astraea/issues/1388
       throw new NoSufficientMetricsException(
           this,
           Duration.ofSeconds(1),
@@ -285,7 +285,7 @@ private long ingress(CachedCalculation calculation, TopicPartition topicPartitio
   private long egress(CachedCalculation calculation, TopicPartition topicPartition) {
     var value = calculation.partitionEgressRate.get(topicPartition);
     if (value == null) {
-      // Maybe the user run into this bug: https://github.com/skiptests/astraea/issues/1388
+      // Maybe the user run into this bug: https://github.com/opensource4you/astraea/issues/1388
       throw new NoSufficientMetricsException(
           this,
           Duration.ofSeconds(1),

common/src/main/java/org/astraea/common/metrics/JndiClient.java

@@ -153,7 +153,7 @@ public Collection<BeanObject> beans(
           () ->
               connection.queryMBeans(beanQuery.objectName(), null).stream()
                   // Parallelize the sampling of bean objects. The underlying RMI is thread-safe.
-                  // https://github.com/skiptests/astraea/issues/1553#issuecomment-1461143723
+                  // https://github.com/opensource4you/astraea/issues/1553#issuecomment-1461143723
                   .parallel()
                   .map(ObjectInstance::getObjectName)
                   .map(BeanQuery::fromObjectName)

common/src/main/java/org/astraea/common/metrics/collector/MetricStore.java

@@ -261,7 +261,7 @@ private MetricStoreImpl(
               try {
                 receivers.stream()
                     // TODO: Busy waiting on metric receiving.
-                    // issue: https://github.com/skiptests/astraea/issues/1834
+                    // issue: https://github.com/opensource4you/astraea/issues/1834
                     // To prevent specific receiver block other receivers' job, we set receive
                     // timeout to zero. But if all receivers return empty immediately, it may cause
                     // this thread busy waiting on doing `receiver.receive`.

common/src/main/java/org/astraea/common/partitioner/Partitioner.java

@@ -108,7 +108,7 @@ public static void beginInterdependent(
    * @param producer Astraea producer
    */
   // TODO One thread supports multiple producers.
-  // TODO: https://github.com/skiptests/astraea/pull/721#discussion_r973677891
+  // TODO: https://github.com/opensource4you/astraea/pull/721#discussion_r973677891
   public static void beginInterdependent(org.astraea.common.producer.Producer<?, ?> producer) {
     beginInterdependent((Producer<?, ?>) Utils.member(producer, "kafkaProducer"));
   }
@@ -127,7 +127,7 @@ public static void endInterdependent(org.apache.kafka.clients.producer.Producer<
    *
    * @param producer Kafka producer
    */
-  // TODO: https://github.com/skiptests/astraea/pull/721#discussion_r973677891
+  // TODO: https://github.com/opensource4you/astraea/pull/721#discussion_r973677891
   public static void endInterdependent(org.astraea.common.producer.Producer<?, ?> producer) {
     endInterdependent((Producer<?, ?>) Utils.member(producer, "kafkaProducer"));
   }

common/src/main/java/org/astraea/common/producer/RecordGenerator.java

@@ -137,7 +137,7 @@ public RecordGenerator build() {
             var key = recordKeyTable.get(keyDistribution.get());
             // Intentionally replace key with zero length by null key. A key with zero length can
             // lead to ambiguous behavior in an experiment.
-            // See https://github.com/skiptests/astraea/pull/1521#discussion_r1121801293 for further
+            // See https://github.com/opensource4you/astraea/pull/1521#discussion_r1121801293 for further
             // details.
             return key != null && key.length > 0 ? key : null;
           };

common/src/test/java/org/astraea/common/admin/ClusterInfoTest.java

@@ -44,7 +44,7 @@ public class ClusterInfoTest {
    */
   public static ClusterInfo of(List<Replica> replicas) {
     // TODO: this method is not suitable for production use. Move it to the test scope.
-    //  see https://github.com/skiptests/astraea/issues/1185
+    //  see https://github.com/opensource4you/astraea/issues/1185
     return ClusterInfo.of(
         "fake",
         replicas.stream()

common/src/test/java/org/astraea/common/connector/ConnectorClientBuilderTest.java

@@ -36,9 +36,9 @@ void testUrlShouldSet() throws MalformedURLException {
     Assertions.assertThrows(
         IllegalArgumentException.class, () -> ConnectorClient.builder().build());
 
-    ConnectorClient.builder().url(new URL("https://github.com/skiptests/astraea/")).build();
+    ConnectorClient.builder().url(new URL("https://github.com/opensource4you/astraea/")).build();
     ConnectorClient.builder()
-        .urls(List.of(new URL("https://github.com/skiptests/astraea/")))
+        .urls(List.of(new URL("https://github.com/opensource4you/astraea/")))
         .build();
   }
 

docker/build_deps_image.sh

@@ -16,7 +16,7 @@
 
 declare -r DOCKER_FOLDER=$(cd -- "$(dirname -- "${BASH_SOURCE[0]}")" &>/dev/null && pwd)
 source $DOCKER_FOLDER/docker_build_common.sh
-declare -r REPO=${REPO:-ghcr.io/skiptests/astraea/deps}
+declare -r REPO=${REPO:-ghcr.io/opensource4you/astraea/deps}
 declare -r VERSION="latest"
 declare -r IMAGE_NAME="$REPO:$VERSION"
 declare -r DOCKERFILE=$DOCKER_FOLDER/deps.dockerfile
@@ -34,7 +34,7 @@ RUN apt-get update && apt-get install -y \
 
 # build code and download dependencies
 WORKDIR /astraea
-RUN git clone https://github.com/skiptests/astraea.git /astraea
+RUN git clone https://github.com/opensource4you/astraea.git /astraea
 RUN ./gradlew clean build -x test
 # download test dependencies
 RUN ./gradlew clean build testClasses -x test --no-daemon

docker/start_app.sh

@@ -19,7 +19,7 @@ source $DOCKER_FOLDER/docker_build_common.sh
 
 # ===============================[global variables]===============================
 declare -r VERSION=${REVISION:-${VERSION:-main}}
-declare -r ACCOUNT=${ACCOUNT:-skiptests}
+declare -r ACCOUNT=${ACCOUNT:-opensource4you}
 if [[ "$VERSION" == "main" ]]; then
   declare -r IMAGE_NAME="ghcr.io/${ACCOUNT}/astraea/app:latest"
 else
@@ -38,14 +38,14 @@ declare -r BACKGROUND="${BACKGROUND:-"false"}"
 function showHelp() {
   echo "Usage: [ENV] start_app.sh"
   echo "ENV: "
-  echo "    ACCOUNT=skiptests          set the account to clone from"
+  echo "    ACCOUNT=opensource4you          set the account to clone from"
   echo "    BUILD=false                set true if you want to build image locally"
   echo "    RUN=false                  set false if you want to build/pull image only"
 }
 
 function generateDockerfile() {
   echo "# this dockerfile is generated dynamically
-FROM ghcr.io/skiptests/astraea/deps AS build
+FROM ghcr.io/opensource4you/astraea/deps AS build
 
 # clone repo
 WORKDIR /tmp

docker/start_broker.sh

@@ -18,7 +18,7 @@ declare -r DOCKER_FOLDER=$(cd -- "$(dirname -- "${BASH_SOURCE[0]}")" &>/dev/null
 source $DOCKER_FOLDER/docker_build_common.sh
 
 # ===============================[global variables]===============================
-declare -r ACCOUNT=${ACCOUNT:-skiptests}
+declare -r ACCOUNT=${ACCOUNT:-opensource4you}
 declare -r KAFKA_ACCOUNT=${KAFKA_ACCOUNT:-apache}
 declare -r VERSION=${REVISION:-${VERSION:-3.7.0}}
 declare -r DOCKERFILE=$DOCKER_FOLDER/broker.dockerfile
@@ -60,7 +60,7 @@ function showHelp() {
   echo "    num.network.threads=10                   set broker network threads"
   echo "ENV: "
   echo "    KAFKA_ACCOUNT=apache                      set the github account for kafka repo"
-  echo "    ACCOUNT=skiptests                      set the github account for astraea repo"
+  echo "    ACCOUNT=opensource4you                      set the github account for astraea repo"
   echo "    HEAP_OPTS=\"-Xmx2G -Xms2G\"                set broker JVM memory"
   echo "    REVISION=trunk                           set revision of kafka source code to build container"
   echo "    VERSION=3.7.0                            set version of kafka distribution"
@@ -73,7 +73,7 @@ function showHelp() {
 function generateDockerfileBySource() {
   local kafka_repo="https://github.com/${KAFKA_ACCOUNT}/kafka"
   echo "# this dockerfile is generated dynamically
-FROM ghcr.io/skiptests/astraea/deps AS build
+FROM ghcr.io/opensource4you/astraea/deps AS build
 
 # download jmx exporter
 RUN mkdir /opt/jmx_exporter

docker/start_controller.sh

@@ -18,7 +18,7 @@ declare -r DOCKER_FOLDER=$(cd -- "$(dirname -- "${BASH_SOURCE[0]}")" &>/dev/null
 source $DOCKER_FOLDER/docker_build_common.sh
 
 # ===============================[global variables]===============================
-declare -r ACCOUNT=${ACCOUNT:-skiptests}
+declare -r ACCOUNT=${ACCOUNT:-opensource4you}
 declare -r KAFKA_ACCOUNT=${KAFKA_ACCOUNT:-apache}
 declare -r VERSION=${REVISION:-${VERSION:-3.7.0}}
 declare -r DOCKERFILE=$DOCKER_FOLDER/controller.dockerfile
@@ -71,7 +71,7 @@ function showHelp() {
   echo "Usage: [ENV] start_controller.sh [ ARGUMENTS ]"
   echo "ENV: "
   echo "    KAFKA_ACCOUNT=apache                      set the github account for kafka repo"
-  echo "    ACCOUNT=skiptests                      set the github account for astraea repo"
+  echo "    ACCOUNT=opensource4you                      set the github account for astraea repo"
   echo "    HEAP_OPTS=\"-Xmx2G -Xms2G\"                set controller JVM memory"
   echo "    REVISION=trunk                           set revision of kafka source code to build container"
   echo "    VERSION=3.7.0                            set version of kafka distribution"
@@ -83,7 +83,7 @@ function showHelp() {
 function generateDockerfileBySource() {
   local kafka_repo="https://github.com/${KAFKA_ACCOUNT}/kafka"
   echo "# this dockerfile is generated dynamically
-FROM ghcr.io/skiptests/astraea/deps AS build
+FROM ghcr.io/opensource4you/astraea/deps AS build
 
 # download jmx exporter
 RUN mkdir /opt/jmx_exporter

docker/start_hadoop.sh

@@ -19,7 +19,7 @@ source $DOCKER_FOLDER/docker_build_common.sh
 
 # ===============================[global variables]===============================
 declare -r VERSION=${VERSION:-3.3.5}
-declare -r REPO=${REPO:-ghcr.io/skiptests/astraea/hadoop}
+declare -r REPO=${REPO:-ghcr.io/opensource4you/astraea/hadoop}
 declare -r IMAGE_NAME="$REPO:$VERSION"
 declare -r DOCKERFILE=$DOCKER_FOLDER/hadoop.dockerfile
 declare -r EXPORTER_VERSION="0.16.1"
@@ -78,7 +78,7 @@ RUN tar -zxvf hadoop-${VERSION}.tar.gz -C /opt/hadoop --strip-components=1
 FROM ubuntu:23.10
 
 #install tools
-# TODO: upgrade to jdk 11 (https://github.com/skiptests/astraea/issues/1681)
+# TODO: upgrade to jdk 11 (https://github.com/opensource4you/astraea/issues/1681)
 RUN apt-get update && apt-get install -y openjdk-11-jre
 
 #copy hadoop

docker/start_worker.sh

@@ -18,7 +18,7 @@ declare -r DOCKER_FOLDER=$(cd -- "$(dirname -- "${BASH_SOURCE[0]}")" &>/dev/null
 source $DOCKER_FOLDER/docker_build_common.sh
 
 # ===============================[global variables]===============================
-declare -r ACCOUNT=${ACCOUNT:-skiptests}
+declare -r ACCOUNT=${ACCOUNT:-opensource4you}
 declare -r KAFKA_ACCOUNT=${KAFKA_ACCOUNT:-apache}
 declare -r VERSION=${REVISION:-${VERSION:-3.7.0}}
 declare -r DOCKERFILE=$DOCKER_FOLDER/worker.dockerfile
@@ -47,7 +47,7 @@ function showHelp() {
   echo "    bootstrap.servers=node:22222,node:1111   set brokers connection"
   echo "ENV: "
   echo "    KAFKA_ACCOUNT=apache                      set the github account for kafka repo"
-  echo "    ACCOUNT=skiptests                      set the github account for astraea repo"
+  echo "    ACCOUNT=opensource4you                      set the github account for astraea repo"
   echo "    HEAP_OPTS=\"-Xmx2G -Xms2G\"              set worker JVM memory"
   echo "    REVISION=trunk                           set revision of kafka source code to build container"
   echo "    VERSION=3.7.0                            set version of kafka distribution"
@@ -77,7 +77,7 @@ function generateDockerfileBySource() {
   local repo="https://github.com/${ACCOUNT}/astraea"
 
   echo "# this dockerfile is generated dynamically
-FROM ghcr.io/skiptests/astraea/deps AS build
+FROM ghcr.io/opensource4you/astraea/deps AS build
 
 # build kafka from source code
 RUN git clone --depth=1 ${kafka_repo} /tmp/kafka
@@ -113,7 +113,7 @@ WORKDIR /opt/kafka
 function generateDockerfileByVersion() {
   local repo="https://github.com/${ACCOUNT}/astraea"
   echo "# this dockerfile is generated dynamically
-FROM ghcr.io/skiptests/astraea/deps AS build
+FROM ghcr.io/opensource4you/astraea/deps AS build
 
 # install tools
 RUN apt-get update && apt-get install -y wget

docker/start_zookeeper.sh

@@ -19,7 +19,7 @@ source $DOCKER_FOLDER/docker_build_common.sh
 
 # ===============================[global variables]===============================
 declare -r VERSION=${VERSION:-3.9.1}
-declare -r REPO=${REPO:-ghcr.io/skiptests/astraea/zookeeper}
+declare -r REPO=${REPO:-ghcr.io/opensource4you/astraea/zookeeper}
 declare -r IMAGE_NAME="$REPO:$VERSION"
 declare -r ZOOKEEPER_PORT=${ZOOKEEPER_PORT:-"$(getRandomPort)"}
 declare -r ZOOKEEPER_JMX_PORT="${ZOOKEEPER_JMX_PORT:-"$(getRandomPort)"}"