This is an automated email from the ASF dual-hosted git repository.
pmaheshwari pushed a commit to branch latest
in repository https://gitbox.apache.org/repos/asf/samza-hello-samza.git
The following commit(s) were added to refs/heads/latest by this push:
new a05bf22 [CHERRY-PICK] Kafka Download URL correction and version bump
for ZK & Kafka
a05bf22 is described below
commit a05bf22541ee7482b12c8270e108c901e26e51be
Author: Adam Faris <[email protected]>
AuthorDate: Fri Apr 12 16:19:31 2019 -0700
[CHERRY-PICK] Kafka Download URL correction and version bump for ZK & Kafka
Author: Adam Faris <[email protected]>
Reviewers: Prateek Maheshwari <[email protected]>
Closes #57 from prateekm/latest
---
bin/grid | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/bin/grid b/bin/grid
index 638fd48..f872dc7 100755
--- a/bin/grid
+++ b/bin/grid
@@ -35,9 +35,9 @@ DOWNLOAD_CACHE_DIR=$HOME/.samza/download
COMMAND=$1
SYSTEM=$2
-DOWNLOAD_KAFKA=https://archive.apache.org/dist/kafka/0.10.1.1/kafka_2.11-0.10.1.1.tgz
+DOWNLOAD_KAFKA=https://archive.apache.org/dist/kafka/2.1.1/kafka_2.11-2.1.1.tgz
DOWNLOAD_YARN=https://archive.apache.org/dist/hadoop/common/hadoop-2.6.1/hadoop-2.6.1.tar.gz
-DOWNLOAD_ZOOKEEPER=http://archive.apache.org/dist/zookeeper/zookeeper-3.4.3/zookeeper-3.4.3.tar.gz
+DOWNLOAD_ZOOKEEPER=https://archive.apache.org/dist/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz
SERVICE_WAIT_TIMEOUT_SEC=20
ZOOKEEPER_PORT=2181
@@ -97,7 +97,7 @@ install_samza() {
install_zookeeper() {
mkdir -p "$DEPLOY_ROOT_DIR"
- install zookeeper $DOWNLOAD_ZOOKEEPER zookeeper-3.4.3
+ install zookeeper $DOWNLOAD_ZOOKEEPER zookeeper-3.4.14
cp "$DEPLOY_ROOT_DIR/zookeeper/conf/zoo_sample.cfg"
"$DEPLOY_ROOT_DIR/zookeeper/conf/zoo.cfg"
}
@@ -113,7 +113,7 @@ install_yarn() {
install_kafka() {
mkdir -p "$DEPLOY_ROOT_DIR"
- install kafka $DOWNLOAD_KAFKA kafka_2.11-0.10.1.1
+ install kafka $DOWNLOAD_KAFKA kafka_2.11-2.1.1
# have to use SIGTERM since nohup on appears to ignore SIGINT
# and Kafka switched to SIGINT in KAFKA-1031.
sed -i.bak 's/SIGINT/SIGTERM/g'
$DEPLOY_ROOT_DIR/kafka/bin/kafka-server-stop.sh
