Move kafka-src to servers/0.8.0/kafka-src, move test/resources to servers/0.8.0/resources, update fixtures, add build_integration.sh for getting started with development

1 files changed, 4 insertions, 3 deletions

diff --git a/test/fixtures.py b/test/fixtures.py
index bb6bc87..af4c145 100644
--- a/test/fixtures.py
+++ b/test/fixtures.py
@@ -11,14 +11,15 @@ from .service import ExternalService, SpawnedService
 from .testutil import get_open_port
 
 class Fixture(object):
-    project_root = os.environ.get('PROJECT_ROOT', os.path.abspath(os.path.join(os.path.dirname(__file__), "..")))
+    kafka_version = os.environ.get('KAFKA_VERSION', '0.8.0')
     scala_version = os.environ.get("SCALA_VERSION", '2.8.0')
-    kafka_root = os.environ.get("KAFKA_ROOT", os.path.join(project_root, "kafka-src"))
+    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-src"))
     ivy_root = os.environ.get('IVY_ROOT', os.path.expanduser("~/.ivy2/cache"))
 
     @classmethod
     def test_resource(cls, filename):
-        return os.path.join(cls.project_root, "test", "resources", filename)
+        return os.path.join(cls.project_root, "servers", cls.kafka_version, "resources", filename)
 
     @classmethod
     def test_classpath(cls):