diff --git a/...dded-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-6-big-Data.db b/...dded-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-6-big-Data.db
diff --git a/...cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-6-big-Digest.crc32 b/...cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-6-big-Digest.crc32
@@ -0,0 +1 @@
+3641291290
diff --git a/...ed-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-6-big-Filter.db b/...ed-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-6-big-Filter.db
diff --git a/...ded-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-6-big-Index.db b/...ded-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-6-big-Index.db
diff --git a/...assandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-6-big-Statistics.db b/...assandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-6-big-Statistics.db
diff --git a/...d-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-6-big-Summary.db b/...d-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-6-big-Summary.db
diff --git a/...dded-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-6-big-TOC.txt b/...dded-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-6-big-TOC.txt
@@ -0,0 +1,8 @@
+Digest.crc32
+Index.db
+CompressionInfo.db
+TOC.txt
+Statistics.db
+Data.db
+Filter.db
+Summary.db
diff --git a/...dra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-CompressionInfo.db b/...dra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-CompressionInfo.db
diff --git a/...dded-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-Data.db b/...dded-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-Data.db
diff --git a/...cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-Digest.crc32 b/...cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-Digest.crc32
@@ -0,0 +1 @@
+874621109
diff --git a/...ed-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-Filter.db b/...ed-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-Filter.db
diff --git a/...ded-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-Index.db b/...ded-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-Index.db
diff --git a/...assandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-Statistics.db b/...assandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-Statistics.db
diff --git a/...d-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-Summary.db b/...d-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-Summary.db
diff --git a/...dded-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-TOC.txt b/...dded-cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/mc-7-big-TOC.txt
@@ -0,0 +1,8 @@
+Digest.crc32
+Index.db
+CompressionInfo.db
+TOC.txt
+Statistics.db
+Data.db
+Filter.db
+Summary.db
diff --git a/...dra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-5-big-CompressionInfo.db b/...dra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-5-big-CompressionInfo.db
diff --git a/...dded-cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-5-big-Data.db b/...dded-cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-5-big-Data.db
diff --git a/...cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-5-big-Digest.crc32 b/...cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-5-big-Digest.crc32
diff --git a/...ded-cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-5-big-Index.db b/...ded-cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-5-big-Index.db
diff --git a/...dded-cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-6-big-Data.db b/...dded-cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-6-big-Data.db
diff --git a/...cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-6-big-Digest.crc32 b/...cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-6-big-Digest.crc32
diff --git a/...assandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-6-big-Statistics.db b/...assandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-6-big-Statistics.db
diff --git a/...dra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-9-big-CompressionInfo.db b/...dra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-9-big-CompressionInfo.db
diff --git a/...dded-cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-9-big-Data.db b/...dded-cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-9-big-Data.db
diff --git a/...cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-9-big-Digest.crc32 b/...cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-9-big-Digest.crc32
@@ -0,0 +1 @@
+3347754238
diff --git a/...583201a7cdad556410c985/mc-5-big-Filter.db → ...583201a7cdad556410c985/mc-9-big-Filter.db b/...583201a7cdad556410c985/mc-5-big-Filter.db → ...583201a7cdad556410c985/mc-9-big-Filter.db
diff --git a/...ded-cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-9-big-Index.db b/...ded-cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-9-big-Index.db
diff --git a/...01a7cdad556410c985/mc-5-big-Statistics.db → ...01a7cdad556410c985/mc-9-big-Statistics.db b/...01a7cdad556410c985/mc-5-big-Statistics.db → ...01a7cdad556410c985/mc-9-big-Statistics.db
diff --git a/...83201a7cdad556410c985/mc-5-big-Summary.db → ...83201a7cdad556410c985/mc-9-big-Summary.db b/...83201a7cdad556410c985/mc-5-big-Summary.db → ...83201a7cdad556410c985/mc-9-big-Summary.db
diff --git a/...dded-cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-9-big-TOC.txt b/...dded-cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/mc-9-big-TOC.txt
@@ -0,0 +1,8 @@
+Digest.crc32
+Index.db
+CompressionInfo.db
+TOC.txt
+Statistics.db
+Data.db
+Filter.db
+Summary.db
diff --git a/target/embedded-cassandra/dev-embedded-cassandra.yaml b/target/embedded-cassandra/dev-embedded-cassandra.yaml
@@ -12,15 +12,15 @@ cluster_name: 'Test Cluster'
 
 # directories where Cassandra should store data on disk.
 data_file_directories:
-    - /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/embedded-cassandra/data
+    - C:\kanban\target\embedded-cassandra/data
 
 # commit log
-commitlog_directory: /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/embedded-cassandra/commitlog
+commitlog_directory: C:\kanban\target\embedded-cassandra/commitlog
 
 # saved caches
-saved_caches_directory: /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/embedded-cassandra/saved_caches
+saved_caches_directory: C:\kanban\target\embedded-cassandra/saved_caches
 
-hints_directory: /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/embedded-cassandra/hints
+hints_directory: C:\kanban\target\embedded-cassandra/hints
 
 commitlog_sync: periodic
 commitlog_sync_period_in_ms: 10000
@@ -36,7 +36,7 @@ start_native_transport: true
 native_transport_port: 4000
 
 # TCP port, for commands and data
-storage_port: 51258
+storage_port: 2798
 
 # Whether to start the thrift rpc server.
 start_rpc: false

diff --git a/...om.kanban/lagom-internal-meta-project-cassandra_2.11/1.0-SNAPSHOT/resolved.xml.properties b/...om.kanban/lagom-internal-meta-project-cassandra_2.11/1.0-SNAPSHOT/resolved.xml.properties
@@ -1,5 +1,5 @@
 #com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT resolved revisions
-#Thu Apr 27 23:54:10 CEST 2017
+#Wed May 03 17:55:33 CEST 2017
 +organisation\:\#@\#\:+com.lightbend.lagom\:\#@\#\:+branch\:\#@\#\:+@\#\:NULL\:\#@\:\#@\#\:+module\:\#@\#\:+lagom-cassandra-server_2.11\:\#@\#\:+revision\:\#@\#\:+1.3.2\:\#@\#\:=1.3.2 release 1.3.2 null
 +organisation\:\#@\#\:+org.scala-lang\:\#@\#\:+branch\:\#@\#\:+@\#\:NULL\:\#@\:\#@\#\:+module\:\#@\#\:+scala-library\:\#@\#\:+revision\:\#@\#\:+2.11.7\:\#@\#\:=2.11.7 ? 2.11.7 null
 +organisation\:\#@\#\:+org.scala-lang\:\#@\#\:+branch\:\#@\#\:+@\#\:NULL\:\#@\:\#@\#\:+module\:\#@\#\:+scala-compiler\:\#@\#\:+revision\:\#@\#\:+2.11.7\:\#@\#\:=2.11.7 release 2.11.7 null
diff --git a/...cache/com.kanban/lagom-internal-meta-project-cassandra_2.11/1.0-SNAPSHOT/resolved.xml.xml b/...cache/com.kanban/lagom-internal-meta-project-cassandra_2.11/1.0-SNAPSHOT/resolved.xml.xml
@@ -4,7 +4,7 @@
 		module="lagom-internal-meta-project-cassandra_2.11"
 		revision="1.0-SNAPSHOT"
 		status="integration"
-		publication="20170427235408"
+		publication="20170503175528"
 	>
 		<description>
 		lagom-internal-meta-project-cassandra

diff --git a/...-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-compile-internal.xml b/...-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-compile-internal.xml
diff --git a/...esolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-compile.xml b/...esolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-compile.xml
diff --git a/...t/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-docs.xml b/...t/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-docs.xml
@@ -7,7 +7,7 @@
 		revision="1.0-SNAPSHOT"
 		conf="docs"
 		confs="compile, runtime, test, provided, optional, compile-internal, runtime-internal, test-internal, plugin, sources, docs, pom, scala-tool"
-		date="20170427235408"/>
+		date="20170503175528"/>
 	<dependencies>
 	</dependencies>
 </ivy-report>
diff --git a/...solution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-optional.xml b/...solution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-optional.xml
@@ -7,7 +7,7 @@
 		revision="1.0-SNAPSHOT"
 		conf="optional"
 		confs="compile, runtime, test, provided, optional, compile-internal, runtime-internal, test-internal, plugin, sources, docs, pom, scala-tool"
-		date="20170427235408"/>
+		date="20170503175528"/>
 	<dependencies>
 	</dependencies>
 </ivy-report>
diff --git a/...resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-plugin.xml b/...resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-plugin.xml
@@ -7,7 +7,7 @@
 		revision="1.0-SNAPSHOT"
 		conf="plugin"
 		confs="compile, runtime, test, provided, optional, compile-internal, runtime-internal, test-internal, plugin, sources, docs, pom, scala-tool"
-		date="20170427235408"/>
+		date="20170503175528"/>
 	<dependencies>
 	</dependencies>
 </ivy-report>
diff --git a/...et/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-pom.xml b/...et/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-pom.xml
@@ -7,7 +7,7 @@
 		revision="1.0-SNAPSHOT"
 		conf="pom"
 		confs="compile, runtime, test, provided, optional, compile-internal, runtime-internal, test-internal, plugin, sources, docs, pom, scala-tool"
-		date="20170427235408"/>
+		date="20170503175528"/>
 	<dependencies>
 	</dependencies>
 </ivy-report>
diff --git a/...solution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-provided.xml b/...solution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-provided.xml
@@ -7,7 +7,7 @@
 		revision="1.0-SNAPSHOT"
 		conf="provided"
 		confs="compile, runtime, test, provided, optional, compile-internal, runtime-internal, test-internal, plugin, sources, docs, pom, scala-tool"
-		date="20170427235408"/>
+		date="20170503175528"/>
 	<dependencies>
 	</dependencies>
 </ivy-report>
diff --git a/...-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-runtime-internal.xml b/...-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-runtime-internal.xml
diff --git a/...esolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-runtime.xml b/...esolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-runtime.xml
diff --git a/...lution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-scala-tool.xml b/...lution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-scala-tool.xml
@@ -7,63 +7,63 @@
 		revision="1.0-SNAPSHOT"
 		conf="scala-tool"
 		confs="compile, runtime, test, provided, optional, compile-internal, runtime-internal, test-internal, plugin, sources, docs, pom, scala-tool"
-		date="20170427235408"/>
+		date="20170503175528"/>
 	<dependencies>
 		<module organisation="org.scala-lang" name="scala-compiler">
 			<revision name="2.11.7" status="release" pubdate="20150622221819" resolver="sbt-chain" artresolver="sbt-chain" homepage="http://www.scala-lang.org/" downloaded="false" searched="false" default="false" conf="default, compile, runtime, optional, optional(default), master" position="0">
 				<license name="BSD 3-Clause" url="http://www.scala-lang.org/license.html"/>
-				<metadata-artifact status="no" details="" size="3133" time="0" location="/Users/oguzgelal/.ivy2/cache/org.scala-lang/scala-compiler/ivy-2.11.7.xml" searched="false" origin-is-local="false" origin-location="https://repo1.maven.org/maven2/org/scala-lang/scala-compiler/2.11.7/scala-compiler-2.11.7.pom"/>
+				<metadata-artifact status="no" details="" size="3296" time="0" location="C:\Users\oskar\.ivy2\cache\org.scala-lang\scala-compiler\ivy-2.11.7.xml" searched="false" origin-is-local="false" origin-location="https://repo1.maven.org/maven2/org/scala-lang/scala-compiler/2.11.7/scala-compiler-2.11.7.pom"/>
 				<caller organisation="com.kanban" name="lagom-internal-meta-project-cassandra_2.11" conf="scala-tool" rev="2.11.7" rev-constraint-default="2.11.7" rev-constraint-dynamic="2.11.7" callerrev="1.0-SNAPSHOT"/>
 				<artifacts>
-					<artifact name="scala-compiler" type="jar" ext="jar" status="no" details="" size="15244851" time="0" location="/Users/oguzgelal/.ivy2/cache/org.scala-lang/scala-compiler/jars/scala-compiler-2.11.7.jar">
+					<artifact name="scala-compiler" type="jar" ext="jar" status="no" details="" size="15244851" time="0" location="C:\Users\oskar\.ivy2\cache\org.scala-lang\scala-compiler\jars\scala-compiler-2.11.7.jar">
 						<origin-location is-local="false" location="https://repo1.maven.org/maven2/org/scala-lang/scala-compiler/2.11.7/scala-compiler-2.11.7.jar"/>
 					</artifact>
 				</artifacts>
 			</revision>
 		</module>
 		<module organisation="jline" name="jline">
-			<revision name="2.12.1" status="release" pubdate="20150210015511" resolver="sbt-chain" artresolver="sbt-chain" homepage="" downloaded="false" searched="false" default="false" conf="compile, master(compile), compile(*), master" position="5">
+			<revision name="2.12.1" status="release" pubdate="20150209195511" resolver="sbt-chain" artresolver="sbt-chain" homepage="" downloaded="false" searched="false" default="false" conf="compile, master(compile), compile(*), master" position="5">
 				<license name="The BSD License" url="http://www.opensource.org/licenses/bsd-license.php"/>
-				<metadata-artifact status="no" details="" size="3901" time="0" location="/Users/oguzgelal/.ivy2/cache/jline/jline/ivy-2.12.1.xml" searched="false" origin-is-local="false" origin-location="https://repo1.maven.org/maven2/jline/jline/2.12.1/jline-2.12.1.pom"/>
+				<metadata-artifact status="no" details="" size="3891" time="0" location="C:\Users\oskar\.ivy2\cache\jline\jline\ivy-2.12.1.xml" searched="false" origin-is-local="false" origin-location="file:////C:/Activator/typesafe-activator-1.3.12/activator-dist-1.3.12/repository/jline/jline/2.12.1/ivys/ivy.xml"/>
 				<caller organisation="org.scala-lang" name="scala-compiler" conf="optional" rev="2.12.1" rev-constraint-default="2.12.1" rev-constraint-dynamic="2.12.1" callerrev="2.11.7"/>
 				<artifacts>
-					<artifact name="jline" type="jar" ext="jar" status="no" details="" size="213911" time="0" location="/Users/oguzgelal/.ivy2/cache/jline/jline/jars/jline-2.12.1.jar">
-						<origin-location is-local="false" location="https://repo1.maven.org/maven2/jline/jline/2.12.1/jline-2.12.1.jar"/>
+					<artifact name="jline" type="jar" ext="jar" status="no" details="" size="213911" time="0" location="C:\Users\oskar\.ivy2\cache\jline\jline\jars\jline-2.12.1.jar">
+						<origin-location is-local="false" location="file:////C:/Activator/typesafe-activator-1.3.12/activator-dist-1.3.12/repository/jline/jline/2.12.1/jars/jline.jar"/>
 					</artifact>
 				</artifacts>
 			</revision>
 		</module>
 		<module organisation="org.scala-lang.modules" name="scala-parser-combinators_2.11">
-			<revision name="1.0.4" status="release" pubdate="20150430160747" resolver="sbt-chain" artresolver="sbt-chain" homepage="http://www.scala-lang.org/" downloaded="false" searched="false" default="false" conf="compile, runtime(*), master(compile), runtime, compile(*), master" position="4">
+			<revision name="1.0.4" status="release" pubdate="20150430100747" resolver="sbt-chain" artresolver="sbt-chain" homepage="http://www.scala-lang.org/" downloaded="false" searched="false" default="false" conf="compile, runtime(*), master(compile), runtime, compile(*), master" position="4">
 				<license name="BSD 3-clause" url="http://opensource.org/licenses/BSD-3-Clause"/>
-				<metadata-artifact status="no" details="" size="2929" time="0" location="/Users/oguzgelal/.ivy2/cache/org.scala-lang.modules/scala-parser-combinators_2.11/ivy-1.0.4.xml" searched="false" origin-is-local="false" origin-location="https://repo1.maven.org/maven2/org/scala-lang/modules/scala-parser-combinators_2.11/1.0.4/scala-parser-combinators_2.11-1.0.4.pom"/>
+				<metadata-artifact status="no" details="" size="2920" time="0" location="C:\Users\oskar\.ivy2\cache\org.scala-lang.modules\scala-parser-combinators_2.11\ivy-1.0.4.xml" searched="false" origin-is-local="false" origin-location="file:////C:/Activator/typesafe-activator-1.3.12/activator-dist-1.3.12/repository/org.scala-lang.modules/scala-parser-combinators_2.11/1.0.4/ivys/ivy.xml"/>
 				<caller organisation="org.scala-lang" name="scala-compiler" conf="default, compile, runtime, optional, master" rev="1.0.4" rev-constraint-default="1.0.4" rev-constraint-dynamic="1.0.4" callerrev="2.11.7"/>
 				<artifacts>
-					<artifact name="scala-parser-combinators_2.11" type="bundle" ext="jar" status="no" details="" size="423753" time="0" location="/Users/oguzgelal/.ivy2/cache/org.scala-lang.modules/scala-parser-combinators_2.11/bundles/scala-parser-combinators_2.11-1.0.4.jar">
-						<origin-location is-local="false" location="https://repo1.maven.org/maven2/org/scala-lang/modules/scala-parser-combinators_2.11/1.0.4/scala-parser-combinators_2.11-1.0.4.jar"/>
+					<artifact name="scala-parser-combinators_2.11" type="bundle" ext="jar" status="no" details="" size="423753" time="0" location="C:\Users\oskar\.ivy2\cache\org.scala-lang.modules\scala-parser-combinators_2.11\bundles\scala-parser-combinators_2.11-1.0.4.jar">
+						<origin-location is-local="false" location="file:////C:/Activator/typesafe-activator-1.3.12/activator-dist-1.3.12/repository/org.scala-lang.modules/scala-parser-combinators_2.11/1.0.4/bundles/scala-parser-combinators_2.11.jar"/>
 					</artifact>
 				</artifacts>
 			</revision>
 		</module>
 		<module organisation="org.scala-lang.modules" name="scala-xml_2.11">
-			<revision name="1.0.4" status="release" pubdate="20150430155302" resolver="sbt-chain" artresolver="sbt-chain" homepage="http://www.scala-lang.org/" downloaded="false" searched="false" default="false" conf="compile, runtime(*), master(compile), runtime, compile(*), master" position="3">
+			<revision name="1.0.4" status="release" pubdate="20150430095302" resolver="sbt-chain" artresolver="sbt-chain" homepage="http://www.scala-lang.org/" downloaded="false" searched="false" default="false" conf="compile, runtime(*), master(compile), runtime, compile(*), master" position="3">
 				<license name="BSD 3-clause" url="http://opensource.org/licenses/BSD-3-Clause"/>
-				<metadata-artifact status="no" details="" size="3137" time="0" location="/Users/oguzgelal/.ivy2/cache/org.scala-lang.modules/scala-xml_2.11/ivy-1.0.4.xml" searched="false" origin-is-local="false" origin-location="https://repo1.maven.org/maven2/org/scala-lang/modules/scala-xml_2.11/1.0.4/scala-xml_2.11-1.0.4.pom"/>
+				<metadata-artifact status="no" details="" size="3128" time="0" location="C:\Users\oskar\.ivy2\cache\org.scala-lang.modules\scala-xml_2.11\ivy-1.0.4.xml" searched="false" origin-is-local="false" origin-location="file:////C:/Activator/typesafe-activator-1.3.12/activator-dist-1.3.12/repository/org.scala-lang.modules/scala-xml_2.11/1.0.4/ivys/ivy.xml"/>
 				<caller organisation="org.scala-lang" name="scala-compiler" conf="default, compile, runtime, optional, master" rev="1.0.4" rev-constraint-default="1.0.4" rev-constraint-dynamic="1.0.4" callerrev="2.11.7"/>
 				<artifacts>
-					<artifact name="scala-xml_2.11" type="bundle" ext="jar" status="no" details="" size="647891" time="0" location="/Users/oguzgelal/.ivy2/cache/org.scala-lang.modules/scala-xml_2.11/bundles/scala-xml_2.11-1.0.4.jar">
-						<origin-location is-local="false" location="https://repo1.maven.org/maven2/org/scala-lang/modules/scala-xml_2.11/1.0.4/scala-xml_2.11-1.0.4.jar"/>
+					<artifact name="scala-xml_2.11" type="bundle" ext="jar" status="no" details="" size="647891" time="0" location="C:\Users\oskar\.ivy2\cache\org.scala-lang.modules\scala-xml_2.11\bundles\scala-xml_2.11-1.0.4.jar">
+						<origin-location is-local="false" location="file:////C:/Activator/typesafe-activator-1.3.12/activator-dist-1.3.12/repository/org.scala-lang.modules/scala-xml_2.11/1.0.4/bundles/scala-xml_2.11.jar"/>
 					</artifact>
 				</artifacts>
 			</revision>
 		</module>
 		<module organisation="org.scala-lang" name="scala-reflect">
 			<revision name="2.11.7" status="release" pubdate="20150622221746" resolver="sbt-chain" artresolver="sbt-chain" homepage="http://www.scala-lang.org/" extra-info.apiURL="http://www.scala-lang.org/api/2.11.7/" downloaded="false" searched="false" default="false" conf="compile, runtime(*), master(compile), runtime, compile(*), master" position="2">
 				<license name="BSD 3-Clause" url="http://www.scala-lang.org/license.html"/>
-				<metadata-artifact status="no" details="" size="2825" time="0" location="/Users/oguzgelal/.ivy2/cache/org.scala-lang/scala-reflect/ivy-2.11.7.xml" searched="false" origin-is-local="false" origin-location="https://repo1.maven.org/maven2/org/scala-lang/scala-reflect/2.11.7/scala-reflect-2.11.7.pom"/>
+				<metadata-artifact status="no" details="" size="2860" time="0" location="C:\Users\oskar\.ivy2\cache\org.scala-lang\scala-reflect\ivy-2.11.7.xml" searched="false" origin-is-local="false" origin-location="https://repo1.maven.org/maven2/org/scala-lang/scala-reflect/2.11.7/scala-reflect-2.11.7.pom"/>
 				<caller organisation="org.scala-lang" name="scala-compiler" conf="default, compile, runtime, optional, master" rev="2.11.7" rev-constraint-default="2.11.7" rev-constraint-dynamic="2.11.7" callerrev="2.11.7"/>
 				<artifacts>
-					<artifact name="scala-reflect" type="jar" ext="jar" status="no" details="" size="4576443" time="0" location="/Users/oguzgelal/.ivy2/cache/org.scala-lang/scala-reflect/jars/scala-reflect-2.11.7.jar">
+					<artifact name="scala-reflect" type="jar" ext="jar" status="no" details="" size="4576443" time="0" location="C:\Users\oskar\.ivy2\cache\org.scala-lang\scala-reflect\jars\scala-reflect-2.11.7.jar">
 						<origin-location is-local="false" location="https://repo1.maven.org/maven2/org/scala-lang/scala-reflect/2.11.7/scala-reflect-2.11.7.jar"/>
 					</artifact>
 				</artifacts>
@@ -72,14 +72,14 @@
 		<module organisation="org.scala-lang" name="scala-library">
 			<revision name="2.11.7" status="release" pubdate="20150622221702" resolver="sbt-chain" artresolver="sbt-chain" homepage="http://www.scala-lang.org/" extra-info.apiURL="http://www.scala-lang.org/api/2.11.7/" downloaded="false" searched="false" default="false" conf="default, compile, runtime(*), master(compile), runtime, optional, optional(default), compile(*), master" position="1">
 				<license name="BSD 3-Clause" url="http://www.scala-lang.org/license.html"/>
-				<metadata-artifact status="no" details="" size="2653" time="0" location="/Users/oguzgelal/.ivy2/cache/org.scala-lang/scala-library/ivy-2.11.7.xml" searched="false" origin-is-local="false" origin-location="https://repo1.maven.org/maven2/org/scala-lang/scala-library/2.11.7/scala-library-2.11.7.pom"/>
+				<metadata-artifact status="no" details="" size="2685" time="0" location="C:\Users\oskar\.ivy2\cache\org.scala-lang\scala-library\ivy-2.11.7.xml" searched="false" origin-is-local="false" origin-location="https://repo1.maven.org/maven2/org/scala-lang/scala-library/2.11.7/scala-library-2.11.7.pom"/>
 				<caller organisation="org.scala-lang" name="scala-reflect" conf="compile, runtime" rev="2.11.7" rev-constraint-default="2.11.7" rev-constraint-dynamic="2.11.7" callerrev="2.11.7"/>
 				<caller organisation="org.scala-lang.modules" name="scala-parser-combinators_2.11" conf="compile, runtime" rev="2.11.7" rev-constraint-default="2.11.7" rev-constraint-dynamic="2.11.7" callerrev="1.0.4"/>
 				<caller organisation="com.kanban" name="lagom-internal-meta-project-cassandra_2.11" conf="scala-tool" rev="2.11.7" rev-constraint-default="2.11.7" rev-constraint-dynamic="2.11.7" callerrev="1.0-SNAPSHOT"/>
 				<caller organisation="org.scala-lang" name="scala-compiler" conf="default, compile, runtime, optional, master" rev="2.11.7" rev-constraint-default="2.11.7" rev-constraint-dynamic="2.11.7" callerrev="2.11.7"/>
 				<caller organisation="org.scala-lang.modules" name="scala-xml_2.11" conf="compile, runtime" rev="2.11.7" rev-constraint-default="2.11.7" rev-constraint-dynamic="2.11.7" callerrev="1.0.4"/>
 				<artifacts>
-					<artifact name="scala-library" type="jar" ext="jar" status="no" details="" size="5745606" time="0" location="/Users/oguzgelal/.ivy2/cache/org.scala-lang/scala-library/jars/scala-library-2.11.7.jar">
+					<artifact name="scala-library" type="jar" ext="jar" status="no" details="" size="5745606" time="0" location="C:\Users\oskar\.ivy2\cache\org.scala-lang\scala-library\jars\scala-library-2.11.7.jar">
 						<origin-location is-local="false" location="https://repo1.maven.org/maven2/org/scala-lang/scala-library/2.11.7/scala-library-2.11.7.jar"/>
 					</artifact>
 				</artifacts>

diff --git a/...esolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-sources.xml b/...esolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-sources.xml
@@ -7,7 +7,7 @@
 		revision="1.0-SNAPSHOT"
 		conf="sources"
 		confs="compile, runtime, test, provided, optional, compile-internal, runtime-internal, test-internal, plugin, sources, docs, pom, scala-tool"
-		date="20170427235408"/>
+		date="20170503175528"/>
 	<dependencies>
 	</dependencies>
 </ivy-report>
diff --git a/...ion-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-test-internal.xml b/...ion-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-test-internal.xml
diff --git a/...t/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-test.xml b/...t/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-test.xml
diff --git a/...s/lagom-internal-meta-project-cassandra/target/streams/$global/update/$global/streams/out b/...s/lagom-internal-meta-project-cassandra/target/streams/$global/update/$global/streams/out
@@ -1,4 +1,4 @@
-[0m[[0minfo[0m] [0mUpdating {file:/Users/oguzgelal/Core/Oguz/web/LATEST/kanban/}lagom-internal-meta-project-cassandra...[0m
+[0m[[0minfo[0m] [0mUpdating {file:/C:/kanban/}lagom-internal-meta-project-cassandra...[0m
 [0m[[0mdebug[0m] [0m:: resolving dependencies :: com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT[0m
 [0m[[0mdebug[0m] [0m	confs: [compile, runtime, test, provided, optional, compile-internal, runtime-internal, test-internal, plugin, sources, docs, pom, scala-tool][0m
 [0m[[0mdebug[0m] [0m	validate = true[0m
@@ -13398,19 +13398,19 @@
 [0m[[0mdebug[0m] [0m	[NOT REQUIRED] org.scala-lang#scala-reflect;2.11.7!scala-reflect.jar[0m
 [0m[[0mdebug[0m] [0m	[NOT REQUIRED] org.scala-lang.modules#scala-xml_2.11;1.0.4!scala-xml_2.11.jar(bundle)[0m
 [0m[[0mdebug[0m] [0m	[NOT REQUIRED] jline#jline;2.12.1!jline.jar[0m
-[0m[[0mdebug[0m] [0m:: resolution report :: resolve 2106ms :: artifacts dl 38ms[0m
-[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT compile produced in /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/lagom-dynamic-projects/lagom-internal-meta-project-cassandra/target/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-compile.xml[0m
-[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT runtime produced in /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/lagom-dynamic-projects/lagom-internal-meta-project-cassandra/target/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-runtime.xml[0m
-[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT test produced in /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/lagom-dynamic-projects/lagom-internal-meta-project-cassandra/target/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-test.xml[0m
-[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT provided produced in /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/lagom-dynamic-projects/lagom-internal-meta-project-cassandra/target/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-provided.xml[0m
-[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT optional produced in /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/lagom-dynamic-projects/lagom-internal-meta-project-cassandra/target/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-optional.xml[0m
-[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT compile-internal produced in /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/lagom-dynamic-projects/lagom-internal-meta-project-cassandra/target/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-compile-internal.xml[0m
-[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT runtime-internal produced in /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/lagom-dynamic-projects/lagom-internal-meta-project-cassandra/target/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-runtime-internal.xml[0m
-[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT test-internal produced in /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/lagom-dynamic-projects/lagom-internal-meta-project-cassandra/target/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-test-internal.xml[0m
-[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT plugin produced in /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/lagom-dynamic-projects/lagom-internal-meta-project-cassandra/target/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-plugin.xml[0m
-[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT sources produced in /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/lagom-dynamic-projects/lagom-internal-meta-project-cassandra/target/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-sources.xml[0m
-[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT docs produced in /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/lagom-dynamic-projects/lagom-internal-meta-project-cassandra/target/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-docs.xml[0m
-[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT pom produced in /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/lagom-dynamic-projects/lagom-internal-meta-project-cassandra/target/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-pom.xml[0m
-[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT scala-tool produced in /Users/oguzgelal/Core/Oguz/web/LATEST/kanban/target/lagom-dynamic-projects/lagom-internal-meta-project-cassandra/target/resolution-cache/reports/com.kanban-lagom-internal-meta-project-cassandra_2.11-scala-tool.xml[0m
-[0m[[0mdebug[0m] [0m	resolve done (2106ms resolve - 38ms download)[0m
+[0m[[0mdebug[0m] [0m:: resolution report :: resolve 5772ms :: artifacts dl 192ms[0m
+[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT compile produced in C:\kanban\target\lagom-dynamic-projects\lagom-internal-meta-project-cassandra\target\resolution-cache\reports\com.kanban-lagom-internal-meta-project-cassandra_2.11-compile.xml[0m
+[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT runtime produced in C:\kanban\target\lagom-dynamic-projects\lagom-internal-meta-project-cassandra\target\resolution-cache\reports\com.kanban-lagom-internal-meta-project-cassandra_2.11-runtime.xml[0m
+[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT test produced in C:\kanban\target\lagom-dynamic-projects\lagom-internal-meta-project-cassandra\target\resolution-cache\reports\com.kanban-lagom-internal-meta-project-cassandra_2.11-test.xml[0m
+[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT provided produced in C:\kanban\target\lagom-dynamic-projects\lagom-internal-meta-project-cassandra\target\resolution-cache\reports\com.kanban-lagom-internal-meta-project-cassandra_2.11-provided.xml[0m
+[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT optional produced in C:\kanban\target\lagom-dynamic-projects\lagom-internal-meta-project-cassandra\target\resolution-cache\reports\com.kanban-lagom-internal-meta-project-cassandra_2.11-optional.xml[0m
+[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT compile-internal produced in C:\kanban\target\lagom-dynamic-projects\lagom-internal-meta-project-cassandra\target\resolution-cache\reports\com.kanban-lagom-internal-meta-project-cassandra_2.11-compile-internal.xml[0m
+[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT runtime-internal produced in C:\kanban\target\lagom-dynamic-projects\lagom-internal-meta-project-cassandra\target\resolution-cache\reports\com.kanban-lagom-internal-meta-project-cassandra_2.11-runtime-internal.xml[0m
+[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT test-internal produced in C:\kanban\target\lagom-dynamic-projects\lagom-internal-meta-project-cassandra\target\resolution-cache\reports\com.kanban-lagom-internal-meta-project-cassandra_2.11-test-internal.xml[0m
+[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT plugin produced in C:\kanban\target\lagom-dynamic-projects\lagom-internal-meta-project-cassandra\target\resolution-cache\reports\com.kanban-lagom-internal-meta-project-cassandra_2.11-plugin.xml[0m
+[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT sources produced in C:\kanban\target\lagom-dynamic-projects\lagom-internal-meta-project-cassandra\target\resolution-cache\reports\com.kanban-lagom-internal-meta-project-cassandra_2.11-sources.xml[0m
+[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT docs produced in C:\kanban\target\lagom-dynamic-projects\lagom-internal-meta-project-cassandra\target\resolution-cache\reports\com.kanban-lagom-internal-meta-project-cassandra_2.11-docs.xml[0m
+[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT pom produced in C:\kanban\target\lagom-dynamic-projects\lagom-internal-meta-project-cassandra\target\resolution-cache\reports\com.kanban-lagom-internal-meta-project-cassandra_2.11-pom.xml[0m
+[0m[[0mdebug[0m] [0m	report for com.kanban#lagom-internal-meta-project-cassandra_2.11;1.0-SNAPSHOT scala-tool produced in C:\kanban\target\lagom-dynamic-projects\lagom-internal-meta-project-cassandra\target\resolution-cache\reports\com.kanban-lagom-internal-meta-project-cassandra_2.11-scala-tool.xml[0m
+[0m[[0mdebug[0m] [0m	resolve done (5772ms resolve - 192ms download)[0m
 [0m[[0minfo[0m] [0mDone updating.[0m
diff --git a/...-project-cassandra/target/streams/$global/update/$global/streams/update_cache_2.11/inputs b/...-project-cassandra/target/streams/$global/update/$global/streams/update_cache_2.11/inputs
diff --git a/...-project-cassandra/target/streams/$global/update/$global/streams/update_cache_2.11/output b/...-project-cassandra/target/streams/$global/update/$global/streams/update_cache_2.11/output
diff --git a/...nal-meta-project-cassandra/target/streams/compile/managedClasspath/$global/streams/export b/...nal-meta-project-cassandra/target/streams/compile/managedClasspath/$global/streams/export
@@ -1 +1 @@
-/Users/oguzgelal/.ivy2/cache/org.scala-lang/scala-library/jars/scala-library-2.11.7.jar:/Users/oguzgelal/.ivy2/cache/com.lightbend.lagom/lagom-cassandra-server_2.11/jars/lagom-cassandra-server_2.11-1.3.2.jar:/Users/oguzgelal/.ivy2/cache/com.typesafe.akka/akka-persistence-cassandra_2.11/bundles/akka-persistence-cassandra_2.11-0.22.jar:/Users/oguzgelal/.ivy2/cache/com.datastax.cassandra/cassandra-driver-core/bundles/cassandra-driver-core-3.1.0.jar:/Users/oguzgelal/.ivy2/cache/io.dropwizard.metrics/metrics-core/bundles/metrics-core-3.1.2.jar:/Users/oguzgelal/.ivy2/cache/org.slf4j/slf4j-api/jars/slf4j-api-1.7.7.jar:/Users/oguzgelal/.ivy2/cache/com.github.jnr/jnr-ffi/jars/jnr-ffi-2.0.7.jar:/Users/oguzgelal/.ivy2/cache/com.github.jnr/jffi/jars/jffi-1.2.10.jar:/Users/oguzgelal/.ivy2/cache/com.github.jnr/jffi/jars/jffi-1.2.10-native.jar:/Users/oguzgelal/.ivy2/cache/org.ow2.asm/asm/jars/asm-5.0.3.jar:/Users/oguzgelal/.ivy2/cache/org.ow2.asm/asm-commons/jars/asm-commons-5.0.3.jar:/Users/oguzgelal/.ivy2/cache/org.ow2.asm/asm-tree/jars/asm-tree-5.0.3.jar:/Users/oguzgelal/.ivy2/cache/org.ow2.asm/asm-analysis/jars/asm-analysis-5.0.3.jar:/Users/oguzgelal/.ivy2/cache/org.ow2.asm/asm-util/jars/asm-util-5.0.3.jar:/Users/oguzgelal/.ivy2/cache/com.github.jnr/jnr-x86asm/jars/jnr-x86asm-1.0.2.jar:/Users/oguzgelal/.ivy2/cache/com.github.jnr/jnr-posix/jars/jnr-posix-3.0.27.jar:/Users/oguzgelal/.ivy2/cache/com.github.jnr/jnr-constants/jars/jnr-constants-0.9.0.jar:/Users/oguzgelal/.ivy2/cache/com.typesafe.akka/akka-persistence_2.11/jars/akka-persistence_2.11-2.4.14.jar:/Users/oguzgelal/.ivy2/cache/com.typesafe.akka/akka-actor_2.11/jars/akka-actor_2.11-2.4.14.jar:/Users/oguzgelal/.ivy2/cache/com.typesafe/config/bundles/config-1.3.0.jar:/Users/oguzgelal/.ivy2/cache/org.scala-lang.modules/scala-java8-compat_2.11/bundles/scala-java8-compat_2.11-0.7.0.jar:/Users/oguzgelal/.ivy2/cache/com.typesafe.akka/akka-protobuf_2.11/jars/akka-protobuf_2.11-2.4.14.jar:/Users/oguzgelal/.ivy2/cache/com.typesafe.akka/akka-cluster-tools_2.11/jars/akka-cluster-tools_2.11-2.4.14.jar:/Users/oguzgelal/.ivy2/cache/com.typesafe.akka/akka-cluster_2.11/jars/akka-cluster_2.11-2.4.14.jar:/Users/oguzgelal/.ivy2/cache/com.typesafe.akka/akka-remote_2.11/jars/akka-remote_2.11-2.4.14.jar:/Users/oguzgelal/.ivy2/cache/com.typesafe.akka/akka-stream_2.11/jars/akka-stream_2.11-2.4.14.jar:/Users/oguzgelal/.ivy2/cache/org.reactivestreams/reactive-streams/jars/reactive-streams-1.0.0.jar:/Users/oguzgelal/.ivy2/cache/com.typesafe/ssl-config-core_2.11/bundles/ssl-config-core_2.11-0.2.1.jar:/Users/oguzgelal/.ivy2/cache/org.scala-lang.modules/scala-parser-combinators_2.11/bundles/scala-parser-combinators_2.11-1.0.4.jar:/Users/oguzgelal/.ivy2/cache/io.netty/netty/bundles/netty-3.10.6.Final.jar:/Users/oguzgelal/.ivy2/cache/org.uncommons.maths/uncommons-maths/jars/uncommons-maths-1.2.2a.jar:/Users/oguzgelal/.ivy2/cache/io.aeron/aeron-driver/jars/aeron-driver-1.0.4.jar:/Users/oguzgelal/.ivy2/cache/io.aeron/aeron-client/jars/aeron-client-1.0.4.jar:/Users/oguzgelal/.ivy2/cache/org.agrona/Agrona/jars/Agrona-0.9.0.jar:/Users/oguzgelal/.ivy2/cache/com.typesafe.akka/akka-persistence-query-experimental_2.11/jars/akka-persistence-query-experimental_2.11-2.4.14.jar:/Users/oguzgelal/.ivy2/cache/com.typesafe.akka/akka-testkit_2.11/jars/akka-testkit_2.11-2.4.14.jar:/Users/oguzgelal/.ivy2/cache/com.typesafe.akka/akka-stream-testkit_2.11/jars/akka-stream-testkit_2.11-2.4.14.jar:/Users/oguzgelal/.ivy2/cache/org.apache.cassandra/cassandra-all/jars/cassandra-all-3.0.9.jar:/Users/oguzgelal/.ivy2/cache/org.xerial.snappy/snappy-java/bundles/snappy-java-1.1.1.7.jar:/Users/oguzgelal/.ivy2/cache/net.jpountz.lz4/lz4/jars/lz4-1.3.0.jar:/Users/oguzgelal/.ivy2/cache/com.ning/compress-lzf/bundles/compress-lzf-0.8.4.jar:/Users/oguzgelal/.ivy2/cache/com.google.guava/guava/bundles/guava-18.0.jar:/Users/oguzgelal/.ivy2/cache/commons-cli/commons-cli/jars/commons-cli-1.1.jar:/Users/oguzgelal/.ivy2/cache/commons-codec/commons-codec/jars/commons-codec-1.2.jar:/Users/oguzgelal/.ivy2/cache/org.apache.commons/commons-lang3/jars/commons-lang3-3.1.jar:/Users/oguzgelal/.ivy2/cache/org.apache.commons/commons-math3/jars/commons-math3-3.2.jar:/Users/oguzgelal/.ivy2/cache/com.googlecode.concurrentlinkedhashmap/concurrentlinkedhashmap-lru/jars/concurrentlinkedhashmap-lru-1.4.jar:/Users/oguzgelal/.ivy2/cache/org.antlr/antlr/jars/antlr-3.5.2.jar:/Users/oguzgelal/.ivy2/cache/org.antlr/antlr-runtime/jars/antlr-runtime-3.5.2.jar:/Users/oguzgelal/.ivy2/cache/org.antlr/ST4/jars/ST4-4.0.8.jar:/Users/oguzgelal/.ivy2/cache/org.slf4j/log4j-over-slf4j/jars/log4j-over-slf4j-1.7.7.jar:/Users/oguzgelal/.ivy2/cache/org.slf4j/jcl-over-slf4j/jars/jcl-over-slf4j-1.7.7.jar:/Users/oguzgelal/.ivy2/cache/org.codehaus.jackson/jackson-core-asl/jars/jackson-core-asl-1.9.2.jar:/Users/oguzgelal/.ivy2/cache/org.codehaus.jackson/jackson-mapper-asl/jars/jackson-mapper-asl-1.9.2.jar:/Users/oguzgelal/.ivy2/cache/com.googlecode.json-simple/json-simple/jars/json-simple-1.1.jar:/Users/oguzgelal/.ivy2/cache/com.boundary/high-scale-lib/jars/high-scale-lib-1.0.6.jar:/Users/oguzgelal/.ivy2/cache/org.yaml/snakeyaml/bundles/snakeyaml-1.11.jar:/Users/oguzgelal/.ivy2/cache/org.mindrot/jbcrypt/jars/jbcrypt-0.3m.jar:/Users/oguzgelal/.ivy2/cache/io.dropwizard.metrics/metrics-jvm/bundles/metrics-jvm-3.1.0.jar:/Users/oguzgelal/.ivy2/cache/com.addthis.metrics/reporter-config3/jars/reporter-config3-3.0.0.jar:/Users/oguzgelal/.ivy2/cache/com.addthis.metrics/reporter-config-base/jars/reporter-config-base-3.0.0.jar:/Users/oguzgelal/.ivy2/cache/org.hibernate/hibernate-validator/jars/hibernate-validator-4.3.0.Final.jar:/Users/oguzgelal/.ivy2/cache/javax.validation/validation-api/jars/validation-api-1.0.0.GA.jar:/Users/oguzgelal/.ivy2/cache/org.jboss.logging/jboss-logging/jars/jboss-logging-3.1.0.CR2.jar:/Users/oguzgelal/.ivy2/cache/com.thinkaurelius.thrift/thrift-server/jars/thrift-server-0.3.7.jar:/Users/oguzgelal/.ivy2/cache/com.lmax/disruptor/jars/disruptor-3.0.1.jar:/Users/oguzgelal/.ivy2/cache/org.apache.thrift/libthrift/jars/libthrift-0.9.2.jar:/Users/oguzgelal/.ivy2/cache/org.apache.httpcomponents/httpclient/jars/httpclient-4.2.5.jar:/Users/oguzgelal/.ivy2/cache/org.apache.httpcomponents/httpcore/jars/httpcore-4.2.4.jar:/Users/oguzgelal/.ivy2/cache/commons-logging/commons-logging/jars/commons-logging-1.1.1.jar:/Users/oguzgelal/.ivy2/cache/junit/junit/jars/junit-4.8.1.jar:/Users/oguzgelal/.ivy2/cache/com.clearspring.analytics/stream/jars/stream-2.5.2.jar:/Users/oguzgelal/.ivy2/cache/it.unimi.dsi/fastutil/jars/fastutil-6.5.7.jar:/Users/oguzgelal/.ivy2/cache/ch.qos.logback/logback-core/jars/logback-core-1.1.3.jar:/Users/oguzgelal/.ivy2/cache/ch.qos.logback/logback-classic/jars/logback-classic-1.1.3.jar:/Users/oguzgelal/.ivy2/cache/org.apache.cassandra/cassandra-thrift/jars/cassandra-thrift-3.0.9.jar:/Users/oguzgelal/.ivy2/cache/net.java.dev.jna/jna/jars/jna-4.0.0.jar:/Users/oguzgelal/.ivy2/cache/com.github.jbellis/jamm/jars/jamm-0.3.0.jar:/Users/oguzgelal/.ivy2/cache/io.netty/netty-all/jars/netty-all-4.0.23.Final.jar:/Users/oguzgelal/.ivy2/cache/joda-time/joda-time/jars/joda-time-2.4.jar:/Users/oguzgelal/.ivy2/cache/org.fusesource/sigar/jars/sigar-1.6.4.jar:/Users/oguzgelal/.ivy2/cache/org.eclipse.jdt.core.compiler/ecj/jars/ecj-4.4.2.jar:/Users/oguzgelal/.ivy2/cache/org.caffinitas.ohc/ohc-core/jars/ohc-core-0.4.3.jar
+C:\Users\oskar\.ivy2\cache\org.scala-lang\scala-library\jars\scala-library-2.11.7.jar;C:\Users\oskar\.ivy2\cache\com.lightbend.lagom\lagom-cassandra-server_2.11\jars\lagom-cassandra-server_2.11-1.3.2.jar;C:\Users\oskar\.ivy2\cache\com.typesafe.akka\akka-persistence-cassandra_2.11\bundles\akka-persistence-cassandra_2.11-0.22.jar;C:\Users\oskar\.ivy2\cache\com.datastax.cassandra\cassandra-driver-core\bundles\cassandra-driver-core-3.1.0.jar;C:\Users\oskar\.ivy2\cache\io.dropwizard.metrics\metrics-core\bundles\metrics-core-3.1.2.jar;C:\Users\oskar\.ivy2\cache\org.slf4j\slf4j-api\jars\slf4j-api-1.7.7.jar;C:\Users\oskar\.ivy2\cache\com.github.jnr\jnr-ffi\jars\jnr-ffi-2.0.7.jar;C:\Users\oskar\.ivy2\cache\com.github.jnr\jffi\jars\jffi-1.2.10.jar;C:\Users\oskar\.ivy2\cache\com.github.jnr\jffi\jars\jffi-1.2.10-native.jar;C:\Users\oskar\.ivy2\cache\org.ow2.asm\asm\jars\asm-5.0.3.jar;C:\Users\oskar\.ivy2\cache\org.ow2.asm\asm-commons\jars\asm-commons-5.0.3.jar;C:\Users\oskar\.ivy2\cache\org.ow2.asm\asm-tree\jars\asm-tree-5.0.3.jar;C:\Users\oskar\.ivy2\cache\org.ow2.asm\asm-analysis\jars\asm-analysis-5.0.3.jar;C:\Users\oskar\.ivy2\cache\org.ow2.asm\asm-util\jars\asm-util-5.0.3.jar;C:\Users\oskar\.ivy2\cache\com.github.jnr\jnr-x86asm\jars\jnr-x86asm-1.0.2.jar;C:\Users\oskar\.ivy2\cache\com.github.jnr\jnr-posix\jars\jnr-posix-3.0.27.jar;C:\Users\oskar\.ivy2\cache\com.github.jnr\jnr-constants\jars\jnr-constants-0.9.0.jar;C:\Users\oskar\.ivy2\cache\com.typesafe.akka\akka-persistence_2.11\jars\akka-persistence_2.11-2.4.14.jar;C:\Users\oskar\.ivy2\cache\com.typesafe.akka\akka-actor_2.11\jars\akka-actor_2.11-2.4.14.jar;C:\Users\oskar\.ivy2\cache\com.typesafe\config\bundles\config-1.3.0.jar;C:\Users\oskar\.ivy2\cache\org.scala-lang.modules\scala-java8-compat_2.11\bundles\scala-java8-compat_2.11-0.7.0.jar;C:\Users\oskar\.ivy2\cache\com.typesafe.akka\akka-protobuf_2.11\jars\akka-protobuf_2.11-2.4.14.jar;C:\Users\oskar\.ivy2\cache\com.typesafe.akka\akka-cluster-tools_2.11\jars\akka-cluster-tools_2.11-2.4.14.jar;C:\Users\oskar\.ivy2\cache\com.typesafe.akka\akka-cluster_2.11\jars\akka-cluster_2.11-2.4.14.jar;C:\Users\oskar\.ivy2\cache\com.typesafe.akka\akka-remote_2.11\jars\akka-remote_2.11-2.4.14.jar;C:\Users\oskar\.ivy2\cache\com.typesafe.akka\akka-stream_2.11\jars\akka-stream_2.11-2.4.14.jar;C:\Users\oskar\.ivy2\cache\org.reactivestreams\reactive-streams\jars\reactive-streams-1.0.0.jar;C:\Users\oskar\.ivy2\cache\com.typesafe\ssl-config-core_2.11\bundles\ssl-config-core_2.11-0.2.1.jar;C:\Users\oskar\.ivy2\cache\org.scala-lang.modules\scala-parser-combinators_2.11\bundles\scala-parser-combinators_2.11-1.0.4.jar;C:\Users\oskar\.ivy2\cache\io.netty\netty\bundles\netty-3.10.6.Final.jar;C:\Users\oskar\.ivy2\cache\org.uncommons.maths\uncommons-maths\jars\uncommons-maths-1.2.2a.jar;C:\Users\oskar\.ivy2\cache\io.aeron\aeron-driver\jars\aeron-driver-1.0.4.jar;C:\Users\oskar\.ivy2\cache\io.aeron\aeron-client\jars\aeron-client-1.0.4.jar;C:\Users\oskar\.ivy2\cache\org.agrona\Agrona\jars\Agrona-0.9.0.jar;C:\Users\oskar\.ivy2\cache\com.typesafe.akka\akka-persistence-query-experimental_2.11\jars\akka-persistence-query-experimental_2.11-2.4.14.jar;C:\Users\oskar\.ivy2\cache\com.typesafe.akka\akka-testkit_2.11\jars\akka-testkit_2.11-2.4.14.jar;C:\Users\oskar\.ivy2\cache\com.typesafe.akka\akka-stream-testkit_2.11\jars\akka-stream-testkit_2.11-2.4.14.jar;C:\Users\oskar\.ivy2\cache\org.apache.cassandra\cassandra-all\jars\cassandra-all-3.0.9.jar;C:\Users\oskar\.ivy2\cache\org.xerial.snappy\snappy-java\bundles\snappy-java-1.1.1.7.jar;C:\Users\oskar\.ivy2\cache\net.jpountz.lz4\lz4\jars\lz4-1.3.0.jar;C:\Users\oskar\.ivy2\cache\com.ning\compress-lzf\bundles\compress-lzf-0.8.4.jar;C:\Users\oskar\.ivy2\cache\com.google.guava\guava\bundles\guava-18.0.jar;C:\Users\oskar\.ivy2\cache\commons-cli\commons-cli\jars\commons-cli-1.1.jar;C:\Users\oskar\.ivy2\cache\commons-codec\commons-codec\jars\commons-codec-1.2.jar;C:\Users\oskar\.ivy2\cache\org.apache.commons\commons-lang3\jars\commons-lang3-3.1.jar;C:\Users\oskar\.ivy2\cache\org.apache.commons\commons-math3\jars\commons-math3-3.2.jar;C:\Users\oskar\.ivy2\cache\com.googlecode.concurrentlinkedhashmap\concurrentlinkedhashmap-lru\jars\concurrentlinkedhashmap-lru-1.4.jar;C:\Users\oskar\.ivy2\cache\org.antlr\antlr\jars\antlr-3.5.2.jar;C:\Users\oskar\.ivy2\cache\org.antlr\antlr-runtime\jars\antlr-runtime-3.5.2.jar;C:\Users\oskar\.ivy2\cache\org.antlr\ST4\jars\ST4-4.0.8.jar;C:\Users\oskar\.ivy2\cache\org.slf4j\log4j-over-slf4j\jars\log4j-over-slf4j-1.7.7.jar;C:\Users\oskar\.ivy2\cache\org.slf4j\jcl-over-slf4j\jars\jcl-over-slf4j-1.7.7.jar;C:\Users\oskar\.ivy2\cache\org.codehaus.jackson\jackson-core-asl\jars\jackson-core-asl-1.9.2.jar;C:\Users\oskar\.ivy2\cache\org.codehaus.jackson\jackson-mapper-asl\jars\jackson-mapper-asl-1.9.2.jar;C:\Users\oskar\.ivy2\cache\com.googlecode.json-simple\json-simple\jars\json-simple-1.1.jar;C:\Users\oskar\.ivy2\cache\com.boundary\high-scale-lib\jars\high-scale-lib-1.0.6.jar;C:\Users\oskar\.ivy2\cache\org.yaml\snakeyaml\bundles\snakeyaml-1.11.jar;C:\Users\oskar\.ivy2\cache\org.mindrot\jbcrypt\jars\jbcrypt-0.3m.jar;C:\Users\oskar\.ivy2\cache\io.dropwizard.metrics\metrics-jvm\bundles\metrics-jvm-3.1.0.jar;C:\Users\oskar\.ivy2\cache\com.addthis.metrics\reporter-config3\jars\reporter-config3-3.0.0.jar;C:\Users\oskar\.ivy2\cache\com.addthis.metrics\reporter-config-base\jars\reporter-config-base-3.0.0.jar;C:\Users\oskar\.ivy2\cache\org.hibernate\hibernate-validator\jars\hibernate-validator-4.3.0.Final.jar;C:\Users\oskar\.ivy2\cache\javax.validation\validation-api\jars\validation-api-1.0.0.GA.jar;C:\Users\oskar\.ivy2\cache\org.jboss.logging\jboss-logging\jars\jboss-logging-3.1.0.CR2.jar;C:\Users\oskar\.ivy2\cache\com.thinkaurelius.thrift\thrift-server\jars\thrift-server-0.3.7.jar;C:\Users\oskar\.ivy2\cache\com.lmax\disruptor\jars\disruptor-3.0.1.jar;C:\Users\oskar\.ivy2\cache\org.apache.thrift\libthrift\jars\libthrift-0.9.2.jar;C:\Users\oskar\.ivy2\cache\org.apache.httpcomponents\httpclient\jars\httpclient-4.2.5.jar;C:\Users\oskar\.ivy2\cache\org.apache.httpcomponents\httpcore\jars\httpcore-4.2.4.jar;C:\Users\oskar\.ivy2\cache\commons-logging\commons-logging\jars\commons-logging-1.1.1.jar;C:\Users\oskar\.ivy2\cache\junit\junit\jars\junit-4.8.1.jar;C:\Users\oskar\.ivy2\cache\com.clearspring.analytics\stream\jars\stream-2.5.2.jar;C:\Users\oskar\.ivy2\cache\it.unimi.dsi\fastutil\jars\fastutil-6.5.7.jar;C:\Users\oskar\.ivy2\cache\ch.qos.logback\logback-core\jars\logback-core-1.1.3.jar;C:\Users\oskar\.ivy2\cache\ch.qos.logback\logback-classic\jars\logback-classic-1.1.3.jar;C:\Users\oskar\.ivy2\cache\org.apache.cassandra\cassandra-thrift\jars\cassandra-thrift-3.0.9.jar;C:\Users\oskar\.ivy2\cache\net.java.dev.jna\jna\jars\jna-4.0.0.jar;C:\Users\oskar\.ivy2\cache\com.github.jbellis\jamm\jars\jamm-0.3.0.jar;C:\Users\oskar\.ivy2\cache\io.netty\netty-all\jars\netty-all-4.0.23.Final.jar;C:\Users\oskar\.ivy2\cache\joda-time\joda-time\jars\joda-time-2.4.jar;C:\Users\oskar\.ivy2\cache\org.fusesource\sigar\jars\sigar-1.6.4.jar;C:\Users\oskar\.ivy2\cache\org.eclipse.jdt.core.compiler\ecj\jars\ecj-4.4.2.jar;C:\Users\oskar\.ivy2\cache\org.caffinitas.ohc\ohc-core\jars\ohc-core-0.4.3.jar
diff --git a/...gom-dynamic-projects/lagom-internal-meta-project-kafka/target/log4j_output/controller.log b/...gom-dynamic-projects/lagom-internal-meta-project-kafka/target/log4j_output/controller.log
@@ -1,55 +1,13 @@
-[2017-04-28 14:11:57,884] INFO [SessionExpirationListener on 0], ZK expired; shut down all controller components and try to re-elect (kafka.controller.KafkaController$SessionExpirationListener)
-[2017-04-28 14:11:57,971] DEBUG [Controller 0]: Controller resigning, broker id 0 (kafka.controller.KafkaController)
-[2017-04-28 14:11:57,971] DEBUG [Controller 0]: De-registering IsrChangeNotificationListener (kafka.controller.KafkaController)
-[2017-04-28 14:11:57,990] INFO [Partition state machine on Controller 0]: Stopped partition state machine (kafka.controller.PartitionStateMachine)
-[2017-04-28 14:11:57,991] INFO [Replica state machine on controller 0]: Stopped replica state machine (kafka.controller.ReplicaStateMachine)
-[2017-04-28 14:11:57,995] INFO [Controller-0-to-broker-0-send-thread], Shutting down (kafka.controller.RequestSendThread)
-[2017-04-28 14:11:57,996] INFO [Controller-0-to-broker-0-send-thread], Stopped  (kafka.controller.RequestSendThread)
-[2017-04-28 14:11:57,996] INFO [Controller-0-to-broker-0-send-thread], Shutdown completed (kafka.controller.RequestSendThread)
-[2017-04-28 14:11:57,997] INFO [Controller 0]: Broker 0 resigned as the controller (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,077] INFO [Controller 0]: Broker 0 starting become controller state transition (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,079] INFO [Controller 0]: Initialized controller epoch to 5 and zk version 4 (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,091] INFO [Controller 0]: Controller 0 incremented epoch to 6 (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,094] DEBUG [Controller 0]: Registering IsrChangeNotificationListener (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,099] INFO [Controller 0]: Partitions undergoing preferred replica election:  (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,099] INFO [Controller 0]: Partitions that completed preferred replica election:  (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,099] INFO [Controller 0]: Resuming preferred replica election for partitions:  (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,100] INFO [Controller 0]: Partitions being reassigned: Map() (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,100] INFO [Controller 0]: Partitions already reassigned: List() (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,100] INFO [Controller 0]: Resuming reassignment of partitions: Map() (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,101] INFO [Controller 0]: List of topics to be deleted:  (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,101] INFO [Controller 0]: List of topics ineligible for deletion:  (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,101] INFO [Controller 0]: Currently active brokers in the cluster: Set() (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,101] INFO [Controller 0]: Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,101] INFO [Controller 0]: Current list of topics in the cluster: Set() (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,102] INFO [Replica state machine on controller 0]: Started replica state machine with initial state -> Map() (kafka.controller.ReplicaStateMachine)
-[2017-04-28 14:11:58,102] INFO [Partition state machine on Controller 0]: Started partition state machine with initial state -> Map() (kafka.controller.PartitionStateMachine)
-[2017-04-28 14:11:58,102] INFO [Controller 0]: Broker 0 is ready to serve as the new controller with epoch 6 (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,102] INFO [Controller 0]: Starting preferred replica leader election for partitions  (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,102] INFO [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions  (kafka.controller.PartitionStateMachine)
-[2017-04-28 14:11:58,104] INFO [Controller 0]: starting the partition rebalance scheduler (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,121] DEBUG [IsrChangeNotificationListener] Fired!!! (kafka.controller.IsrChangeNotificationListener)
-[2017-04-28 14:11:58,124] INFO [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
-[2017-04-28 14:11:58,168] INFO [BrokerChangeListener on Controller 0]: Newly added brokers: 0, deleted brokers: , all live brokers: 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
-[2017-04-28 14:11:58,168] DEBUG [Channel manager on controller 0]: Controller 0 trying to connect to broker 0 (kafka.controller.ControllerChannelManager)
-[2017-04-28 14:11:58,170] INFO [Controller 0]: New broker startup callback for 0 (kafka.controller.KafkaController)
-[2017-04-28 14:11:58,170] INFO [Controller-0-to-broker-0-send-thread], Starting  (kafka.controller.RequestSendThread)
-[2017-04-28 14:11:58,172] INFO [Controller-0-to-broker-0-send-thread], Controller 0 connected to localhost:9092 (id: 0 rack: null) for sending state change requests (kafka.controller.RequestSendThread)
-[2017-04-28 14:11:58,202] DEBUG [TopicChangeListener on Controller 0]: Topic change listener fired for path /brokers/topics with children  (kafka.controller.PartitionStateMachine$TopicChangeListener)
-[2017-04-28 14:11:58,204] INFO [TopicChangeListener on Controller 0]: New topics: [Set()], deleted topics: [Set()], new partition replica assignment [Map()] (kafka.controller.PartitionStateMachine$TopicChangeListener)
-[2017-04-28 14:11:58,211] INFO [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
-[2017-04-28 14:11:58,217] INFO [BrokerChangeListener on Controller 0]: Newly added brokers: , deleted brokers: , all live brokers: 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
-[2017-04-28 14:12:03,108] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController)
-[2017-04-28 14:12:03,109] DEBUG [Controller 0]: preferred replicas by broker Map() (kafka.controller.KafkaController)
-[2017-04-28 14:12:08,466] INFO [Controller 0]: Shutting down broker 0 (kafka.controller.KafkaController)
-[2017-04-28 14:12:08,468] DEBUG [Controller 0]: All shutting down brokers: 0 (kafka.controller.KafkaController)
-[2017-04-28 14:12:08,468] DEBUG [Controller 0]: Live brokers:  (kafka.controller.KafkaController)
-[2017-04-28 14:12:08,470] TRACE [Controller 0]: All leaders =  (kafka.controller.KafkaController)
-[2017-04-28 14:12:10,790] DEBUG [Controller 0]: Controller resigning, broker id 0 (kafka.controller.KafkaController)
-[2017-04-28 14:12:10,790] DEBUG [Controller 0]: De-registering IsrChangeNotificationListener (kafka.controller.KafkaController)
-[2017-04-28 14:12:10,791] INFO [Partition state machine on Controller 0]: Stopped partition state machine (kafka.controller.PartitionStateMachine)
-[2017-04-28 14:12:10,791] INFO [Replica state machine on controller 0]: Stopped replica state machine (kafka.controller.ReplicaStateMachine)
-[2017-04-28 14:12:10,796] INFO [Controller-0-to-broker-0-send-thread], Shutting down (kafka.controller.RequestSendThread)
-[2017-04-28 14:12:10,796] INFO [Controller-0-to-broker-0-send-thread], Stopped  (kafka.controller.RequestSendThread)
-[2017-04-28 14:12:10,796] INFO [Controller-0-to-broker-0-send-thread], Shutdown completed (kafka.controller.RequestSendThread)
-[2017-04-28 14:12:10,797] INFO [Controller 0]: Broker 0 resigned as the controller (kafka.controller.KafkaController)
+[2017-05-03 18:00:39,186] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController)
+[2017-05-03 18:00:39,193] DEBUG [Controller 0]: preferred replicas by broker Map() (kafka.controller.KafkaController)
+[2017-05-03 18:05:39,186] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController)
+[2017-05-03 18:05:39,186] DEBUG [Controller 0]: preferred replicas by broker Map() (kafka.controller.KafkaController)
+[2017-05-03 18:10:39,187] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController)
+[2017-05-03 18:10:39,187] DEBUG [Controller 0]: preferred replicas by broker Map() (kafka.controller.KafkaController)
+[2017-05-03 18:15:21,633] INFO [Controller 0]: Controller starting up (kafka.controller.KafkaController)
+[2017-05-03 18:15:21,881] INFO [Controller 0]: Controller startup complete (kafka.controller.KafkaController)
+[2017-05-03 18:15:24,636] DEBUG [Controller 0]: Controller resigning, broker id 0 (kafka.controller.KafkaController)
+[2017-05-03 18:15:24,637] DEBUG [Controller 0]: De-registering IsrChangeNotificationListener (kafka.controller.KafkaController)
+[2017-05-03 18:15:24,640] INFO [Partition state machine on Controller 0]: Stopped partition state machine (kafka.controller.PartitionStateMachine)
+[2017-05-03 18:15:24,640] INFO [Replica state machine on controller 0]: Stopped replica state machine (kafka.controller.ReplicaStateMachine)
+[2017-05-03 18:15:24,642] INFO [Controller 0]: Broker 0 resigned as the controller (kafka.controller.KafkaController)
diff --git a/...ojects/lagom-internal-meta-project-kafka/target/log4j_output/controller.log.2017-05-02-18 b/...ojects/lagom-internal-meta-project-kafka/target/log4j_output/controller.log.2017-05-02-18
@@ -0,0 +1,55 @@
+[2017-04-28 14:11:57,884] INFO [SessionExpirationListener on 0], ZK expired; shut down all controller components and try to re-elect (kafka.controller.KafkaController$SessionExpirationListener)
+[2017-04-28 14:11:57,971] DEBUG [Controller 0]: Controller resigning, broker id 0 (kafka.controller.KafkaController)
+[2017-04-28 14:11:57,971] DEBUG [Controller 0]: De-registering IsrChangeNotificationListener (kafka.controller.KafkaController)
+[2017-04-28 14:11:57,990] INFO [Partition state machine on Controller 0]: Stopped partition state machine (kafka.controller.PartitionStateMachine)
+[2017-04-28 14:11:57,991] INFO [Replica state machine on controller 0]: Stopped replica state machine (kafka.controller.ReplicaStateMachine)
+[2017-04-28 14:11:57,995] INFO [Controller-0-to-broker-0-send-thread], Shutting down (kafka.controller.RequestSendThread)
+[2017-04-28 14:11:57,996] INFO [Controller-0-to-broker-0-send-thread], Stopped  (kafka.controller.RequestSendThread)
+[2017-04-28 14:11:57,996] INFO [Controller-0-to-broker-0-send-thread], Shutdown completed (kafka.controller.RequestSendThread)
+[2017-04-28 14:11:57,997] INFO [Controller 0]: Broker 0 resigned as the controller (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,077] INFO [Controller 0]: Broker 0 starting become controller state transition (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,079] INFO [Controller 0]: Initialized controller epoch to 5 and zk version 4 (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,091] INFO [Controller 0]: Controller 0 incremented epoch to 6 (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,094] DEBUG [Controller 0]: Registering IsrChangeNotificationListener (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,099] INFO [Controller 0]: Partitions undergoing preferred replica election:  (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,099] INFO [Controller 0]: Partitions that completed preferred replica election:  (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,099] INFO [Controller 0]: Resuming preferred replica election for partitions:  (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,100] INFO [Controller 0]: Partitions being reassigned: Map() (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,100] INFO [Controller 0]: Partitions already reassigned: List() (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,100] INFO [Controller 0]: Resuming reassignment of partitions: Map() (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,101] INFO [Controller 0]: List of topics to be deleted:  (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,101] INFO [Controller 0]: List of topics ineligible for deletion:  (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,101] INFO [Controller 0]: Currently active brokers in the cluster: Set() (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,101] INFO [Controller 0]: Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,101] INFO [Controller 0]: Current list of topics in the cluster: Set() (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,102] INFO [Replica state machine on controller 0]: Started replica state machine with initial state -> Map() (kafka.controller.ReplicaStateMachine)
+[2017-04-28 14:11:58,102] INFO [Partition state machine on Controller 0]: Started partition state machine with initial state -> Map() (kafka.controller.PartitionStateMachine)
+[2017-04-28 14:11:58,102] INFO [Controller 0]: Broker 0 is ready to serve as the new controller with epoch 6 (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,102] INFO [Controller 0]: Starting preferred replica leader election for partitions  (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,102] INFO [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions  (kafka.controller.PartitionStateMachine)
+[2017-04-28 14:11:58,104] INFO [Controller 0]: starting the partition rebalance scheduler (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,121] DEBUG [IsrChangeNotificationListener] Fired!!! (kafka.controller.IsrChangeNotificationListener)
+[2017-04-28 14:11:58,124] INFO [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
+[2017-04-28 14:11:58,168] INFO [BrokerChangeListener on Controller 0]: Newly added brokers: 0, deleted brokers: , all live brokers: 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
+[2017-04-28 14:11:58,168] DEBUG [Channel manager on controller 0]: Controller 0 trying to connect to broker 0 (kafka.controller.ControllerChannelManager)
+[2017-04-28 14:11:58,170] INFO [Controller 0]: New broker startup callback for 0 (kafka.controller.KafkaController)
+[2017-04-28 14:11:58,170] INFO [Controller-0-to-broker-0-send-thread], Starting  (kafka.controller.RequestSendThread)
+[2017-04-28 14:11:58,172] INFO [Controller-0-to-broker-0-send-thread], Controller 0 connected to localhost:9092 (id: 0 rack: null) for sending state change requests (kafka.controller.RequestSendThread)
+[2017-04-28 14:11:58,202] DEBUG [TopicChangeListener on Controller 0]: Topic change listener fired for path /brokers/topics with children  (kafka.controller.PartitionStateMachine$TopicChangeListener)
+[2017-04-28 14:11:58,204] INFO [TopicChangeListener on Controller 0]: New topics: [Set()], deleted topics: [Set()], new partition replica assignment [Map()] (kafka.controller.PartitionStateMachine$TopicChangeListener)
+[2017-04-28 14:11:58,211] INFO [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
+[2017-04-28 14:11:58,217] INFO [BrokerChangeListener on Controller 0]: Newly added brokers: , deleted brokers: , all live brokers: 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
+[2017-04-28 14:12:03,108] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController)
+[2017-04-28 14:12:03,109] DEBUG [Controller 0]: preferred replicas by broker Map() (kafka.controller.KafkaController)
+[2017-04-28 14:12:08,466] INFO [Controller 0]: Shutting down broker 0 (kafka.controller.KafkaController)
+[2017-04-28 14:12:08,468] DEBUG [Controller 0]: All shutting down brokers: 0 (kafka.controller.KafkaController)
+[2017-04-28 14:12:08,468] DEBUG [Controller 0]: Live brokers:  (kafka.controller.KafkaController)
+[2017-04-28 14:12:08,470] TRACE [Controller 0]: All leaders =  (kafka.controller.KafkaController)
+[2017-04-28 14:12:10,790] DEBUG [Controller 0]: Controller resigning, broker id 0 (kafka.controller.KafkaController)
+[2017-04-28 14:12:10,790] DEBUG [Controller 0]: De-registering IsrChangeNotificationListener (kafka.controller.KafkaController)
+[2017-04-28 14:12:10,791] INFO [Partition state machine on Controller 0]: Stopped partition state machine (kafka.controller.PartitionStateMachine)
+[2017-04-28 14:12:10,791] INFO [Replica state machine on controller 0]: Stopped replica state machine (kafka.controller.ReplicaStateMachine)
+[2017-04-28 14:12:10,796] INFO [Controller-0-to-broker-0-send-thread], Shutting down (kafka.controller.RequestSendThread)
+[2017-04-28 14:12:10,796] INFO [Controller-0-to-broker-0-send-thread], Stopped  (kafka.controller.RequestSendThread)
+[2017-04-28 14:12:10,796] INFO [Controller-0-to-broker-0-send-thread], Shutdown completed (kafka.controller.RequestSendThread)
+[2017-04-28 14:12:10,797] INFO [Controller 0]: Broker 0 resigned as the controller (kafka.controller.KafkaController)
diff --git a/...ojects/lagom-internal-meta-project-kafka/target/log4j_output/controller.log.2017-05-03-17 b/...ojects/lagom-internal-meta-project-kafka/target/log4j_output/controller.log.2017-05-03-17
@@ -0,0 +1,31 @@
+[2017-05-03 17:55:33,979] INFO [Controller 0]: Controller starting up (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,073] INFO [Controller 0]: Broker 0 starting become controller state transition (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,078] INFO [Controller 0]: Initialized controller epoch to 6 and zk version 5 (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,084] INFO [Controller 0]: Controller 0 incremented epoch to 7 (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,087] DEBUG [Controller 0]: Registering IsrChangeNotificationListener (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,114] INFO [Controller 0]: Partitions undergoing preferred replica election:  (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,115] INFO [Controller 0]: Partitions that completed preferred replica election:  (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,116] INFO [Controller 0]: Resuming preferred replica election for partitions:  (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,122] INFO [Controller 0]: Partitions being reassigned: Map() (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,123] INFO [Controller 0]: Partitions already reassigned: List() (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,125] INFO [Controller 0]: Resuming reassignment of partitions: Map() (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,138] INFO [Controller 0]: List of topics to be deleted:  (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,140] INFO [Controller 0]: List of topics ineligible for deletion:  (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,150] INFO [Controller 0]: Currently active brokers in the cluster: Set() (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,150] INFO [Controller 0]: Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,151] INFO [Controller 0]: Current list of topics in the cluster: Set() (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,156] INFO [Replica state machine on controller 0]: Started replica state machine with initial state -> Map() (kafka.controller.ReplicaStateMachine)
+[2017-05-03 17:55:34,168] INFO [Partition state machine on Controller 0]: Started partition state machine with initial state -> Map() (kafka.controller.PartitionStateMachine)
+[2017-05-03 17:55:34,170] INFO [Controller 0]: Broker 0 is ready to serve as the new controller with epoch 7 (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,173] INFO [Controller 0]: Starting preferred replica leader election for partitions  (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,175] INFO [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions  (kafka.controller.PartitionStateMachine)
+[2017-05-03 17:55:34,185] INFO [Controller 0]: starting the partition rebalance scheduler (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,187] INFO [Controller 0]: Controller startup complete (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,405] INFO [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
+[2017-05-03 17:55:34,458] INFO [BrokerChangeListener on Controller 0]: Newly added brokers: 0, deleted brokers: , all live brokers: 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
+[2017-05-03 17:55:34,460] DEBUG [Channel manager on controller 0]: Controller 0 trying to connect to broker 0 (kafka.controller.ControllerChannelManager)
+[2017-05-03 17:55:34,476] INFO [Controller-0-to-broker-0-send-thread], Starting  (kafka.controller.RequestSendThread)
+[2017-05-03 17:55:34,477] INFO [Controller 0]: New broker startup callback for 0 (kafka.controller.KafkaController)
+[2017-05-03 17:55:34,541] INFO [Controller-0-to-broker-0-send-thread], Controller 0 connected to 192.168.0.171:9092 (id: 0 rack: null) for sending state change requests (kafka.controller.RequestSendThread)
+[2017-05-03 17:55:39,188] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController)
+[2017-05-03 17:55:39,190] DEBUG [Controller 0]: preferred replicas by broker Map() (kafka.controller.KafkaController)
diff --git a/...om-dynamic-projects/lagom-internal-meta-project-kafka/target/log4j_output/log-cleaner.log b/...om-dynamic-projects/lagom-internal-meta-project-kafka/target/log4j_output/log-cleaner.log
@@ -1,4 +1,8 @@
-[2017-04-28 14:12:10,425] INFO Shutting down the log cleaner. (kafka.log.LogCleaner)
-[2017-04-28 14:12:10,427] INFO [kafka-log-cleaner-thread-0], Shutting down (kafka.log.LogCleaner)
-[2017-04-28 14:12:10,430] INFO [kafka-log-cleaner-thread-0], Stopped  (kafka.log.LogCleaner)
-[2017-04-28 14:12:10,430] INFO [kafka-log-cleaner-thread-0], Shutdown completed (kafka.log.LogCleaner)
+[2017-05-03 17:55:33,694] INFO Starting the log cleaner (kafka.log.LogCleaner)
+[2017-05-03 17:55:33,703] INFO [kafka-log-cleaner-thread-0], Starting  (kafka.log.LogCleaner)
+[2017-05-03 18:15:21,411] INFO Starting the log cleaner (kafka.log.LogCleaner)
+[2017-05-03 18:15:21,416] INFO [kafka-log-cleaner-thread-0], Starting  (kafka.log.LogCleaner)
+[2017-05-03 18:15:24,451] INFO Shutting down the log cleaner. (kafka.log.LogCleaner)
+[2017-05-03 18:15:24,452] INFO [kafka-log-cleaner-thread-0], Shutting down (kafka.log.LogCleaner)
+[2017-05-03 18:15:24,460] INFO [kafka-log-cleaner-thread-0], Stopped  (kafka.log.LogCleaner)
+[2017-05-03 18:15:24,461] INFO [kafka-log-cleaner-thread-0], Shutdown completed (kafka.log.LogCleaner)
diff --git a/...jects/lagom-internal-meta-project-kafka/target/log4j_output/log-cleaner.log.2017-05-02-18 b/...jects/lagom-internal-meta-project-kafka/target/log4j_output/log-cleaner.log.2017-05-02-18
@@ -0,0 +1,4 @@
+[2017-04-28 14:12:10,425] INFO Shutting down the log cleaner. (kafka.log.LogCleaner)
+[2017-04-28 14:12:10,427] INFO [kafka-log-cleaner-thread-0], Shutting down (kafka.log.LogCleaner)
+[2017-04-28 14:12:10,430] INFO [kafka-log-cleaner-thread-0], Stopped  (kafka.log.LogCleaner)
+[2017-04-28 14:12:10,430] INFO [kafka-log-cleaner-thread-0], Shutdown completed (kafka.log.LogCleaner)
diff --git a/...t/lagom-dynamic-projects/lagom-internal-meta-project-kafka/target/log4j_output/server.log b/...t/lagom-dynamic-projects/lagom-internal-meta-project-kafka/target/log4j_output/server.log
@@ -1,49 +1,81 @@
-[2017-04-28 14:11:57,129] INFO zookeeper state changed (Disconnected) (org.I0Itec.zkclient.ZkClient)
-[2017-04-28 14:11:57,883] INFO zookeeper state changed (Expired) (org.I0Itec.zkclient.ZkClient)
-[2017-04-28 14:11:58,068] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient)
-[2017-04-28 14:11:58,069] INFO Creating /controller (is it secure? false) (kafka.utils.ZKCheckedEphemeral)
-[2017-04-28 14:11:58,076] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral)
-[2017-04-28 14:11:58,076] INFO 0 successfully elected as leader (kafka.server.ZookeeperLeaderElector)
-[2017-04-28 14:11:58,107] INFO re-registering broker info in ZK for broker 0 (kafka.server.KafkaHealthcheck$SessionExpireListener)
-[2017-04-28 14:11:58,111] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.utils.ZKCheckedEphemeral)
-[2017-04-28 14:11:58,117] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral)
-[2017-04-28 14:11:58,117] INFO Registered broker 0 at path /brokers/ids/0 with addresses: PLAINTEXT -> EndPoint(localhost,9092,PLAINTEXT) (kafka.utils.ZkUtils)
-[2017-04-28 14:11:58,118] INFO done re-registering broker (kafka.server.KafkaHealthcheck$SessionExpireListener)
-[2017-04-28 14:11:58,119] INFO Subscribing to /brokers/topics path to watch for new topics (kafka.server.KafkaHealthcheck$SessionExpireListener)
-[2017-04-28 14:11:58,209] INFO New leader is 0 (kafka.server.ZookeeperLeaderElector$LeaderChangeListener)
-[2017-04-28 14:12:08,412] INFO [Kafka Server 0], shutting down (kafka.server.KafkaServer)
-[2017-04-28 14:12:08,418] INFO [Kafka Server 0], Starting controlled shutdown (kafka.server.KafkaServer)
-[2017-04-28 14:12:08,518] INFO [Kafka Server 0], Controlled shutdown succeeded (kafka.server.KafkaServer)
-[2017-04-28 14:12:08,520] INFO [Socket Server on Broker 0], Shutting down (kafka.network.SocketServer)
-[2017-04-28 14:12:08,557] INFO [Socket Server on Broker 0], Shutdown completed (kafka.network.SocketServer)
-[2017-04-28 14:12:08,558] INFO [Kafka Request Handler on Broker 0], shutting down (kafka.server.KafkaRequestHandlerPool)
-[2017-04-28 14:12:08,560] INFO [Kafka Request Handler on Broker 0], shut down completely (kafka.server.KafkaRequestHandlerPool)
-[2017-04-28 14:12:08,566] INFO [ThrottledRequestReaper-Produce], Shutting down (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
-[2017-04-28 14:12:09,058] INFO [ThrottledRequestReaper-Produce], Stopped  (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
-[2017-04-28 14:12:09,058] INFO [ThrottledRequestReaper-Produce], Shutdown completed (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
-[2017-04-28 14:12:09,058] INFO [ThrottledRequestReaper-Fetch], Shutting down (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
-[2017-04-28 14:12:10,062] INFO [ThrottledRequestReaper-Fetch], Stopped  (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
-[2017-04-28 14:12:10,062] INFO [ThrottledRequestReaper-Fetch], Shutdown completed (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
-[2017-04-28 14:12:10,062] INFO [KafkaApi-0] Shutdown complete. (kafka.server.KafkaApis)
-[2017-04-28 14:12:10,064] INFO [Replica Manager on Broker 0]: Shutting down (kafka.server.ReplicaManager)
-[2017-04-28 14:12:10,065] INFO [ReplicaFetcherManager on broker 0] shutting down (kafka.server.ReplicaFetcherManager)
-[2017-04-28 14:12:10,065] INFO [ReplicaFetcherManager on broker 0] shutdown completed (kafka.server.ReplicaFetcherManager)
-[2017-04-28 14:12:10,066] INFO [ExpirationReaper-0], Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
-[2017-04-28 14:12:10,202] INFO [ExpirationReaper-0], Stopped  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
-[2017-04-28 14:12:10,202] INFO [ExpirationReaper-0], Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
-[2017-04-28 14:12:10,202] INFO [ExpirationReaper-0], Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
-[2017-04-28 14:12:10,404] INFO [ExpirationReaper-0], Stopped  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
-[2017-04-28 14:12:10,404] INFO [ExpirationReaper-0], Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
-[2017-04-28 14:12:10,423] INFO [Replica Manager on Broker 0]: Shut down completely (kafka.server.ReplicaManager)
-[2017-04-28 14:12:10,423] INFO Shutting down. (kafka.log.LogManager)
-[2017-04-28 14:12:10,441] INFO Shutdown complete. (kafka.log.LogManager)
-[2017-04-28 14:12:10,447] INFO [GroupCoordinator 0]: Shutting down. (kafka.coordinator.GroupCoordinator)
-[2017-04-28 14:12:10,448] INFO [ExpirationReaper-0], Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
-[2017-04-28 14:12:10,605] INFO [ExpirationReaper-0], Stopped  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
-[2017-04-28 14:12:10,605] INFO [ExpirationReaper-0], Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
-[2017-04-28 14:12:10,605] INFO [ExpirationReaper-0], Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
-[2017-04-28 14:12:10,789] INFO [ExpirationReaper-0], Stopped  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
-[2017-04-28 14:12:10,789] INFO [ExpirationReaper-0], Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
-[2017-04-28 14:12:10,790] INFO [GroupCoordinator 0]: Shutdown complete. (kafka.coordinator.GroupCoordinator)
-[2017-04-28 14:12:10,799] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)
-[2017-04-28 14:12:10,804] INFO [Kafka Server 0], shut down completed (kafka.server.KafkaServer)
+[2017-05-03 18:05:34,250] INFO [Group Metadata Manager on Broker 0]: Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.GroupMetadataManager)
+[2017-05-03 18:15:21,106] INFO starting (kafka.server.KafkaServer)
+[2017-05-03 18:15:21,135] INFO Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer)
+[2017-05-03 18:15:21,159] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)
+[2017-05-03 18:15:21,186] INFO Waiting for keeper state SyncConnected (org.I0Itec.zkclient.ZkClient)
+[2017-05-03 18:15:21,209] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient)
+[2017-05-03 18:15:21,278] INFO Loading logs. (kafka.log.LogManager)
+[2017-05-03 18:15:21,289] INFO Logs loading complete. (kafka.log.LogManager)
+[2017-05-03 18:15:21,406] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager)
+[2017-05-03 18:15:21,410] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager)
+[2017-05-03 18:15:21,517] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.Acceptor)
+[2017-05-03 18:15:21,522] INFO [Socket Server on Broker 0], Started 1 acceptor threads (kafka.network.SocketServer)
+[2017-05-03 18:15:21,583] INFO [ExpirationReaper-0], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:21,584] INFO [ExpirationReaper-0], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:21,914] INFO [GroupCoordinator 0]: Starting up. (kafka.coordinator.GroupCoordinator)
+[2017-05-03 18:15:21,915] INFO [GroupCoordinator 0]: Startup complete. (kafka.coordinator.GroupCoordinator)
+[2017-05-03 18:15:21,974] INFO [Group Metadata Manager on Broker 0]: Removed 0 expired offsets in 11 milliseconds. (kafka.coordinator.GroupMetadataManager)
+[2017-05-03 18:15:21,975] INFO [ExpirationReaper-0], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:21,975] INFO [ExpirationReaper-0], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:22,009] INFO Will not load MX4J, mx4j-tools.jar is not in the classpath (kafka.utils.Mx4jLoader$)
+[2017-05-03 18:15:22,044] INFO [ThrottledRequestReaper-Fetch], Starting  (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-05-03 18:15:22,045] INFO [ThrottledRequestReaper-Produce], Starting  (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-05-03 18:15:22,080] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.utils.ZKCheckedEphemeral)
+[2017-05-03 18:15:22,095] INFO Result of znode creation is: NODEEXISTS (kafka.utils.ZKCheckedEphemeral)
+[2017-05-03 18:15:22,097] FATAL [Kafka Server 0], Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
+java.lang.RuntimeException: A broker is already registered on the path /brokers/ids/0. This probably indicates that you either have configured a brokerid that is already in use, or else you have shutdown this broker and restarted it faster than the zookeeper timeout so it appears to be re-registering.
+	at kafka.utils.ZkUtils.registerBrokerInZk(ZkUtils.scala:305)
+	at kafka.utils.ZkUtils.registerBrokerInZk(ZkUtils.scala:291)
+	at kafka.server.KafkaHealthcheck.register(KafkaHealthcheck.scala:70)
+	at kafka.server.KafkaHealthcheck.startup(KafkaHealthcheck.scala:51)
+	at kafka.server.KafkaServer.startup(KafkaServer.scala:244)
+	at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:37)
+	at com.lightbend.lagom.internal.kafka.KafkaLocalServer.start(KafkaLocalServer.scala:38)
+	at com.lightbend.lagom.internal.kafka.KafkaLauncher$.main(KafkaLauncher.scala:45)
+	at com.lightbend.lagom.internal.kafka.KafkaLauncher.main(KafkaLauncher.scala)
+[2017-05-03 18:15:22,105] INFO [Kafka Server 0], shutting down (kafka.server.KafkaServer)
+[2017-05-03 18:15:22,108] INFO [Socket Server on Broker 0], Shutting down (kafka.network.SocketServer)
+[2017-05-03 18:15:22,125] INFO [Socket Server on Broker 0], Shutdown completed (kafka.network.SocketServer)
+[2017-05-03 18:15:22,126] INFO [Kafka Request Handler on Broker 0], shutting down (kafka.server.KafkaRequestHandlerPool)
+[2017-05-03 18:15:22,205] INFO [Kafka Request Handler on Broker 0], shut down completely (kafka.server.KafkaRequestHandlerPool)
+[2017-05-03 18:15:22,209] INFO [ThrottledRequestReaper-Produce], Shutting down (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-05-03 18:15:23,046] INFO [ThrottledRequestReaper-Produce], Shutdown completed (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-05-03 18:15:23,046] INFO [ThrottledRequestReaper-Produce], Stopped  (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-05-03 18:15:23,046] INFO [ThrottledRequestReaper-Fetch], Shutting down (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-05-03 18:15:24,046] INFO [ThrottledRequestReaper-Fetch], Shutdown completed (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-05-03 18:15:24,046] INFO [ThrottledRequestReaper-Fetch], Stopped  (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-05-03 18:15:24,046] INFO [KafkaApi-0] Shutdown complete. (kafka.server.KafkaApis)
+[2017-05-03 18:15:24,049] INFO [Replica Manager on Broker 0]: Shutting down (kafka.server.ReplicaManager)
+[2017-05-03 18:15:24,050] INFO [ReplicaFetcherManager on broker 0] shutting down (kafka.server.ReplicaFetcherManager)
+[2017-05-03 18:15:24,052] INFO [ReplicaFetcherManager on broker 0] shutdown completed (kafka.server.ReplicaFetcherManager)
+[2017-05-03 18:15:24,052] INFO [ExpirationReaper-0], Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:24,245] INFO [ExpirationReaper-0], Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:24,245] INFO [ExpirationReaper-0], Stopped  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:24,245] INFO [ExpirationReaper-0], Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:24,446] INFO [ExpirationReaper-0], Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:24,449] INFO [Replica Manager on Broker 0]: Shut down completely (kafka.server.ReplicaManager)
+[2017-05-03 18:15:24,450] INFO Shutting down. (kafka.log.LogManager)
+[2017-05-03 18:15:24,472] INFO Shutdown complete. (kafka.log.LogManager)
+[2017-05-03 18:15:24,473] INFO [GroupCoordinator 0]: Shutting down. (kafka.coordinator.GroupCoordinator)
+[2017-05-03 18:15:24,473] INFO [ExpirationReaper-0], Stopped  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:24,474] INFO [ExpirationReaper-0], Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:24,632] INFO [ExpirationReaper-0], Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:24,633] INFO [ExpirationReaper-0], Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:24,633] INFO [ExpirationReaper-0], Stopped  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:24,633] INFO [ExpirationReaper-0], Stopped  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:24,633] INFO [ExpirationReaper-0], Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 18:15:24,634] INFO [GroupCoordinator 0]: Shutdown complete. (kafka.coordinator.GroupCoordinator)
+[2017-05-03 18:15:24,642] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)
+[2017-05-03 18:15:24,649] INFO [Kafka Server 0], shut down completed (kafka.server.KafkaServer)
+[2017-05-03 18:15:24,650] FATAL Fatal error during KafkaServerStartable startup. Prepare to shutdown (kafka.server.KafkaServerStartable)
+java.lang.RuntimeException: A broker is already registered on the path /brokers/ids/0. This probably indicates that you either have configured a brokerid that is already in use, or else you have shutdown this broker and restarted it faster than the zookeeper timeout so it appears to be re-registering.
+	at kafka.utils.ZkUtils.registerBrokerInZk(ZkUtils.scala:305)
+	at kafka.utils.ZkUtils.registerBrokerInZk(ZkUtils.scala:291)
+	at kafka.server.KafkaHealthcheck.register(KafkaHealthcheck.scala:70)
+	at kafka.server.KafkaHealthcheck.startup(KafkaHealthcheck.scala:51)
+	at kafka.server.KafkaServer.startup(KafkaServer.scala:244)
+	at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:37)
+	at com.lightbend.lagom.internal.kafka.KafkaLocalServer.start(KafkaLocalServer.scala:38)
+	at com.lightbend.lagom.internal.kafka.KafkaLauncher$.main(KafkaLauncher.scala:45)
+	at com.lightbend.lagom.internal.kafka.KafkaLauncher.main(KafkaLauncher.scala)
+[2017-05-03 18:15:24,661] INFO [Kafka Server 0], shutting down (kafka.server.KafkaServer)
diff --git a/...c-projects/lagom-internal-meta-project-kafka/target/log4j_output/server.log.2017-05-02-18 b/...c-projects/lagom-internal-meta-project-kafka/target/log4j_output/server.log.2017-05-02-18
@@ -0,0 +1,49 @@
+[2017-04-28 14:11:57,129] INFO zookeeper state changed (Disconnected) (org.I0Itec.zkclient.ZkClient)
+[2017-04-28 14:11:57,883] INFO zookeeper state changed (Expired) (org.I0Itec.zkclient.ZkClient)
+[2017-04-28 14:11:58,068] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient)
+[2017-04-28 14:11:58,069] INFO Creating /controller (is it secure? false) (kafka.utils.ZKCheckedEphemeral)
+[2017-04-28 14:11:58,076] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral)
+[2017-04-28 14:11:58,076] INFO 0 successfully elected as leader (kafka.server.ZookeeperLeaderElector)
+[2017-04-28 14:11:58,107] INFO re-registering broker info in ZK for broker 0 (kafka.server.KafkaHealthcheck$SessionExpireListener)
+[2017-04-28 14:11:58,111] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.utils.ZKCheckedEphemeral)
+[2017-04-28 14:11:58,117] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral)
+[2017-04-28 14:11:58,117] INFO Registered broker 0 at path /brokers/ids/0 with addresses: PLAINTEXT -> EndPoint(localhost,9092,PLAINTEXT) (kafka.utils.ZkUtils)
+[2017-04-28 14:11:58,118] INFO done re-registering broker (kafka.server.KafkaHealthcheck$SessionExpireListener)
+[2017-04-28 14:11:58,119] INFO Subscribing to /brokers/topics path to watch for new topics (kafka.server.KafkaHealthcheck$SessionExpireListener)
+[2017-04-28 14:11:58,209] INFO New leader is 0 (kafka.server.ZookeeperLeaderElector$LeaderChangeListener)
+[2017-04-28 14:12:08,412] INFO [Kafka Server 0], shutting down (kafka.server.KafkaServer)
+[2017-04-28 14:12:08,418] INFO [Kafka Server 0], Starting controlled shutdown (kafka.server.KafkaServer)
+[2017-04-28 14:12:08,518] INFO [Kafka Server 0], Controlled shutdown succeeded (kafka.server.KafkaServer)
+[2017-04-28 14:12:08,520] INFO [Socket Server on Broker 0], Shutting down (kafka.network.SocketServer)
+[2017-04-28 14:12:08,557] INFO [Socket Server on Broker 0], Shutdown completed (kafka.network.SocketServer)
+[2017-04-28 14:12:08,558] INFO [Kafka Request Handler on Broker 0], shutting down (kafka.server.KafkaRequestHandlerPool)
+[2017-04-28 14:12:08,560] INFO [Kafka Request Handler on Broker 0], shut down completely (kafka.server.KafkaRequestHandlerPool)
+[2017-04-28 14:12:08,566] INFO [ThrottledRequestReaper-Produce], Shutting down (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-04-28 14:12:09,058] INFO [ThrottledRequestReaper-Produce], Stopped  (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-04-28 14:12:09,058] INFO [ThrottledRequestReaper-Produce], Shutdown completed (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-04-28 14:12:09,058] INFO [ThrottledRequestReaper-Fetch], Shutting down (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-04-28 14:12:10,062] INFO [ThrottledRequestReaper-Fetch], Stopped  (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-04-28 14:12:10,062] INFO [ThrottledRequestReaper-Fetch], Shutdown completed (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-04-28 14:12:10,062] INFO [KafkaApi-0] Shutdown complete. (kafka.server.KafkaApis)
+[2017-04-28 14:12:10,064] INFO [Replica Manager on Broker 0]: Shutting down (kafka.server.ReplicaManager)
+[2017-04-28 14:12:10,065] INFO [ReplicaFetcherManager on broker 0] shutting down (kafka.server.ReplicaFetcherManager)
+[2017-04-28 14:12:10,065] INFO [ReplicaFetcherManager on broker 0] shutdown completed (kafka.server.ReplicaFetcherManager)
+[2017-04-28 14:12:10,066] INFO [ExpirationReaper-0], Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-04-28 14:12:10,202] INFO [ExpirationReaper-0], Stopped  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-04-28 14:12:10,202] INFO [ExpirationReaper-0], Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-04-28 14:12:10,202] INFO [ExpirationReaper-0], Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-04-28 14:12:10,404] INFO [ExpirationReaper-0], Stopped  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-04-28 14:12:10,404] INFO [ExpirationReaper-0], Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-04-28 14:12:10,423] INFO [Replica Manager on Broker 0]: Shut down completely (kafka.server.ReplicaManager)
+[2017-04-28 14:12:10,423] INFO Shutting down. (kafka.log.LogManager)
+[2017-04-28 14:12:10,441] INFO Shutdown complete. (kafka.log.LogManager)
+[2017-04-28 14:12:10,447] INFO [GroupCoordinator 0]: Shutting down. (kafka.coordinator.GroupCoordinator)
+[2017-04-28 14:12:10,448] INFO [ExpirationReaper-0], Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-04-28 14:12:10,605] INFO [ExpirationReaper-0], Stopped  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-04-28 14:12:10,605] INFO [ExpirationReaper-0], Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-04-28 14:12:10,605] INFO [ExpirationReaper-0], Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-04-28 14:12:10,789] INFO [ExpirationReaper-0], Stopped  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-04-28 14:12:10,789] INFO [ExpirationReaper-0], Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-04-28 14:12:10,790] INFO [GroupCoordinator 0]: Shutdown complete. (kafka.coordinator.GroupCoordinator)
+[2017-04-28 14:12:10,799] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)
+[2017-04-28 14:12:10,804] INFO [Kafka Server 0], shut down completed (kafka.server.KafkaServer)
diff --git a/...c-projects/lagom-internal-meta-project-kafka/target/log4j_output/server.log.2017-05-03-17 b/...c-projects/lagom-internal-meta-project-kafka/target/log4j_output/server.log.2017-05-03-17
@@ -0,0 +1,29 @@
+[2017-05-03 17:55:33,277] INFO starting (kafka.server.KafkaServer)
+[2017-05-03 17:55:33,298] INFO Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer)
+[2017-05-03 17:55:33,336] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)
+[2017-05-03 17:55:33,379] INFO Waiting for keeper state SyncConnected (org.I0Itec.zkclient.ZkClient)
+[2017-05-03 17:55:33,422] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient)
+[2017-05-03 17:55:33,513] INFO Loading logs. (kafka.log.LogManager)
+[2017-05-03 17:55:33,525] INFO Logs loading complete. (kafka.log.LogManager)
+[2017-05-03 17:55:33,687] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager)
+[2017-05-03 17:55:33,691] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager)
+[2017-05-03 17:55:33,826] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.Acceptor)
+[2017-05-03 17:55:33,850] INFO [Socket Server on Broker 0], Started 1 acceptor threads (kafka.network.SocketServer)
+[2017-05-03 17:55:33,898] INFO [ExpirationReaper-0], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 17:55:33,899] INFO [ExpirationReaper-0], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 17:55:34,056] INFO Creating /controller (is it secure? false) (kafka.utils.ZKCheckedEphemeral)
+[2017-05-03 17:55:34,071] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral)
+[2017-05-03 17:55:34,072] INFO 0 successfully elected as leader (kafka.server.ZookeeperLeaderElector)
+[2017-05-03 17:55:34,204] INFO [ExpirationReaper-0], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 17:55:34,204] INFO [ExpirationReaper-0], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
+[2017-05-03 17:55:34,256] INFO [GroupCoordinator 0]: Starting up. (kafka.coordinator.GroupCoordinator)
+[2017-05-03 17:55:34,256] INFO [GroupCoordinator 0]: Startup complete. (kafka.coordinator.GroupCoordinator)
+[2017-05-03 17:55:34,268] INFO [Group Metadata Manager on Broker 0]: Removed 0 expired offsets in 14 milliseconds. (kafka.coordinator.GroupMetadataManager)
+[2017-05-03 17:55:34,329] INFO [ThrottledRequestReaper-Produce], Starting  (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-05-03 17:55:34,329] INFO [ThrottledRequestReaper-Fetch], Starting  (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
+[2017-05-03 17:55:34,336] INFO Will not load MX4J, mx4j-tools.jar is not in the classpath (kafka.utils.Mx4jLoader$)
+[2017-05-03 17:55:34,384] INFO New leader is 0 (kafka.server.ZookeeperLeaderElector$LeaderChangeListener)
+[2017-05-03 17:55:34,395] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.utils.ZKCheckedEphemeral)
+[2017-05-03 17:55:34,401] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral)
+[2017-05-03 17:55:34,404] INFO Registered broker 0 at path /brokers/ids/0 with addresses: PLAINTEXT -> EndPoint(192.168.0.171,9092,PLAINTEXT) (kafka.utils.ZkUtils)
+[2017-05-03 17:55:34,427] INFO [Kafka Server 0], started (kafka.server.KafkaServer)
diff --git a/...m-dynamic-projects/lagom-internal-meta-project-kafka/target/log4j_output/state-change.log b/...m-dynamic-projects/lagom-internal-meta-project-kafka/target/log4j_output/state-change.log
@@ -1 +1 @@
-[2017-04-28 14:11:58,174] TRACE Controller 0 epoch 6 received response {error_code=0} for a request sent to broker localhost:9092 (id: 0 rack: null) (state.change.logger)
+[2017-05-03 17:55:34,588] TRACE Controller 0 epoch 7 received response {error_code=0} for a request sent to broker 192.168.0.171:9092 (id: 0 rack: null) (state.change.logger)
diff --git a/...ects/lagom-internal-meta-project-kafka/target/log4j_output/state-change.log.2017-05-02-18 b/...ects/lagom-internal-meta-project-kafka/target/log4j_output/state-change.log.2017-05-02-18
@@ -0,0 +1 @@
+[2017-04-28 14:11:58,174] TRACE Controller 0 epoch 6 received response {error_code=0} for a request sent to broker localhost:9092 (id: 0 rack: null) (state.change.logger)
diff --git a/...he/com.kanban/lagom-internal-meta-project-kafka_2.11/1.0-SNAPSHOT/resolved.xml.properties b/...he/com.kanban/lagom-internal-meta-project-kafka_2.11/1.0-SNAPSHOT/resolved.xml.properties
@@ -1,5 +1,5 @@
 #com.kanban#lagom-internal-meta-project-kafka_2.11;1.0-SNAPSHOT resolved revisions
-#Thu Apr 27 23:54:07 CEST 2017
+#Wed May 03 17:55:27 CEST 2017
 +organisation\:\#@\#\:+org.scala-lang\:\#@\#\:+branch\:\#@\#\:+@\#\:NULL\:\#@\:\#@\#\:+module\:\#@\#\:+scala-library\:\#@\#\:+revision\:\#@\#\:+2.11.7\:\#@\#\:=2.11.7 ? 2.11.7 null
 +organisation\:\#@\#\:+com.lightbend.lagom\:\#@\#\:+branch\:\#@\#\:+@\#\:NULL\:\#@\:\#@\#\:+module\:\#@\#\:+lagom-kafka-server_2.11\:\#@\#\:+revision\:\#@\#\:+1.3.2\:\#@\#\:=1.3.2 release 1.3.2 null
 +organisation\:\#@\#\:+org.scala-lang\:\#@\#\:+branch\:\#@\#\:+@\#\:NULL\:\#@\:\#@\#\:+module\:\#@\#\:+scala-compiler\:\#@\#\:+revision\:\#@\#\:+2.11.7\:\#@\#\:=2.11.7 release 2.11.7 null
diff --git a/...ion-cache/com.kanban/lagom-internal-meta-project-kafka_2.11/1.0-SNAPSHOT/resolved.xml.xml b/...ion-cache/com.kanban/lagom-internal-meta-project-kafka_2.11/1.0-SNAPSHOT/resolved.xml.xml
@@ -4,7 +4,7 @@
 		module="lagom-internal-meta-project-kafka_2.11"
 		revision="1.0-SNAPSHOT"
 		status="integration"
-		publication="20170427235407"
+		publication="20170503175526"
 	>
 		<description>
 		lagom-internal-meta-project-kafka
		@@ -0,0 +1 @@
		[2017-04-28 14:11:58,174] TRACE Controller 0 epoch 6 received response {error_code=0} for a request sent to broker localhost:9092 (id: 0 rack: null) (state.change.logger)