Repository: samza
Updated Branches:
  refs/heads/master d89d1ba3a -> 9e2ee35d6


SAMZA-1274; Update kafka-python and kafka broker version for integration tests

Author: Prateek Maheshwari <pmahe...@linkedin.com>

Reviewers: Jagadish <jagad...@apache.org>

Closes #174 from prateekm/integration-test-updates


Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/9e2ee35d
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/9e2ee35d
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/9e2ee35d

Branch: refs/heads/master
Commit: 9e2ee35d61b8bf92c1e9b59d821d97face576108
Parents: d89d1ba
Author: Prateek Maheshwari <pmahe...@linkedin.com>
Authored: Tue May 9 10:41:50 2017 -0700
Committer: vjagadish1989 <jvenk...@linkedin.com>
Committed: Tue May 9 10:41:50 2017 -0700

----------------------------------------------------------------------
 .../src/main/python/configs/downloads.json      |  2 +-
 samza-test/src/main/python/configs/kafka.json   | 22 ++++++++++----------
 samza-test/src/main/python/requirements.txt     |  2 +-
 3 files changed, 13 insertions(+), 13 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/samza/blob/9e2ee35d/samza-test/src/main/python/configs/downloads.json
----------------------------------------------------------------------
diff --git a/samza-test/src/main/python/configs/downloads.json 
b/samza-test/src/main/python/configs/downloads.json
index c468156..ee2edcb 100644
--- a/samza-test/src/main/python/configs/downloads.json
+++ b/samza-test/src/main/python/configs/downloads.json
@@ -1,5 +1,5 @@
 {
-  "url_kafka": 
"http://archive.apache.org/dist/kafka/0.10.0.1/kafka_2.10-0.10.0.1.tgz";,
+  "url_kafka": 
"http://archive.apache.org/dist/kafka/0.10.1.1/kafka_2.10-0.10.1.1.tgz";,
   "url_zookeeper": 
"http://archive.apache.org/dist/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz";,
   "url_hadoop": 
"https://archive.apache.org/dist/hadoop/common/hadoop-2.6.1/hadoop-2.6.1.tar.gz";
 }

http://git-wip-us.apache.org/repos/asf/samza/blob/9e2ee35d/samza-test/src/main/python/configs/kafka.json
----------------------------------------------------------------------
diff --git a/samza-test/src/main/python/configs/kafka.json 
b/samza-test/src/main/python/configs/kafka.json
index ece2a34..91fe23e 100644
--- a/samza-test/src/main/python/configs/kafka.json
+++ b/samza-test/src/main/python/configs/kafka.json
@@ -3,21 +3,21 @@
     "kafka_instance_0": "localhost"
   },
   "kafka_port": 9092,
-  "kafka_start_cmd": "kafka_2.10-0.10.0.1/bin/kafka-server-start.sh -daemon 
kafka_2.10-0.10.0.1/config/server.properties",
-  "kafka_stop_cmd": "kafka_2.10-0.10.0.1/bin/kafka-server-stop.sh",
+  "kafka_start_cmd": "kafka_2.10-0.10.1.1/bin/kafka-server-start.sh -daemon 
kafka_2.10-0.10.1.1/config/server.properties",
+  "kafka_stop_cmd": "kafka_2.10-0.10.1.1/bin/kafka-server-stop.sh",
   "kafka_install_path": "deploy/kafka",
-  "kafka_executable": "kafka_2.10-0.10.0.1.tgz",
+  "kafka_executable": "kafka_2.10-0.10.1.1.tgz",
   "kafka_post_install_cmds": [
-    "sed -i.bak 's/SIGINT/SIGTERM/g' 
kafka_2.10-0.10.0.1/bin/kafka-server-stop.sh",
-    "sed -i.bak 's/^num\\.partitions *=.*/num.partitions=1/' 
kafka_2.10-0.10.0.1/config/server.properties",
-    "sed -i.bak 's/.*log.dirs.*/log.dirs=data/g' 
kafka_2.10-0.10.0.1/config/server.properties"
+    "sed -i.bak 's/SIGINT/SIGTERM/g' 
kafka_2.10-0.10.1.1/bin/kafka-server-stop.sh",
+    "sed -i.bak 's/^num\\.partitions *=.*/num.partitions=1/' 
kafka_2.10-0.10.1.1/config/server.properties",
+    "sed -i.bak 's/.*log.dirs.*/log.dirs=data/g' 
kafka_2.10-0.10.1.1/config/server.properties"
   ],
   "kafka_logs": [
     "log-cleaner.log",
-    "kafka_2.10-0.10.0.1/logs/controller.log",
-    "kafka_2.10-0.10.0.1/logs/kafka-request.log",
-    "kafka_2.10-0.10.0.1/logs/kafkaServer-gc.log",
-    "kafka_2.10-0.10.0.1/logs/server.log",
-    "kafka_2.10-0.10.0.1/logs/state-change.log"
+    "kafka_2.10-0.10.1.1/logs/controller.log",
+    "kafka_2.10-0.10.1.1/logs/kafka-request.log",
+    "kafka_2.10-0.10.1.1/logs/kafkaServer-gc.log",
+    "kafka_2.10-0.10.1.1/logs/server.log",
+    "kafka_2.10-0.10.1.1/logs/state-change.log"
   ]
 }

http://git-wip-us.apache.org/repos/asf/samza/blob/9e2ee35d/samza-test/src/main/python/requirements.txt
----------------------------------------------------------------------
diff --git a/samza-test/src/main/python/requirements.txt 
b/samza-test/src/main/python/requirements.txt
index e1f8c49..cf43a23 100644
--- a/samza-test/src/main/python/requirements.txt
+++ b/samza-test/src/main/python/requirements.txt
@@ -17,5 +17,5 @@
 
 zopkio==0.2.5
 requests
-kafka-python==1.2.5
+kafka-python==1.3.3
 Jinja2

Reply via email to