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
This commit is contained in:
6
.gitmodules
vendored
6
.gitmodules
vendored
@@ -1,3 +1,3 @@
|
|||||||
[submodule "kafka-src"]
|
[submodule "servers/0.8.0/kafka-src"]
|
||||||
path = kafka-src
|
path = servers/0.8.0/kafka-src
|
||||||
url = git://github.com/apache/kafka.git
|
url = https://github.com/apache/kafka.git
|
||||||
|
4
build_integration.sh
Executable file
4
build_integration.sh
Executable file
@@ -0,0 +1,4 @@
|
|||||||
|
#!/bin/bash
|
||||||
|
|
||||||
|
git submodule update --init
|
||||||
|
(cd servers/0.8.0/kafka-src && ./sbt update package assembly-package-dependency)
|
@@ -11,14 +11,15 @@ from .service import ExternalService, SpawnedService
|
|||||||
from .testutil import get_open_port
|
from .testutil import get_open_port
|
||||||
|
|
||||||
class Fixture(object):
|
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')
|
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"))
|
ivy_root = os.environ.get('IVY_ROOT', os.path.expanduser("~/.ivy2/cache"))
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
def test_resource(cls, filename):
|
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
|
@classmethod
|
||||||
def test_classpath(cls):
|
def test_classpath(cls):
|
||||||
|
3
tox.ini
3
tox.ini
@@ -10,6 +10,3 @@ commands =
|
|||||||
nosetests --with-coverage --cover-erase --cover-package kafka []
|
nosetests --with-coverage --cover-erase --cover-package kafka []
|
||||||
setenv =
|
setenv =
|
||||||
PROJECT_ROOT = {toxinidir}
|
PROJECT_ROOT = {toxinidir}
|
||||||
KAFKA_ROOT = {toxinidir}/kafka-src
|
|
||||||
[pytest]
|
|
||||||
norecursedirs = .git .tox build dist kafka-src
|
|
||||||
|
Reference in New Issue
Block a user