diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-01-25 15:20:22 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-01-25 15:20:22 -0800 |
| commit | f38d2e59c1907725b3c6809aa608c03c3d5acde6 (patch) | |
| tree | 306f1de2fa3736258272b3b9d00ed4b85bdc57c3 /test | |
| parent | 351f418ba5b62c28c8cff5ea7dcca8e37cadcf8e (diff) | |
| download | kafka-python-0_11_0_2.tar.gz | |
Use 0.11.0.2 kafka broker for integration testing0_11_0_2
Diffstat (limited to 'test')
| -rw-r--r-- | test/fixtures.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/test/fixtures.py b/test/fixtures.py index b49a160..62c6d50 100644 --- a/test/fixtures.py +++ b/test/fixtures.py @@ -21,7 +21,7 @@ log = logging.getLogger(__name__) class Fixture(object): - kafka_version = os.environ.get('KAFKA_VERSION', '0.11.0.1') + kafka_version = os.environ.get('KAFKA_VERSION', '0.11.0.2') scala_version = os.environ.get("SCALA_VERSION", '2.8.0') project_root = os.environ.get('PROJECT_ROOT', os.path.abspath(os.path.join(os.path.dirname(__file__), ".."))) kafka_root = os.environ.get("KAFKA_ROOT", os.path.join(project_root, 'servers', kafka_version, "kafka-bin")) |