Skip to content

Commit

Permalink
[DOCKER] upgrade kafka from 3.8.1 to 3.9.0
Browse files Browse the repository at this point in the history
  • Loading branch information
chia7712 committed Nov 29, 2024
1 parent 9fab2a0 commit 492f9c1
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 9 deletions.
6 changes: 3 additions & 3 deletions docker/start_broker.sh
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ source $DOCKER_FOLDER/docker_build_common.sh
declare -r ACCOUNT=${ACCOUNT:-opensource4you}
declare -r VERSION=${VERSION:-main}
declare -r KAFKA_ACCOUNT=${KAFKA_ACCOUNT:-apache}
declare -r KAFKA_VERSION=${KAFKA_REVISION:-${KAFKA_VERSION:-3.8.1}}
declare -r KAFKA_VERSION=${KAFKA_REVISION:-${KAFKA_VERSION:-3.9.0}}
declare -r DOCKERFILE=$DOCKER_FOLDER/broker.dockerfile
declare -r DATA_FOLDER_IN_CONTAINER_PREFIX="/tmp/log-folder"
declare -r EXPORTER_VERSION="0.16.1"
Expand Down Expand Up @@ -65,7 +65,7 @@ function showHelp() {
echo " ACCOUNT=opensource4you set the github account for astraea repo"
echo " HEAP_OPTS=\"-Xmx2G -Xms2G\" set broker JVM memory"
echo " KAFKA_REVISION=trunk set revision of kafka source code to build container"
echo " KAFKA_VERSION=3.8.1 set version of kafka distribution"
echo " KAFKA_VERSION=3.9.0 set version of kafka distribution"
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"
echo " DATA_FOLDERS=/tmp/folder1 set host folders used by broker"
Expand Down Expand Up @@ -124,7 +124,7 @@ function generateDockerfileByVersion() {
local kafka_url="https://archive.apache.org/dist/kafka/${KAFKA_VERSION}/kafka_2.13-${KAFKA_VERSION}.tgz"
local version=$KAFKA_VERSION
if [[ "$KAFKA_VERSION" == *"rc"* ]]; then
## `3.8.1-rc1` the rc release does not exist in archive repo
## `3.9.0-rc1` the rc release does not exist in archive repo
version=${KAFKA_VERSION%-*}
kafka_url="https://dist.apache.org/repos/dist/dev/kafka/${KAFKA_VERSION}/kafka_2.13-${version}.tgz"
fi
Expand Down
6 changes: 3 additions & 3 deletions docker/start_controller.sh
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ source $DOCKER_FOLDER/docker_build_common.sh
# ===============================[global variables]===============================
declare -r ACCOUNT=${ACCOUNT:-opensource4you}
declare -r KAFKA_ACCOUNT=${KAFKA_ACCOUNT:-apache}
declare -r KAFKA_VERSION=${KAFKA_REVISION:-${KAFKA_VERSION:-3.8.1}}
declare -r KAFKA_VERSION=${KAFKA_REVISION:-${KAFKA_VERSION:-3.9.0}}
declare -r DOCKERFILE=$DOCKER_FOLDER/controller.dockerfile
declare -r EXPORTER_VERSION="0.16.1"
declare -r CLUSTER_ID=${CLUSTER_ID:-"$(randomString)"}
Expand Down Expand Up @@ -53,7 +53,7 @@ function showHelp() {
echo " ACCOUNT=opensource4you set the github account for astraea repo"
echo " HEAP_OPTS=\"-Xmx2G -Xms2G\" set controller JVM memory"
echo " KAFKA_REVISION=trunk set revision of kafka source code to build container"
echo " KAFKA_VERSION=3.8.1 set version of kafka distribution"
echo " KAFKA_VERSION=3.9.0 set version of kafka distribution"
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"
echo " META_FOLDER=/tmp/folder1 set host folder used by controller"
Expand Down Expand Up @@ -102,7 +102,7 @@ function generateDockerfileByVersion() {
local kafka_url="https://archive.apache.org/dist/kafka/${KAFKA_VERSION}/kafka_2.13-${KAFKA_VERSION}.tgz"
local version=$KAFKA_VERSION
if [[ "$KAFKA_VERSION" == *"rc"* ]]; then
## `3.8.1-rc1` the rc release does not exist in archive repo
## `3.9.0-rc1` the rc release does not exist in archive repo
version=${KAFKA_VERSION%-*}
kafka_url="https://dist.apache.org/repos/dist/dev/kafka/${KAFKA_VERSION}/kafka_2.13-${version}.tgz"
fi
Expand Down
6 changes: 3 additions & 3 deletions docker/start_worker.sh
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ source $DOCKER_FOLDER/docker_build_common.sh
# ===============================[global variables]===============================
declare -r ACCOUNT=${ACCOUNT:-opensource4you}
declare -r KAFKA_ACCOUNT=${KAFKA_ACCOUNT:-apache}
declare -r KAFKA_VERSION=${KAFKA_REVISION:-${KAFKA_VERSION:-3.8.1}}
declare -r KAFKA_VERSION=${KAFKA_REVISION:-${KAFKA_VERSION:-3.9.0}}
declare -r DOCKERFILE=$DOCKER_FOLDER/worker.dockerfile
declare -r WORKER_PORT=${WORKER_PORT:-"$(getRandomPort)"}
declare -r CONTAINER_NAME="worker-$WORKER_PORT"
Expand Down Expand Up @@ -50,7 +50,7 @@ function showHelp() {
echo " ACCOUNT=opensource4you set the github account for astraea repo"
echo " HEAP_OPTS=\"-Xmx2G -Xms2G\" set worker JVM memory"
echo " KAFKA_REVISION=trunk set revision of kafka source code to build container"
echo " KAFKA_VERSION=3.8.1 set version of kafka distribution"
echo " KAFKA_VERSION=3.9.0 set version of kafka distribution"
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"
echo " WORKER_PLUGIN_PATH=/tmp/worker-plugins set plugin path to kafka worker"
Expand Down Expand Up @@ -114,7 +114,7 @@ function generateDockerfileByVersion() {
local kafka_url="https://archive.apache.org/dist/kafka/${KAFKA_VERSION}/kafka_2.13-${KAFKA_VERSION}.tgz"
local version=$KAFKA_VERSION
if [[ "$KAFKA_VERSION" == *"rc"* ]]; then
## `3.8.1-rc1` the rc release does not exist in archive repo
## `3.9.0-rc1` the rc release does not exist in archive repo
version=${KAFKA_VERSION%-*}
kafka_url="https://dist.apache.org/repos/dist/dev/kafka/${KAFKA_VERSION}/kafka_2.13-${version}.tgz"
fi
Expand Down

0 comments on commit 492f9c1

Please sign in to comment.