Error when using Kafka and Zookeeper
Closed this issue · 3 comments
Hello,
I have setup some unit test using the mini-clusters including Zookeeper and Kafka.
The process of launching clusters, creating topic and partition and sending message rolls out without error. Also the instantiation of consumers does not seem to raise any problem.
But when I tried to poll the message from the kafka partition I get a firsts stack that cause the broker to shutdown ...
2016-08-02 05:38:14 ERROR KafkaApis:103 - [KafkaApi-0] error when handling request null java.lang.ClassCastException: org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata cannot be cast to org.apache.kafka.common.requests.JoinGroupRequest$GroupProtocol at kafka.server.KafkaApis$$anonfun$37.apply(KafkaApis.scala:788) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244) at scala.collection.Iterator$class.foreach(Iterator.scala:727) at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) at scala.collection.AbstractIterable.foreach(Iterable.scala:54) at scala.collection.TraversableLike$class.map(TraversableLike.scala:244) at scala.collection.AbstractTraversable.map(Traversable.scala:105) at kafka.server.KafkaApis.handleJoinGroupRequest(KafkaApis.scala:788) at kafka.server.KafkaApis.handle(KafkaApis.scala:79) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60) at java.lang.Thread.run(Thread.java:745)
... and a second that witness a message that could not be sent because the broker is not up:
2016-08-02 05:38:15 INFO TestSendingReceiving:75 - /home/sam/IdeaProjects/affinytix-stream-kafka Unexpected error in join group response: The server experienced an unexpected error when processing the request org.apache.kafka.common.KafkaException: Unexpected error in join group response: The server experienced an unexpected error when processing the request at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:376) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:324) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:665) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:644) at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:167) at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:133) at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:107) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.onComplete(ConsumerNetworkClient.java:380) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:274) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:320) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:213) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:193) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:163) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:222) at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.ensurePartitionAssignment(ConsumerCoordinator.java:311) at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:890) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:853) at com.affinytix.stream.kafka.consumer.partition.BasicPartitionConsumer.consumer(BasicPartitionConsumer.java:32) at com.affinytix.stream.kafka.consumer.receiver.MaxConsumerReceiver.process(MaxConsumerReceiver.java:52) at TestSendingReceiving$$anonfun$2.apply$mcV$sp(TestSendingReceiving.scala:118) at TestSendingReceiving$$anonfun$2.apply(TestSendingReceiving.scala:82) at TestSendingReceiving$$anonfun$2.apply(TestSendingReceiving.scala:82) at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22) at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85) at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104) at org.scalatest.Transformer.apply(Transformer.scala:22) at org.scalatest.Transformer.apply(Transformer.scala:20) at org.scalatest.FlatSpecLike$$anon$1.apply(FlatSpecLike.scala:1647) at org.scalatest.Suite$class.withFixture(Suite.scala:1122) at TestSendingReceiving.withFixture(TestSendingReceiving.scala:59) at org.scalatest.FlatSpecLike$class.invokeWithFixture$1(FlatSpecLike.scala:1644) at org.scalatest.FlatSpecLike$$anonfun$runTest$1.apply(FlatSpecLike.scala:1656) at org.scalatest.FlatSpecLike$$anonfun$runTest$1.apply(FlatSpecLike.scala:1656) at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306) at org.scalatest.FlatSpecLike$class.runTest(FlatSpecLike.scala:1656) at TestSendingReceiving.org$scalatest$BeforeAndAfter$$super$runTest(TestSendingReceiving.scala:17) at org.scalatest.BeforeAndAfter$class.runTest(BeforeAndAfter.scala:200) at TestSendingReceiving.runTest(TestSendingReceiving.scala:17) at org.scalatest.FlatSpecLike$$anonfun$runTests$1.apply(FlatSpecLike.scala:1714) at org.scalatest.FlatSpecLike$$anonfun$runTests$1.apply(FlatSpecLike.scala:1714) at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:413) at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:401) at scala.collection.immutable.List.foreach(List.scala:318) at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401) at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:390) at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:427) at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:401) at scala.collection.immutable.List.foreach(List.scala:318) at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401) at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:396) at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:483) at org.scalatest.FlatSpecLike$class.runTests(FlatSpecLike.scala:1714) at org.scalatest.FlatSpec.runTests(FlatSpec.scala:1683) at org.scalatest.Suite$class.run(Suite.scala:1424) at org.scalatest.FlatSpec.org$scalatest$FlatSpecLike$$super$run(FlatSpec.scala:1683) at org.scalatest.FlatSpecLike$$anonfun$run$1.apply(FlatSpecLike.scala:1760) at org.scalatest.FlatSpecLike$$anonfun$run$1.apply(FlatSpecLike.scala:1760) at org.scalatest.SuperEngine.runImpl(Engine.scala:545) at org.scalatest.FlatSpecLike$class.run(FlatSpecLike.scala:1760) at TestSendingReceiving.org$scalatest$BeforeAndAfter$$super$run(TestSendingReceiving.scala:17) at org.scalatest.BeforeAndAfter$class.run(BeforeAndAfter.scala:241) at TestSendingReceiving.run(TestSendingReceiving.scala:17) at org.scalatest.tools.SuiteRunner.run(SuiteRunner.scala:55) at org.scalatest.tools.Runner$$anonfun$doRunRunRunDaDoRunRun$3.apply(Runner.scala:2563) at org.scalatest.tools.Runner$$anonfun$doRunRunRunDaDoRunRun$3.apply(Runner.scala:2557) at scala.collection.immutable.List.foreach(List.scala:318) at org.scalatest.tools.Runner$.doRunRunRunDaDoRunRun(Runner.scala:2557) at org.scalatest.tools.Runner$$anonfun$runOptionallyWithPassFailReporter$2.apply(Runner.scala:1044) at org.scalatest.tools.Runner$$anonfun$runOptionallyWithPassFailReporter$2.apply(Runner.scala:1043) at org.scalatest.tools.Runner$.withClassLoaderAndDispatchReporter(Runner.scala:2722) at org.scalatest.tools.Runner$.runOptionallyWithPassFailReporter(Runner.scala:1043) at org.scalatest.tools.Runner$.run(Runner.scala:883) at org.scalatest.tools.Runner.run(Runner.scala) at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.runScalaTest2(ScalaTestRunner.java:138) at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.main(ScalaTestRunner.java:28) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147)
Any idea to help ?
Many thanks
The whole test roll out here:
/usr/lib/jvm/java-8-oracle/bin/java -Didea.launcher.port=7532 -Didea.launcher.bin.path=/opt/idea-IC-162.1121.32/bin -Dfile.encoding=UTF-8 -classpath /home/sam/.IdeaIC2016.2/config/plugins/Scala/lib/scala-plugin-runners.jar:/usr/lib/jvm/java-8-oracle/jre/lib/charsets.jar:/usr/lib/jvm/java-8-oracle/jre/lib/deploy.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/cldrdata.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/dnsns.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/jaccess.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/jfxrt.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/localedata.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/nashorn.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunec.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunjce_provider.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunpkcs11.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/zipfs.jar:/usr/lib/jvm/java-8-oracle/jre/lib/javaws.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jce.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jfr.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jfxswt.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jsse.jar:/usr/lib/jvm/java-8-oracle/jre/lib/management-agent.jar:/usr/lib/jvm/java-8-oracle/jre/lib/plugin.jar:/usr/lib/jvm/java-8-oracle/jre/lib/resources.jar:/usr/lib/jvm/java-8-oracle/jre/lib/rt.jar:/home/sam/IdeaProjects/affinytix-stream-kafka/target/scala-2.10/test-classes:/home/sam/IdeaProjects/affinytix-stream-kafka/target/scala-2.10/classes:/home/sam/.sbt/boot/scala-2.10.6/lib/scala-library.jar:/home/sam/.ivy2/cache/xml-apis/xml-apis/jars/xml-apis-1.3.04.jar:/home/sam/.ivy2/cache/xmlenc/xmlenc/jars/xmlenc-0.52.jar:/home/sam/.ivy2/cache/xerces/xercesImpl/jars/xercesImpl-2.9.1.jar:/home/sam/.ivy2/cache/org.sonatype.sisu.inject/cglib/jars/cglib-2.2.1-v20090111.jar:/home/sam/.ivy2/cache/org.fusesource.leveldbjni/leveldbjni-all/bundles/leveldbjni-all-1.8.jar:/home/sam/.ivy2/cache/org.codehaus.jettison/jettison/bundles/jettison-1.1.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-xc/jars/jackson-xc-1.9.13.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-jaxrs/jars/jackson-jaxrs-1.9.13.jar:/home/sam/.ivy2/cache/org.apache.zookeeper/zookeeper/jars/zookeeper-3.4.6.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.httpcomponents/httpcore/jars/httpcore-4.2.4.jar:/home/sam/.ivy2/cache/org.apache.httpcomponents/httpclient/jars/httpclient-4.2.5.jar:/home/sam/.ivy2/cache/org.apache.htrace/htrace-core/jars/htrace-core-3.1.0-incubating.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-server-common/jars/hadoop-yarn-server-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-registry/jars/hadoop-yarn-registry-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-common/jars/hadoop-yarn-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-client/jars/hadoop-yarn-client-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-api/jars/hadoop-yarn-api-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-shuffle/jars/hadoop-mapreduce-client-shuffle-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-jobclient/jars/hadoop-mapreduce-client-jobclient-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-core/jars/hadoop-mapreduce-client-core-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-common/jars/hadoop-mapreduce-client-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-app/jars/hadoop-mapreduce-client-app-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-hdfs/jars/hadoop-hdfs-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-common/jars/hadoop-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-client/jars/hadoop-client-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-auth/jars/hadoop-auth-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-annotations/jars/hadoop-annotations-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.directory.server/apacheds-kerberos-codec/bundles/apacheds-kerberos-codec-2.0.0-M15.jar:/home/sam/.ivy2/cache/org.apache.directory.server/apacheds-i18n/bundles/apacheds-i18n-2.0.0-M15.jar:/home/sam/.ivy2/cache/org.apache.directory.api/api-util/bundles/api-util-1.0.0-M20.jar:/home/sam/.ivy2/cache/org.apache.directory.api/api-asn1-api/bundles/api-asn1-api-1.0.0-M20.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-recipes/bundles/curator-recipes-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-framework/bundles/curator-framework-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-client/bundles/curator-client-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-math3/jars/commons-math3-3.1.1.jar:/home/sam/.ivy2/cache/log4j/log4j/bundles/log4j-1.2.17.jar:/home/sam/.ivy2/cache/junit/junit/jars/junit-3.8.1.jar:/home/sam/.ivy2/cache/javax.xml.stream/stax-api/jars/stax-api-1.0-2.jar:/home/sam/.ivy2/cache/javax.xml.bind/jaxb-api/jars/jaxb-api-2.2.2.jar:/home/sam/.ivy2/cache/javax.servlet.jsp/jsp-api/jars/jsp-api-2.1.jar:/home/sam/.ivy2/cache/javax.servlet/servlet-api/jars/servlet-api-2.5.jar:/home/sam/.ivy2/cache/javax.inject/javax.inject/jars/javax.inject-1.jar:/home/sam/.ivy2/cache/javax.activation/activation/jars/activation-1.1.jar:/home/sam/.ivy2/cache/io.netty/netty-all/jars/netty-all-4.0.23.Final.jar:/home/sam/.ivy2/cache/io.netty/netty/bundles/netty-3.7.0.Final.jar:/home/sam/.ivy2/cache/commons-net/commons-net/jars/commons-net-3.1.jar:/home/sam/.ivy2/cache/commons-logging/commons-logging/jars/commons-logging-1.1.3.jar:/home/sam/.ivy2/cache/commons-io/commons-io/jars/commons-io-2.4.jar:/home/sam/.ivy2/cache/commons-digester/commons-digester/jars/commons-digester-1.8.jar:/home/sam/.ivy2/cache/commons-configuration/commons-configuration/jars/commons-configuration-1.6.jar:/home/sam/.ivy2/cache/commons-collections/commons-collections/jars/commons-collections-3.2.2.jar:/home/sam/.ivy2/cache/commons-beanutils/commons-beanutils-core/jars/commons-beanutils-core-1.8.0.jar:/home/sam/.ivy2/cache/commons-beanutils/commons-beanutils/jars/commons-beanutils-1.7.0.jar:/home/sam/.ivy2/cache/com.sun.xml.bind/jaxb-impl/jars/jaxb-impl-2.2.3-1.jar:/home/sam/.ivy2/cache/com.sun.jersey.contribs/jersey-guice/jars/jersey-guice-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-server/bundles/jersey-server-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-json/bundles/jersey-json-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-core/bundles/jersey-core-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-client/bundles/jersey-client-1.9.jar:/home/sam/.ivy2/cache/com.squareup.okio/okio/jars/okio-1.4.0.jar:/home/sam/.ivy2/cache/com.squareup.okhttp/okhttp/jars/okhttp-2.4.0.jar:/home/sam/.ivy2/cache/com.microsoft.windowsazure.storage/microsoft-windowsazure-storage-sdk/jars/microsoft-windowsazure-storage-sdk-0.6.0.jar:/home/sam/.ivy2/cache/com.jamesmurty.utils/java-xmlbuilder/jars/java-xmlbuilder-0.4.jar:/home/sam/.ivy2/cache/com.google.protobuf/protobuf-java/bundles/protobuf-java-2.5.0.jar:/home/sam/.ivy2/cache/com.google.inject/guice/jars/guice-3.0.jar:/home/sam/.ivy2/cache/com.google.code.gson/gson/jars/gson-2.2.4.jar:/home/sam/.ivy2/cache/com.google.code.findbugs/jsr305/jars/jsr305-3.0.0.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-common/jars/hadoop-mini-clusters-common-0.1.7.jar:/home/sam/.ivy2/cache/com.fasterxml.jackson.core/jackson-core/jars/jackson-core-2.2.3.jar:/home/sam/.ivy2/cache/asm/asm/jars/asm-3.1.jar:/home/sam/.ivy2/cache/aopalliance/aopalliance/jars/aopalliance-1.0.jar:/home/sam/.ivy2/cache/com.affinytix.model/affinytix-model-msg_2.10/jars/affinytix-model-msg_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.google.guava/guava/bundles/guava-19.0.jar:/home/sam/.ivy2/cache/net.jpountz.lz4/lz4/jars/lz4-1.2.0.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka-clients/jars/kafka-clients-0.9.0.1.jar:/home/sam/.sbt/boot/scala-2.10.6/lib/scala-reflect.jar:/home/sam/.ivy2/cache/org.scalatest/scalatest_2.10/bundles/scalatest_2.10-2.2.6.jar:/home/sam/.ivy2/cache/org.xerial.snappy/snappy-java/bundles/snappy-java-1.1.1.7.jar:/home/sam/.ivy2/cache/com.typesafe/config/bundles/config-1.3.0.jar:/home/sam/.ivy2/cache/com.affinytix.exception/affinytix-exception_2.10/jars/affinytix-exception_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.affinytix.util/affinytix-util_2.10/jars/affinytix-util_2.10-1.1.0.jar:/home/sam/.ivy2/cache/com.affinytix.stream/affinytix-stream-serializer_2.10/jars/affinytix-stream-serializer_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.github.stephenc.findbugs/findbugs-annotations/jars/findbugs-annotations-1.3.9-1.jar:/home/sam/.ivy2/cache/com.thoughtworks.paranamer/paranamer/bundles/paranamer-2.7.jar:/home/sam/.ivy2/cache/commons-cli/commons-cli/jars/commons-cli-1.2.jar:/home/sam/.ivy2/cache/commons-codec/commons-codec/jars/commons-codec-1.9.jar:/home/sam/.ivy2/cache/commons-collections/commons-collections/jars/commons-collections-3.2.1.jar:/home/sam/.ivy2/cache/commons-httpclient/commons-httpclient/jars/commons-httpclient-3.1.jar:/home/sam/.ivy2/cache/commons-lang/commons-lang/jars/commons-lang-2.6.jar:/home/sam/.ivy2/cache/commons-logging/commons-logging/jars/commons-logging-1.1.1.jar:/home/sam/.ivy2/cache/io.netty/netty/bundles/netty-3.5.13.Final.jar:/home/sam/.ivy2/cache/joda-time/joda-time/jars/joda-time-2.7.jar:/home/sam/.ivy2/cache/net.sf.jopt-simple/jopt-simple/jars/jopt-simple-4.7.jar:/home/sam/.ivy2/cache/org.apache.avro/avro/jars/avro-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-compiler/bundles/avro-compiler-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-ipc/jars/avro-ipc-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-mapred/jars/avro-mapred-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-tools/jars/avro-tools-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-avro/jars/trevni-avro-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-avro/jars/trevni-avro-1.8.1-tests.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-core/jars/trevni-core-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-core/jars/trevni-core-1.8.1-tests.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-compress/jars/commons-compress-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.velocity/velocity/jars/velocity-1.7.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-core-asl/jars/jackson-core-asl-1.9.13.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-mapper-asl/jars/jackson-mapper-asl-1.9.13.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/jetty/jars/jetty-6.1.26.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/jetty-util/jars/jetty-util-6.1.26.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/servlet-api/jars/servlet-api-2.5-20081211.jar:/home/sam/.ivy2/cache/org.tukaani/xz/jars/xz-1.5.jar:/home/sam/.ivy2/cache/com.101tec/zkclient/jars/zkclient-0.7.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-kafka/jars/hadoop-mini-clusters-kafka-0.1.7.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-zookeeper/jars/hadoop-mini-clusters-zookeeper-0.1.7.jar:/home/sam/.ivy2/cache/com.yammer.metrics/metrics-core/jars/metrics-core-2.2.0.jar:/home/sam/.ivy2/cache/net.sf.jopt-simple/jopt-simple/jars/jopt-simple-4.9.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-math/jars/commons-math-2.2.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-test/jars/curator-test-2.5.0.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka-clients/jars/kafka-clients-0.9.0.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka_2.10/jars/kafka_2.10-0.9.0.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.javassist/javassist/bundles/javassist-3.18.1-GA.jar:/home/sam/.ivy2/cache/org.slf4j/slf4j-api/jars/slf4j-api-1.7.6.jar:/home/sam/.ivy2/cache/org.xerial.snappy/snappy-java/bundles/snappy-java-1.1.2.jar:/opt/idea-IC-162.1121.32/lib/idea_rt.jar com.intellij.rt.execution.application.AppMain org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner -s TestSendingReceiving -testName "A receiver should be able to consume on on topic with one partition" -showProgressMessages true -C org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestReporter
Testing started at 5:38 AM ...
2016-08-02 05:38:05 INFO ZookeeperLocalCluster:174 - ZOOKEEPER: Starting Zookeeper on port: 23456
2016-08-02 05:38:06 INFO ZooKeeperServerMain:95 - Starting server
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:zookeeper.version=3.4.6-258--1, built on 04/25/2016 05:22 GMT
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:host.name=sam-dell
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:java.version=1.8.0_101
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:java.vendor=Oracle Corporation
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:java.home=/usr/lib/jvm/java-8-oracle/jre
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:java.class.path=/home/sam/.IdeaIC2016.2/config/plugins/Scala/lib/scala-plugin-runners.jar:/usr/lib/jvm/java-8-oracle/jre/lib/charsets.jar:/usr/lib/jvm/java-8-oracle/jre/lib/deploy.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/cldrdata.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/dnsns.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/jaccess.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/jfxrt.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/localedata.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/nashorn.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunec.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunjce_provider.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunpkcs11.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/zipfs.jar:/usr/lib/jvm/java-8-oracle/jre/lib/javaws.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jce.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jfr.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jfxswt.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jsse.jar:/usr/lib/jvm/java-8-oracle/jre/lib/management-agent.jar:/usr/lib/jvm/java-8-oracle/jre/lib/plugin.jar:/usr/lib/jvm/java-8-oracle/jre/lib/resources.jar:/usr/lib/jvm/java-8-oracle/jre/lib/rt.jar:/home/sam/IdeaProjects/affinytix-stream-kafka/target/scala-2.10/test-classes:/home/sam/IdeaProjects/affinytix-stream-kafka/target/scala-2.10/classes:/home/sam/.sbt/boot/scala-2.10.6/lib/scala-library.jar:/home/sam/.ivy2/cache/xml-apis/xml-apis/jars/xml-apis-1.3.04.jar:/home/sam/.ivy2/cache/xmlenc/xmlenc/jars/xmlenc-0.52.jar:/home/sam/.ivy2/cache/xerces/xercesImpl/jars/xercesImpl-2.9.1.jar:/home/sam/.ivy2/cache/org.sonatype.sisu.inject/cglib/jars/cglib-2.2.1-v20090111.jar:/home/sam/.ivy2/cache/org.fusesource.leveldbjni/leveldbjni-all/bundles/leveldbjni-all-1.8.jar:/home/sam/.ivy2/cache/org.codehaus.jettison/jettison/bundles/jettison-1.1.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-xc/jars/jackson-xc-1.9.13.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-jaxrs/jars/jackson-jaxrs-1.9.13.jar:/home/sam/.ivy2/cache/org.apache.zookeeper/zookeeper/jars/zookeeper-3.4.6.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.httpcomponents/httpcore/jars/httpcore-4.2.4.jar:/home/sam/.ivy2/cache/org.apache.httpcomponents/httpclient/jars/httpclient-4.2.5.jar:/home/sam/.ivy2/cache/org.apache.htrace/htrace-core/jars/htrace-core-3.1.0-incubating.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-server-common/jars/hadoop-yarn-server-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-registry/jars/hadoop-yarn-registry-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-common/jars/hadoop-yarn-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-client/jars/hadoop-yarn-client-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-api/jars/hadoop-yarn-api-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-shuffle/jars/hadoop-mapreduce-client-shuffle-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-jobclient/jars/hadoop-mapreduce-client-jobclient-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-core/jars/hadoop-mapreduce-client-core-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-common/jars/hadoop-mapreduce-client-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-app/jars/hadoop-mapreduce-client-app-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-hdfs/jars/hadoop-hdfs-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-common/jars/hadoop-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-client/jars/hadoop-client-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-auth/jars/hadoop-auth-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-annotations/jars/hadoop-annotations-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.directory.server/apacheds-kerberos-codec/bundles/apacheds-kerberos-codec-2.0.0-M15.jar:/home/sam/.ivy2/cache/org.apache.directory.server/apacheds-i18n/bundles/apacheds-i18n-2.0.0-M15.jar:/home/sam/.ivy2/cache/org.apache.directory.api/api-util/bundles/api-util-1.0.0-M20.jar:/home/sam/.ivy2/cache/org.apache.directory.api/api-asn1-api/bundles/api-asn1-api-1.0.0-M20.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-recipes/bundles/curator-recipes-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-framework/bundles/curator-framework-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-client/bundles/curator-client-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-math3/jars/commons-math3-3.1.1.jar:/home/sam/.ivy2/cache/log4j/log4j/bundles/log4j-1.2.17.jar:/home/sam/.ivy2/cache/junit/junit/jars/junit-3.8.1.jar:/home/sam/.ivy2/cache/javax.xml.stream/stax-api/jars/stax-api-1.0-2.jar:/home/sam/.ivy2/cache/javax.xml.bind/jaxb-api/jars/jaxb-api-2.2.2.jar:/home/sam/.ivy2/cache/javax.servlet.jsp/jsp-api/jars/jsp-api-2.1.jar:/home/sam/.ivy2/cache/javax.servlet/servlet-api/jars/servlet-api-2.5.jar:/home/sam/.ivy2/cache/javax.inject/javax.inject/jars/javax.inject-1.jar:/home/sam/.ivy2/cache/javax.activation/activation/jars/activation-1.1.jar:/home/sam/.ivy2/cache/io.netty/netty-all/jars/netty-all-4.0.23.Final.jar:/home/sam/.ivy2/cache/io.netty/netty/bundles/netty-3.7.0.Final.jar:/home/sam/.ivy2/cache/commons-net/commons-net/jars/commons-net-3.1.jar:/home/sam/.ivy2/cache/commons-logging/commons-logging/jars/commons-logging-1.1.3.jar:/home/sam/.ivy2/cache/commons-io/commons-io/jars/commons-io-2.4.jar:/home/sam/.ivy2/cache/commons-digester/commons-digester/jars/commons-digester-1.8.jar:/home/sam/.ivy2/cache/commons-configuration/commons-configuration/jars/commons-configuration-1.6.jar:/home/sam/.ivy2/cache/commons-collections/commons-collections/jars/commons-collections-3.2.2.jar:/home/sam/.ivy2/cache/commons-beanutils/commons-beanutils-core/jars/commons-beanutils-core-1.8.0.jar:/home/sam/.ivy2/cache/commons-beanutils/commons-beanutils/jars/commons-beanutils-1.7.0.jar:/home/sam/.ivy2/cache/com.sun.xml.bind/jaxb-impl/jars/jaxb-impl-2.2.3-1.jar:/home/sam/.ivy2/cache/com.sun.jersey.contribs/jersey-guice/jars/jersey-guice-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-server/bundles/jersey-server-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-json/bundles/jersey-json-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-core/bundles/jersey-core-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-client/bundles/jersey-client-1.9.jar:/home/sam/.ivy2/cache/com.squareup.okio/okio/jars/okio-1.4.0.jar:/home/sam/.ivy2/cache/com.squareup.okhttp/okhttp/jars/okhttp-2.4.0.jar:/home/sam/.ivy2/cache/com.microsoft.windowsazure.storage/microsoft-windowsazure-storage-sdk/jars/microsoft-windowsazure-storage-sdk-0.6.0.jar:/home/sam/.ivy2/cache/com.jamesmurty.utils/java-xmlbuilder/jars/java-xmlbuilder-0.4.jar:/home/sam/.ivy2/cache/com.google.protobuf/protobuf-java/bundles/protobuf-java-2.5.0.jar:/home/sam/.ivy2/cache/com.google.inject/guice/jars/guice-3.0.jar:/home/sam/.ivy2/cache/com.google.code.gson/gson/jars/gson-2.2.4.jar:/home/sam/.ivy2/cache/com.google.code.findbugs/jsr305/jars/jsr305-3.0.0.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-common/jars/hadoop-mini-clusters-common-0.1.7.jar:/home/sam/.ivy2/cache/com.fasterxml.jackson.core/jackson-core/jars/jackson-core-2.2.3.jar:/home/sam/.ivy2/cache/asm/asm/jars/asm-3.1.jar:/home/sam/.ivy2/cache/aopalliance/aopalliance/jars/aopalliance-1.0.jar:/home/sam/.ivy2/cache/com.affinytix.model/affinytix-model-msg_2.10/jars/affinytix-model-msg_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.google.guava/guava/bundles/guava-19.0.jar:/home/sam/.ivy2/cache/net.jpountz.lz4/lz4/jars/lz4-1.2.0.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka-clients/jars/kafka-clients-0.9.0.1.jar:/home/sam/.sbt/boot/scala-2.10.6/lib/scala-reflect.jar:/home/sam/.ivy2/cache/org.scalatest/scalatest_2.10/bundles/scalatest_2.10-2.2.6.jar:/home/sam/.ivy2/cache/org.xerial.snappy/snappy-java/bundles/snappy-java-1.1.1.7.jar:/home/sam/.ivy2/cache/com.typesafe/config/bundles/config-1.3.0.jar:/home/sam/.ivy2/cache/com.affinytix.exception/affinytix-exception_2.10/jars/affinytix-exception_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.affinytix.util/affinytix-util_2.10/jars/affinytix-util_2.10-1.1.0.jar:/home/sam/.ivy2/cache/com.affinytix.stream/affinytix-stream-serializer_2.10/jars/affinytix-stream-serializer_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.github.stephenc.findbugs/findbugs-annotations/jars/findbugs-annotations-1.3.9-1.jar:/home/sam/.ivy2/cache/com.thoughtworks.paranamer/paranamer/bundles/paranamer-2.7.jar:/home/sam/.ivy2/cache/commons-cli/commons-cli/jars/commons-cli-1.2.jar:/home/sam/.ivy2/cache/commons-codec/commons-codec/jars/commons-codec-1.9.jar:/home/sam/.ivy2/cache/commons-collections/commons-collections/jars/commons-collections-3.2.1.jar:/home/sam/.ivy2/cache/commons-httpclient/commons-httpclient/jars/commons-httpclient-3.1.jar:/home/sam/.ivy2/cache/commons-lang/commons-lang/jars/commons-lang-2.6.jar:/home/sam/.ivy2/cache/commons-logging/commons-logging/jars/commons-logging-1.1.1.jar:/home/sam/.ivy2/cache/io.netty/netty/bundles/netty-3.5.13.Final.jar:/home/sam/.ivy2/cache/joda-time/joda-time/jars/joda-time-2.7.jar:/home/sam/.ivy2/cache/net.sf.jopt-simple/jopt-simple/jars/jopt-simple-4.7.jar:/home/sam/.ivy2/cache/org.apache.avro/avro/jars/avro-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-compiler/bundles/avro-compiler-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-ipc/jars/avro-ipc-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-mapred/jars/avro-mapred-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-tools/jars/avro-tools-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-avro/jars/trevni-avro-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-avro/jars/trevni-avro-1.8.1-tests.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-core/jars/trevni-core-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-core/jars/trevni-core-1.8.1-tests.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-compress/jars/commons-compress-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.velocity/velocity/jars/velocity-1.7.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-core-asl/jars/jackson-core-asl-1.9.13.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-mapper-asl/jars/jackson-mapper-asl-1.9.13.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/jetty/jars/jetty-6.1.26.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/jetty-util/jars/jetty-util-6.1.26.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/servlet-api/jars/servlet-api-2.5-20081211.jar:/home/sam/.ivy2/cache/org.tukaani/xz/jars/xz-1.5.jar:/home/sam/.ivy2/cache/com.101tec/zkclient/jars/zkclient-0.7.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-kafka/jars/hadoop-mini-clusters-kafka-0.1.7.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-zookeeper/jars/hadoop-mini-clusters-zookeeper-0.1.7.jar:/home/sam/.ivy2/cache/com.yammer.metrics/metrics-core/jars/metrics-core-2.2.0.jar:/home/sam/.ivy2/cache/net.sf.jopt-simple/jopt-simple/jars/jopt-simple-4.9.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-math/jars/commons-math-2.2.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-test/jars/curator-test-2.5.0.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka-clients/jars/kafka-clients-0.9.0.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka_2.10/jars/kafka_2.10-0.9.0.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.javassist/javassist/bundles/javassist-3.18.1-GA.jar:/home/sam/.ivy2/cache/org.slf4j/slf4j-api/jars/slf4j-api-1.7.6.jar:/home/sam/.ivy2/cache/org.xerial.snappy/snappy-java/bundles/snappy-java-1.1.2.jar:/opt/idea-IC-162.1121.32/lib/idea_rt.jar
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:java.library.path=/opt/idea-IC-162.1121.32/bin::/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:java.io.tmpdir=/tmp
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:java.compiler=
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:os.name=Linux
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:os.arch=amd64
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:os.version=4.4.0-31-generic
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:user.name=sam
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:user.home=/home/sam
2016-08-02 05:38:06 INFO ZooKeeperServer:100 - Server environment:user.dir=/home/sam/IdeaProjects/affinytix-stream-kafka
2016-08-02 05:38:06 INFO ZooKeeperServer:755 - tickTime set to 2000
2016-08-02 05:38:06 INFO ZooKeeperServer:764 - minSessionTimeout set to -1
2016-08-02 05:38:06 INFO ZooKeeperServer:773 - maxSessionTimeout set to -1
2016-08-02 05:38:06 INFO NIOServerCnxnFactory:94 - binding to port 0.0.0.0/0.0.0.0:23456
2016-08-02 05:38:07 INFO KafkaLocalBroker:158 - KAFKA: Starting Kafka on port: 11111
2016-08-02 05:38:07 INFO KafkaConfig:165 - KafkaConfig values:
advertised.host.name = localhost
metric.reporters = []
quota.producer.default = 9223372036854775807
offsets.topic.num.partitions = 50
log.flush.interval.messages = 9223372036854775807
auto.create.topics.enable = true
controller.socket.timeout.ms = 30000
log.flush.interval.ms = null
principal.builder.class = class org.apache.kafka.common.security.auth.DefaultPrincipalBuilder
replica.socket.receive.buffer.bytes = 65536
min.insync.replicas = 1
replica.fetch.wait.max.ms = 500
num.recovery.threads.per.data.dir = 1
ssl.keystore.type = JKS
default.replication.factor = 1
ssl.truststore.password = null
log.preallocate = false
sasl.kerberos.principal.to.local.rules = [DEFAULT]
fetch.purgatory.purge.interval.requests = 1000
ssl.endpoint.identification.algorithm = null
replica.socket.timeout.ms = 30000
message.max.bytes = 1000012
num.io.threads = 8
offsets.commit.required.acks = -1
log.flush.offset.checkpoint.interval.ms = 60000
delete.topic.enable = false
quota.window.size.seconds = 1
ssl.truststore.type = JKS
offsets.commit.timeout.ms = 5000
quota.window.num = 11
zookeeper.connect = localhost:23456
authorizer.class.name =
num.replica.fetchers = 1
log.retention.ms = null
log.roll.jitter.hours = 0
log.cleaner.enable = true
offsets.load.buffer.size = 5242880
log.cleaner.delete.retention.ms = 86400000
ssl.client.auth = none
controlled.shutdown.max.retries = 3
queued.max.requests = 500
offsets.topic.replication.factor = 3
log.cleaner.threads = 1
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
socket.request.max.bytes = 104857600
ssl.trustmanager.algorithm = PKIX
zookeeper.session.timeout.ms = 6000
log.retention.bytes = -1
sasl.kerberos.min.time.before.relogin = 60000
zookeeper.set.acl = false
connections.max.idle.ms = 600000
offsets.retention.minutes = 1440
replica.fetch.backoff.ms = 1000
inter.broker.protocol.version = 0.9.0.X
log.retention.hours = 168
num.partitions = 1
broker.id.generation.enable = true
listeners = null
ssl.provider = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
log.roll.ms = null
log.flush.scheduler.interval.ms = 9223372036854775807
ssl.cipher.suites = null
log.index.size.max.bytes = 10485760
ssl.keymanager.algorithm = SunX509
security.inter.broker.protocol = PLAINTEXT
replica.fetch.max.bytes = 1048576
advertised.port = null
log.cleaner.dedupe.buffer.size = 134217728
replica.high.watermark.checkpoint.interval.ms = 5000
log.cleaner.io.buffer.size = 524288
sasl.kerberos.ticket.renew.window.factor = 0.8
zookeeper.connection.timeout.ms = null
controlled.shutdown.retry.backoff.ms = 5000
log.roll.hours = 168
log.cleanup.policy = delete
host.name =
log.roll.jitter.ms = null
max.connections.per.ip = 2147483647
offsets.topic.segment.bytes = 104857600
background.threads = 10
quota.consumer.default = 9223372036854775807
request.timeout.ms = 30000
log.index.interval.bytes = 4096
log.dir = embedded_kafka
log.segment.bytes = 1073741824
log.cleaner.backoff.ms = 15000
offset.metadata.max.bytes = 4096
ssl.truststore.location = null
group.max.session.timeout.ms = 30000
ssl.keystore.password = null
zookeeper.sync.time.ms = 2000
port = 11111
log.retention.minutes = null
log.segment.delete.delay.ms = 60000
log.dirs = null
controlled.shutdown.enable = true
compression.type = producer
max.connections.per.ip.overrides =
sasl.kerberos.kinit.cmd = /usr/bin/kinit
log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308
auto.leader.rebalance.enable = true
leader.imbalance.check.interval.seconds = 300
log.cleaner.min.cleanable.ratio = 0.5
replica.lag.time.max.ms = 10000
num.network.threads = 3
ssl.key.password = null
reserved.broker.max.id = 1000
metrics.num.samples = 2
socket.send.buffer.bytes = 102400
ssl.protocol = TLS
socket.receive.buffer.bytes = 102400
ssl.keystore.location = null
replica.fetch.min.bytes = 1
unclean.leader.election.enable = true
group.min.session.timeout.ms = 6000
log.cleaner.io.buffer.load.factor = 0.9
offsets.retention.check.interval.ms = 600000
producer.purgatory.purge.interval.requests = 1000
metrics.sample.window.ms = 30000
broker.id = 0
offsets.topic.compression.codec = 0
log.retention.check.interval.ms = 300000
advertised.listeners = null
leader.imbalance.per.broker.percentage = 10
2016-08-02 05:38:07 INFO KafkaServer:68 - starting
2016-08-02 05:38:07 INFO KafkaServer:68 - Connecting to zookeeper on localhost:23456
2016-08-02 05:38:07 INFO ZkEventThread:64 - Starting ZkClient event thread.
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:zookeeper.version=3.4.6-258--1, built on 04/25/2016 05:22 GMT
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:host.name=sam-dell
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:java.version=1.8.0_101
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:java.vendor=Oracle Corporation
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:java.home=/usr/lib/jvm/java-8-oracle/jre
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:java.class.path=/home/sam/.IdeaIC2016.2/config/plugins/Scala/lib/scala-plugin-runners.jar:/usr/lib/jvm/java-8-oracle/jre/lib/charsets.jar:/usr/lib/jvm/java-8-oracle/jre/lib/deploy.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/cldrdata.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/dnsns.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/jaccess.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/jfxrt.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/localedata.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/nashorn.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunec.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunjce_provider.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunpkcs11.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/zipfs.jar:/usr/lib/jvm/java-8-oracle/jre/lib/javaws.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jce.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jfr.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jfxswt.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jsse.jar:/usr/lib/jvm/java-8-oracle/jre/lib/management-agent.jar:/usr/lib/jvm/java-8-oracle/jre/lib/plugin.jar:/usr/lib/jvm/java-8-oracle/jre/lib/resources.jar:/usr/lib/jvm/java-8-oracle/jre/lib/rt.jar:/home/sam/IdeaProjects/affinytix-stream-kafka/target/scala-2.10/test-classes:/home/sam/IdeaProjects/affinytix-stream-kafka/target/scala-2.10/classes:/home/sam/.sbt/boot/scala-2.10.6/lib/scala-library.jar:/home/sam/.ivy2/cache/xml-apis/xml-apis/jars/xml-apis-1.3.04.jar:/home/sam/.ivy2/cache/xmlenc/xmlenc/jars/xmlenc-0.52.jar:/home/sam/.ivy2/cache/xerces/xercesImpl/jars/xercesImpl-2.9.1.jar:/home/sam/.ivy2/cache/org.sonatype.sisu.inject/cglib/jars/cglib-2.2.1-v20090111.jar:/home/sam/.ivy2/cache/org.fusesource.leveldbjni/leveldbjni-all/bundles/leveldbjni-all-1.8.jar:/home/sam/.ivy2/cache/org.codehaus.jettison/jettison/bundles/jettison-1.1.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-xc/jars/jackson-xc-1.9.13.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-jaxrs/jars/jackson-jaxrs-1.9.13.jar:/home/sam/.ivy2/cache/org.apache.zookeeper/zookeeper/jars/zookeeper-3.4.6.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.httpcomponents/httpcore/jars/httpcore-4.2.4.jar:/home/sam/.ivy2/cache/org.apache.httpcomponents/httpclient/jars/httpclient-4.2.5.jar:/home/sam/.ivy2/cache/org.apache.htrace/htrace-core/jars/htrace-core-3.1.0-incubating.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-server-common/jars/hadoop-yarn-server-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-registry/jars/hadoop-yarn-registry-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-common/jars/hadoop-yarn-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-client/jars/hadoop-yarn-client-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-api/jars/hadoop-yarn-api-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-shuffle/jars/hadoop-mapreduce-client-shuffle-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-jobclient/jars/hadoop-mapreduce-client-jobclient-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-core/jars/hadoop-mapreduce-client-core-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-common/jars/hadoop-mapreduce-client-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-app/jars/hadoop-mapreduce-client-app-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-hdfs/jars/hadoop-hdfs-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-common/jars/hadoop-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-client/jars/hadoop-client-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-auth/jars/hadoop-auth-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-annotations/jars/hadoop-annotations-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.directory.server/apacheds-kerberos-codec/bundles/apacheds-kerberos-codec-2.0.0-M15.jar:/home/sam/.ivy2/cache/org.apache.directory.server/apacheds-i18n/bundles/apacheds-i18n-2.0.0-M15.jar:/home/sam/.ivy2/cache/org.apache.directory.api/api-util/bundles/api-util-1.0.0-M20.jar:/home/sam/.ivy2/cache/org.apache.directory.api/api-asn1-api/bundles/api-asn1-api-1.0.0-M20.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-recipes/bundles/curator-recipes-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-framework/bundles/curator-framework-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-client/bundles/curator-client-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-math3/jars/commons-math3-3.1.1.jar:/home/sam/.ivy2/cache/log4j/log4j/bundles/log4j-1.2.17.jar:/home/sam/.ivy2/cache/junit/junit/jars/junit-3.8.1.jar:/home/sam/.ivy2/cache/javax.xml.stream/stax-api/jars/stax-api-1.0-2.jar:/home/sam/.ivy2/cache/javax.xml.bind/jaxb-api/jars/jaxb-api-2.2.2.jar:/home/sam/.ivy2/cache/javax.servlet.jsp/jsp-api/jars/jsp-api-2.1.jar:/home/sam/.ivy2/cache/javax.servlet/servlet-api/jars/servlet-api-2.5.jar:/home/sam/.ivy2/cache/javax.inject/javax.inject/jars/javax.inject-1.jar:/home/sam/.ivy2/cache/javax.activation/activation/jars/activation-1.1.jar:/home/sam/.ivy2/cache/io.netty/netty-all/jars/netty-all-4.0.23.Final.jar:/home/sam/.ivy2/cache/io.netty/netty/bundles/netty-3.7.0.Final.jar:/home/sam/.ivy2/cache/commons-net/commons-net/jars/commons-net-3.1.jar:/home/sam/.ivy2/cache/commons-logging/commons-logging/jars/commons-logging-1.1.3.jar:/home/sam/.ivy2/cache/commons-io/commons-io/jars/commons-io-2.4.jar:/home/sam/.ivy2/cache/commons-digester/commons-digester/jars/commons-digester-1.8.jar:/home/sam/.ivy2/cache/commons-configuration/commons-configuration/jars/commons-configuration-1.6.jar:/home/sam/.ivy2/cache/commons-collections/commons-collections/jars/commons-collections-3.2.2.jar:/home/sam/.ivy2/cache/commons-beanutils/commons-beanutils-core/jars/commons-beanutils-core-1.8.0.jar:/home/sam/.ivy2/cache/commons-beanutils/commons-beanutils/jars/commons-beanutils-1.7.0.jar:/home/sam/.ivy2/cache/com.sun.xml.bind/jaxb-impl/jars/jaxb-impl-2.2.3-1.jar:/home/sam/.ivy2/cache/com.sun.jersey.contribs/jersey-guice/jars/jersey-guice-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-server/bundles/jersey-server-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-json/bundles/jersey-json-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-core/bundles/jersey-core-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-client/bundles/jersey-client-1.9.jar:/home/sam/.ivy2/cache/com.squareup.okio/okio/jars/okio-1.4.0.jar:/home/sam/.ivy2/cache/com.squareup.okhttp/okhttp/jars/okhttp-2.4.0.jar:/home/sam/.ivy2/cache/com.microsoft.windowsazure.storage/microsoft-windowsazure-storage-sdk/jars/microsoft-windowsazure-storage-sdk-0.6.0.jar:/home/sam/.ivy2/cache/com.jamesmurty.utils/java-xmlbuilder/jars/java-xmlbuilder-0.4.jar:/home/sam/.ivy2/cache/com.google.protobuf/protobuf-java/bundles/protobuf-java-2.5.0.jar:/home/sam/.ivy2/cache/com.google.inject/guice/jars/guice-3.0.jar:/home/sam/.ivy2/cache/com.google.code.gson/gson/jars/gson-2.2.4.jar:/home/sam/.ivy2/cache/com.google.code.findbugs/jsr305/jars/jsr305-3.0.0.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-common/jars/hadoop-mini-clusters-common-0.1.7.jar:/home/sam/.ivy2/cache/com.fasterxml.jackson.core/jackson-core/jars/jackson-core-2.2.3.jar:/home/sam/.ivy2/cache/asm/asm/jars/asm-3.1.jar:/home/sam/.ivy2/cache/aopalliance/aopalliance/jars/aopalliance-1.0.jar:/home/sam/.ivy2/cache/com.affinytix.model/affinytix-model-msg_2.10/jars/affinytix-model-msg_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.google.guava/guava/bundles/guava-19.0.jar:/home/sam/.ivy2/cache/net.jpountz.lz4/lz4/jars/lz4-1.2.0.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka-clients/jars/kafka-clients-0.9.0.1.jar:/home/sam/.sbt/boot/scala-2.10.6/lib/scala-reflect.jar:/home/sam/.ivy2/cache/org.scalatest/scalatest_2.10/bundles/scalatest_2.10-2.2.6.jar:/home/sam/.ivy2/cache/org.xerial.snappy/snappy-java/bundles/snappy-java-1.1.1.7.jar:/home/sam/.ivy2/cache/com.typesafe/config/bundles/config-1.3.0.jar:/home/sam/.ivy2/cache/com.affinytix.exception/affinytix-exception_2.10/jars/affinytix-exception_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.affinytix.util/affinytix-util_2.10/jars/affinytix-util_2.10-1.1.0.jar:/home/sam/.ivy2/cache/com.affinytix.stream/affinytix-stream-serializer_2.10/jars/affinytix-stream-serializer_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.github.stephenc.findbugs/findbugs-annotations/jars/findbugs-annotations-1.3.9-1.jar:/home/sam/.ivy2/cache/com.thoughtworks.paranamer/paranamer/bundles/paranamer-2.7.jar:/home/sam/.ivy2/cache/commons-cli/commons-cli/jars/commons-cli-1.2.jar:/home/sam/.ivy2/cache/commons-codec/commons-codec/jars/commons-codec-1.9.jar:/home/sam/.ivy2/cache/commons-collections/commons-collections/jars/commons-collections-3.2.1.jar:/home/sam/.ivy2/cache/commons-httpclient/commons-httpclient/jars/commons-httpclient-3.1.jar:/home/sam/.ivy2/cache/commons-lang/commons-lang/jars/commons-lang-2.6.jar:/home/sam/.ivy2/cache/commons-logging/commons-logging/jars/commons-logging-1.1.1.jar:/home/sam/.ivy2/cache/io.netty/netty/bundles/netty-3.5.13.Final.jar:/home/sam/.ivy2/cache/joda-time/joda-time/jars/joda-time-2.7.jar:/home/sam/.ivy2/cache/net.sf.jopt-simple/jopt-simple/jars/jopt-simple-4.7.jar:/home/sam/.ivy2/cache/org.apache.avro/avro/jars/avro-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-compiler/bundles/avro-compiler-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-ipc/jars/avro-ipc-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-mapred/jars/avro-mapred-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-tools/jars/avro-tools-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-avro/jars/trevni-avro-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-avro/jars/trevni-avro-1.8.1-tests.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-core/jars/trevni-core-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-core/jars/trevni-core-1.8.1-tests.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-compress/jars/commons-compress-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.velocity/velocity/jars/velocity-1.7.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-core-asl/jars/jackson-core-asl-1.9.13.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-mapper-asl/jars/jackson-mapper-asl-1.9.13.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/jetty/jars/jetty-6.1.26.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/jetty-util/jars/jetty-util-6.1.26.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/servlet-api/jars/servlet-api-2.5-20081211.jar:/home/sam/.ivy2/cache/org.tukaani/xz/jars/xz-1.5.jar:/home/sam/.ivy2/cache/com.101tec/zkclient/jars/zkclient-0.7.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-kafka/jars/hadoop-mini-clusters-kafka-0.1.7.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-zookeeper/jars/hadoop-mini-clusters-zookeeper-0.1.7.jar:/home/sam/.ivy2/cache/com.yammer.metrics/metrics-core/jars/metrics-core-2.2.0.jar:/home/sam/.ivy2/cache/net.sf.jopt-simple/jopt-simple/jars/jopt-simple-4.9.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-math/jars/commons-math-2.2.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-test/jars/curator-test-2.5.0.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka-clients/jars/kafka-clients-0.9.0.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka_2.10/jars/kafka_2.10-0.9.0.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.javassist/javassist/bundles/javassist-3.18.1-GA.jar:/home/sam/.ivy2/cache/org.slf4j/slf4j-api/jars/slf4j-api-1.7.6.jar:/home/sam/.ivy2/cache/org.xerial.snappy/snappy-java/bundles/snappy-java-1.1.2.jar:/opt/idea-IC-162.1121.32/lib/idea_rt.jar
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:java.library.path=/opt/idea-IC-162.1121.32/bin::/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:java.io.tmpdir=/tmp
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:java.compiler=
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:os.name=Linux
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:os.arch=amd64
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:os.version=4.4.0-31-generic
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:user.name=sam
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:user.home=/home/sam
2016-08-02 05:38:07 INFO ZooKeeper:100 - Client environment:user.dir=/home/sam/IdeaProjects/affinytix-stream-kafka
2016-08-02 05:38:07 INFO ZooKeeper:438 - Initiating client connection, connectString=localhost:23456 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@710c2b53
2016-08-02 05:38:07 INFO ZkClient:934 - Waiting for keeper state SyncConnected
2016-08-02 05:38:07 INFO ClientCnxn:1019 - Opening socket connection to server localhost/127.0.0.1:23456. Will not attempt to authenticate using SASL (unknown error)
2016-08-02 05:38:07 INFO ClientCnxn:864 - Socket connection established to localhost/127.0.0.1:23456, initiating session
2016-08-02 05:38:07 INFO NIOServerCnxnFactory:197 - Accepted socket connection from /127.0.0.1:37628
2016-08-02 05:38:07 INFO ZooKeeperServer:868 - Client attempting to establish new session at /127.0.0.1:37628
2016-08-02 05:38:07 INFO FileTxnLog:199 - Creating new log file: log.1
2016-08-02 05:38:07 INFO ClientCnxn:1279 - Session establishment complete on server localhost/127.0.0.1:23456, sessionid = 0x156491d83840000, negotiated timeout = 6000
2016-08-02 05:38:07 INFO ZooKeeperServer:617 - Established session 0x156491d83840000 with negotiated timeout 6000 for client /127.0.0.1:37628
2016-08-02 05:38:07 INFO ZkClient:711 - zookeeper state changed (SyncConnected)
2016-08-02 05:38:07 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x5 zxid:0x3 txntype:-1 reqpath:n/a Error Path:/brokers Error:KeeperErrorCode = NoNode for /brokers
2016-08-02 05:38:07 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xb zxid:0x7 txntype:-1 reqpath:n/a Error Path:/config Error:KeeperErrorCode = NoNode for /config
2016-08-02 05:38:08 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x13 zxid:0xc txntype:-1 reqpath:n/a Error Path:/admin Error:KeeperErrorCode = NoNode for /admin
2016-08-02 05:38:08 INFO LogManager:68 - Log directory '/home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka' not found, creating it.
2016-08-02 05:38:08 INFO LogManager:68 - Loading logs.
2016-08-02 05:38:08 INFO LogManager:68 - Logs loading complete.
2016-08-02 05:38:08 INFO LogManager:68 - Starting log cleanup with a period of 300000 ms.
2016-08-02 05:38:08 INFO LogManager:68 - Starting log flusher with a default period of 9223372036854775807 ms.
2016-08-02 05:38:08 INFO LogCleaner:68 - Starting the log cleaner
2016-08-02 05:38:08 INFO LogCleaner:68 - [kafka-log-cleaner-thread-0], Starting
2016-08-02 05:38:08 WARN BrokerMetadataCheckpoint:83 - No meta.properties file under dir /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/meta.properties
2016-08-02 05:38:08 INFO Acceptor:68 - Awaiting socket connections on 0.0.0.0:11111.
2016-08-02 05:38:08 INFO SocketServer:68 - [Socket Server on Broker 0], Started 1 acceptor threads
2016-08-02 05:38:08 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Starting
2016-08-02 05:38:08 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Starting
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Controller starting up
2016-08-02 05:38:08 INFO ZKCheckedEphemeral:68 - Creating /controller (is it secure? false)
2016-08-02 05:38:08 INFO ZKCheckedEphemeral:68 - Result of znode creation is: OK
2016-08-02 05:38:08 INFO ZookeeperLeaderElector:68 - 0 successfully elected as leader
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Broker 0 starting become controller state transition
2016-08-02 05:38:08 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:setData cxid:0x21 zxid:0x12 txntype:-1 reqpath:n/a Error Path:/controller_epoch Error:KeeperErrorCode = NoNode for /controller_epoch
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Controller 0 incremented epoch to 1
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Partitions undergoing preferred replica election:
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Partitions that completed preferred replica election:
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Resuming preferred replica election for partitions:
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Partitions being reassigned: Map()
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Partitions already reassigned: List()
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Resuming reassignment of partitions: Map()
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: List of topics to be deleted:
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: List of topics ineligible for deletion:
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Currently active brokers in the cluster: Set()
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Currently shutting brokers in the cluster: Set()
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Current list of topics in the cluster: Set()
2016-08-02 05:38:08 INFO ReplicaStateMachine:68 - [Replica state machine on controller 0]: Started replica state machine with initial state -> Map()
2016-08-02 05:38:08 INFO PartitionStateMachine:68 - [Partition state machine on Controller 0]: Started partition state machine with initial state -> Map()
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Broker 0 is ready to serve as the new controller with epoch 1
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Starting preferred replica leader election for partitions
2016-08-02 05:38:08 INFO PartitionStateMachine:68 - [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions
2016-08-02 05:38:08 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:delete cxid:0x30 zxid:0x14 txntype:-1 reqpath:n/a Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: starting the partition rebalance scheduler
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: Controller startup complete
2016-08-02 05:38:08 INFO GroupCoordinator:68 - [GroupCoordinator 0]: Starting up.
2016-08-02 05:38:08 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Starting
2016-08-02 05:38:08 INFO GroupCoordinator:68 - [GroupCoordinator 0]: Startup complete.
2016-08-02 05:38:08 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Removed 0 expired offsets in 45 milliseconds.
2016-08-02 05:38:08 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Starting
2016-08-02 05:38:08 INFO ClientQuotaManager$ThrottledRequestReaper:68 - [ThrottledRequestReaper-Produce], Starting
2016-08-02 05:38:08 INFO ClientQuotaManager$ThrottledRequestReaper:68 - [ThrottledRequestReaper-Fetch], Starting
2016-08-02 05:38:08 INFO Mx4jLoader$:68 - Will not load MX4J, mx4j-tools.jar is not in the classpath
2016-08-02 05:38:08 INFO ZKCheckedEphemeral:68 - Creating /brokers/ids/0 (is it secure? false)
2016-08-02 05:38:08 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x37 zxid:0x15 txntype:-1 reqpath:n/a Error Path:/brokers Error:KeeperErrorCode = NodeExists for /brokers
2016-08-02 05:38:08 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x38 zxid:0x16 txntype:-1 reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists for /brokers/ids
2016-08-02 05:38:08 INFO ZookeeperLeaderElector$LeaderChangeListener:68 - New leader is 0
2016-08-02 05:38:08 INFO ZKCheckedEphemeral:68 - Result of znode creation is: OK
2016-08-02 05:38:08 INFO ZkUtils:68 - Registered broker 0 at path /brokers/ids/0 with addresses: PLAINTEXT -> EndPoint(localhost,11111,PLAINTEXT)
2016-08-02 05:38:08 INFO ReplicaStateMachine$BrokerChangeListener:68 - [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0
2016-08-02 05:38:08 INFO AppInfoParser:82 - Kafka version : 0.9.0.1
2016-08-02 05:38:08 INFO AppInfoParser:83 - Kafka commitId : 23c69d62a0cabf06
2016-08-02 05:38:08 INFO KafkaServer:68 - [Kafka Server 0], started
2016-08-02 05:38:08 INFO ReplicaStateMachine$BrokerChangeListener:68 - [BrokerChangeListener on Controller 0]: Newly added brokers: 0, deleted brokers: , all live brokers: 0
2016-08-02 05:38:08 INFO RequestSendThread:68 - [kafka-mini-cluster:Controller-0-to-broker-0-send-thread], Starting
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: New broker startup callback for 0
2016-08-02 05:38:08 INFO RequestSendThread:68 - [kafka-mini-cluster:Controller-0-to-broker-0-send-thread], Controller 0 connected to Node(0, localhost, 11111) for sending state change requests
2016-08-02 05:38:08 INFO ConfigLoader:99 - Load conf at : kafka-producer-test-string.json
2016-08-02 05:38:08 INFO ConfigLoader:100 - Config(SimpleConfigObject({"awt":{"toolkit":"sun.awt.X11.XToolkit"},"file":{"encoding":{"pkg":"sun.io"},"separator":"/"},"idea":{"launcher":{"bin":{"path":"/opt/idea-IC-162.1121.32/bin"},"port":"7532"}},"java":{"awt":{"graphicsenv":"sun.awt.X11GraphicsEnvironment","printerjob":"sun.print.PSPrinterJob"},"class":{"path":"/home/sam/.IdeaIC2016.2/config/plugins/Scala/lib/scala-plugin-runners.jar:/usr/lib/jvm/java-8-oracle/jre/lib/charsets.jar:/usr/lib/jvm/java-8-oracle/jre/lib/deploy.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/cldrdata.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/dnsns.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/jaccess.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/jfxrt.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/localedata.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/nashorn.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunec.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunjce_provider.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunpkcs11.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/zipfs.jar:/usr/lib/jvm/java-8-oracle/jre/lib/javaws.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jce.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jfr.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jfxswt.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jsse.jar:/usr/lib/jvm/java-8-oracle/jre/lib/management-agent.jar:/usr/lib/jvm/java-8-oracle/jre/lib/plugin.jar:/usr/lib/jvm/java-8-oracle/jre/lib/resources.jar:/usr/lib/jvm/java-8-oracle/jre/lib/rt.jar:/home/sam/IdeaProjects/affinytix-stream-kafka/target/scala-2.10/test-classes:/home/sam/IdeaProjects/affinytix-stream-kafka/target/scala-2.10/classes:/home/sam/.sbt/boot/scala-2.10.6/lib/scala-library.jar:/home/sam/.ivy2/cache/xml-apis/xml-apis/jars/xml-apis-1.3.04.jar:/home/sam/.ivy2/cache/xmlenc/xmlenc/jars/xmlenc-0.52.jar:/home/sam/.ivy2/cache/xerces/xercesImpl/jars/xercesImpl-2.9.1.jar:/home/sam/.ivy2/cache/org.sonatype.sisu.inject/cglib/jars/cglib-2.2.1-v20090111.jar:/home/sam/.ivy2/cache/org.fusesource.leveldbjni/leveldbjni-all/bundles/leveldbjni-all-1.8.jar:/home/sam/.ivy2/cache/org.codehaus.jettison/jettison/bundles/jettison-1.1.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-xc/jars/jackson-xc-1.9.13.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-jaxrs/jars/jackson-jaxrs-1.9.13.jar:/home/sam/.ivy2/cache/org.apache.zookeeper/zookeeper/jars/zookeeper-3.4.6.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.httpcomponents/httpcore/jars/httpcore-4.2.4.jar:/home/sam/.ivy2/cache/org.apache.httpcomponents/httpclient/jars/httpclient-4.2.5.jar:/home/sam/.ivy2/cache/org.apache.htrace/htrace-core/jars/htrace-core-3.1.0-incubating.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-server-common/jars/hadoop-yarn-server-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-registry/jars/hadoop-yarn-registry-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-common/jars/hadoop-yarn-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-client/jars/hadoop-yarn-client-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-api/jars/hadoop-yarn-api-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-shuffle/jars/hadoop-mapreduce-client-shuffle-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-jobclient/jars/hadoop-mapreduce-client-jobclient-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-core/jars/hadoop-mapreduce-client-core-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-common/jars/hadoop-mapreduce-client-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-app/jars/hadoop-mapreduce-client-app-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-hdfs/jars/hadoop-hdfs-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-common/jars/hadoop-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-client/jars/hadoop-client-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-auth/jars/hadoop-auth-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-annotations/jars/hadoop-annotations-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.directory.server/apacheds-kerberos-codec/bundles/apacheds-kerberos-codec-2.0.0-M15.jar:/home/sam/.ivy2/cache/org.apache.directory.server/apacheds-i18n/bundles/apacheds-i18n-2.0.0-M15.jar:/home/sam/.ivy2/cache/org.apache.directory.api/api-util/bundles/api-util-1.0.0-M20.jar:/home/sam/.ivy2/cache/org.apache.directory.api/api-asn1-api/bundles/api-asn1-api-1.0.0-M20.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-recipes/bundles/curator-recipes-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-framework/bundles/curator-framework-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-client/bundles/curator-client-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-math3/jars/commons-math3-3.1.1.jar:/home/sam/.ivy2/cache/log4j/log4j/bundles/log4j-1.2.17.jar:/home/sam/.ivy2/cache/junit/junit/jars/junit-3.8.1.jar:/home/sam/.ivy2/cache/javax.xml.stream/stax-api/jars/stax-api-1.0-2.jar:/home/sam/.ivy2/cache/javax.xml.bind/jaxb-api/jars/jaxb-api-2.2.2.jar:/home/sam/.ivy2/cache/javax.servlet.jsp/jsp-api/jars/jsp-api-2.1.jar:/home/sam/.ivy2/cache/javax.servlet/servlet-api/jars/servlet-api-2.5.jar:/home/sam/.ivy2/cache/javax.inject/javax.inject/jars/javax.inject-1.jar:/home/sam/.ivy2/cache/javax.activation/activation/jars/activation-1.1.jar:/home/sam/.ivy2/cache/io.netty/netty-all/jars/netty-all-4.0.23.Final.jar:/home/sam/.ivy2/cache/io.netty/netty/bundles/netty-3.7.0.Final.jar:/home/sam/.ivy2/cache/commons-net/commons-net/jars/commons-net-3.1.jar:/home/sam/.ivy2/cache/commons-logging/commons-logging/jars/commons-logging-1.1.3.jar:/home/sam/.ivy2/cache/commons-io/commons-io/jars/commons-io-2.4.jar:/home/sam/.ivy2/cache/commons-digester/commons-digester/jars/commons-digester-1.8.jar:/home/sam/.ivy2/cache/commons-configuration/commons-configuration/jars/commons-configuration-1.6.jar:/home/sam/.ivy2/cache/commons-collections/commons-collections/jars/commons-collections-3.2.2.jar:/home/sam/.ivy2/cache/commons-beanutils/commons-beanutils-core/jars/commons-beanutils-core-1.8.0.jar:/home/sam/.ivy2/cache/commons-beanutils/commons-beanutils/jars/commons-beanutils-1.7.0.jar:/home/sam/.ivy2/cache/com.sun.xml.bind/jaxb-impl/jars/jaxb-impl-2.2.3-1.jar:/home/sam/.ivy2/cache/com.sun.jersey.contribs/jersey-guice/jars/jersey-guice-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-server/bundles/jersey-server-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-json/bundles/jersey-json-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-core/bundles/jersey-core-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-client/bundles/jersey-client-1.9.jar:/home/sam/.ivy2/cache/com.squareup.okio/okio/jars/okio-1.4.0.jar:/home/sam/.ivy2/cache/com.squareup.okhttp/okhttp/jars/okhttp-2.4.0.jar:/home/sam/.ivy2/cache/com.microsoft.windowsazure.storage/microsoft-windowsazure-storage-sdk/jars/microsoft-windowsazure-storage-sdk-0.6.0.jar:/home/sam/.ivy2/cache/com.jamesmurty.utils/java-xmlbuilder/jars/java-xmlbuilder-0.4.jar:/home/sam/.ivy2/cache/com.google.protobuf/protobuf-java/bundles/protobuf-java-2.5.0.jar:/home/sam/.ivy2/cache/com.google.inject/guice/jars/guice-3.0.jar:/home/sam/.ivy2/cache/com.google.code.gson/gson/jars/gson-2.2.4.jar:/home/sam/.ivy2/cache/com.google.code.findbugs/jsr305/jars/jsr305-3.0.0.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-common/jars/hadoop-mini-clusters-common-0.1.7.jar:/home/sam/.ivy2/cache/com.fasterxml.jackson.core/jackson-core/jars/jackson-core-2.2.3.jar:/home/sam/.ivy2/cache/asm/asm/jars/asm-3.1.jar:/home/sam/.ivy2/cache/aopalliance/aopalliance/jars/aopalliance-1.0.jar:/home/sam/.ivy2/cache/com.affinytix.model/affinytix-model-msg_2.10/jars/affinytix-model-msg_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.google.guava/guava/bundles/guava-19.0.jar:/home/sam/.ivy2/cache/net.jpountz.lz4/lz4/jars/lz4-1.2.0.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka-clients/jars/kafka-clients-0.9.0.1.jar:/home/sam/.sbt/boot/scala-2.10.6/lib/scala-reflect.jar:/home/sam/.ivy2/cache/org.scalatest/scalatest_2.10/bundles/scalatest_2.10-2.2.6.jar:/home/sam/.ivy2/cache/org.xerial.snappy/snappy-java/bundles/snappy-java-1.1.1.7.jar:/home/sam/.ivy2/cache/com.typesafe/config/bundles/config-1.3.0.jar:/home/sam/.ivy2/cache/com.affinytix.exception/affinytix-exception_2.10/jars/affinytix-exception_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.affinytix.util/affinytix-util_2.10/jars/affinytix-util_2.10-1.1.0.jar:/home/sam/.ivy2/cache/com.affinytix.stream/affinytix-stream-serializer_2.10/jars/affinytix-stream-serializer_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.github.stephenc.findbugs/findbugs-annotations/jars/findbugs-annotations-1.3.9-1.jar:/home/sam/.ivy2/cache/com.thoughtworks.paranamer/paranamer/bundles/paranamer-2.7.jar:/home/sam/.ivy2/cache/commons-cli/commons-cli/jars/commons-cli-1.2.jar:/home/sam/.ivy2/cache/commons-codec/commons-codec/jars/commons-codec-1.9.jar:/home/sam/.ivy2/cache/commons-collections/commons-collections/jars/commons-collections-3.2.1.jar:/home/sam/.ivy2/cache/commons-httpclient/commons-httpclient/jars/commons-httpclient-3.1.jar:/home/sam/.ivy2/cache/commons-lang/commons-lang/jars/commons-lang-2.6.jar:/home/sam/.ivy2/cache/commons-logging/commons-logging/jars/commons-logging-1.1.1.jar:/home/sam/.ivy2/cache/io.netty/netty/bundles/netty-3.5.13.Final.jar:/home/sam/.ivy2/cache/joda-time/joda-time/jars/joda-time-2.7.jar:/home/sam/.ivy2/cache/net.sf.jopt-simple/jopt-simple/jars/jopt-simple-4.7.jar:/home/sam/.ivy2/cache/org.apache.avro/avro/jars/avro-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-compiler/bundles/avro-compiler-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-ipc/jars/avro-ipc-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-mapred/jars/avro-mapred-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-tools/jars/avro-tools-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-avro/jars/trevni-avro-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-avro/jars/trevni-avro-1.8.1-tests.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-core/jars/trevni-core-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-core/jars/trevni-core-1.8.1-tests.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-compress/jars/commons-compress-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.velocity/velocity/jars/velocity-1.7.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-core-asl/jars/jackson-core-asl-1.9.13.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-mapper-asl/jars/jackson-mapper-asl-1.9.13.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/jetty/jars/jetty-6.1.26.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/jetty-util/jars/jetty-util-6.1.26.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/servlet-api/jars/servlet-api-2.5-20081211.jar:/home/sam/.ivy2/cache/org.tukaani/xz/jars/xz-1.5.jar:/home/sam/.ivy2/cache/com.101tec/zkclient/jars/zkclient-0.7.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-kafka/jars/hadoop-mini-clusters-kafka-0.1.7.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-zookeeper/jars/hadoop-mini-clusters-zookeeper-0.1.7.jar:/home/sam/.ivy2/cache/com.yammer.metrics/metrics-core/jars/metrics-core-2.2.0.jar:/home/sam/.ivy2/cache/net.sf.jopt-simple/jopt-simple/jars/jopt-simple-4.9.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-math/jars/commons-math-2.2.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-test/jars/curator-test-2.5.0.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka-clients/jars/kafka-clients-0.9.0.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka_2.10/jars/kafka_2.10-0.9.0.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.javassist/javassist/bundles/javassist-3.18.1-GA.jar:/home/sam/.ivy2/cache/org.slf4j/slf4j-api/jars/slf4j-api-1.7.6.jar:/home/sam/.ivy2/cache/org.xerial.snappy/snappy-java/bundles/snappy-java-1.1.2.jar:/opt/idea-IC-162.1121.32/lib/idea_rt.jar","version":"52.0"},"endorsed":{"dirs":"/usr/lib/jvm/java-8-oracle/jre/lib/endorsed"},"ext":{"dirs":"/usr/lib/jvm/java-8-oracle/jre/lib/ext:/usr/java/packages/lib/ext"},"home":"/usr/lib/jvm/java-8-oracle/jre","io":{"tmpdir":"/tmp"},"library":{"path":"/opt/idea-IC-162.1121.32/bin::/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib"},"runtime":{"name":"Java(TM) SE Runtime Environment","version":"1.8.0_101-b13"},"specification":{"name":"Java Platform API Specification","vendor":"Oracle Corporation","version":"1.8"},"vendor":{"url":{"bug":"http://bugreport.sun.com/bugreport/"}},"version":"1.8.0_101","vm":{"info":"mixed mode","name":"Java HotSpot(TM) 64-Bit Server VM","specification":{"name":"Java Virtual Machine Specification","vendor":"Oracle Corporation","version":"1.8"},"vendor":"Oracle Corporation","version":"25.101-b13"}},"kafka-producers":[{"acks":"all","batch_size":16384,"bootstrap_servers":["localhost:11111"],"buffer_memory":33554432,"client_id":"testing-client","compression_type":"none","key_serializer":"org.apache.kafka.common.serialization.StringSerializer","linger_ms":1,"name":"testing","retries":0,"topic":"test","value_serializer":"org.apache.kafka.common.serialization.StringSerializer"}],"line":{"separator":"\n"},"os":{"arch":"amd64","name":"Linux","version":"4.4.0-31-generic"},"path":{"separator":":"},"sun":{"arch":{"data":{"model":"64"}},"boot":{"class":{"path":"/usr/lib/jvm/java-8-oracle/jre/lib/resources.jar:/usr/lib/jvm/java-8-oracle/jre/lib/rt.jar:/usr/lib/jvm/java-8-oracle/jre/lib/sunrsasign.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jsse.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jce.jar:/usr/lib/jvm/java-8-oracle/jre/lib/charsets.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jfr.jar:/usr/lib/jvm/java-8-oracle/jre/classes"},"library":{"path":"/usr/lib/jvm/java-8-oracle/jre/lib/amd64"}},"cpu":{"endian":"little","isalist":""},"desktop":"gnome","io":{"unicode":{"encoding":"UnicodeLittle"}},"java":{"command":"com.intellij.rt.execution.application.AppMain org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner -s TestSendingReceiving -testName A receiver should be able to consume on on topic with one partition -showProgressMessages true -C org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestReporter","launcher":"SUN_STANDARD"},"jnu":{"encoding":"UTF-8"},"management":{"compiler":"HotSpot 64-Bit Tiered Compilers"},"os":{"patch":{"level":"unknown"}}},"user":{"country":"US","dir":"/home/sam/IdeaProjects/affinytix-stream-kafka","home":"/home/sam","language":"en","name":"sam","timezone":"Asia/Jerusalem"}}))
2016-08-02 05:38:08 INFO ProducerConfig:165 - ProducerConfig values:
compression.type = none
metric.reporters = []
metadata.max.age.ms = 300000
metadata.fetch.timeout.ms = 60000
reconnect.backoff.ms = 50
sasl.kerberos.ticket.renew.window.factor = 0.8
bootstrap.servers = [localhost:11111]
retry.backoff.ms = 100
sasl.kerberos.kinit.cmd = /usr/bin/kinit
buffer.memory = 33554432
timeout.ms = 30000
key.serializer = class org.apache.kafka.common.serialization.StringSerializer
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
ssl.keystore.type = JKS
ssl.trustmanager.algorithm = PKIX
block.on.buffer.full = false
ssl.key.password = null
max.block.ms = 60000
sasl.kerberos.min.time.before.relogin = 60000
connections.max.idle.ms = 540000
ssl.truststore.password = null
max.in.flight.requests.per.connection = 5
metrics.num.samples = 2
client.id = testing-client
ssl.endpoint.identification.algorithm = null
ssl.protocol = TLS
request.timeout.ms = 30000
ssl.provider = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
acks = all
batch.size = 16384
ssl.keystore.location = null
receive.buffer.bytes = 32768
ssl.cipher.suites = null
ssl.truststore.type = JKS
security.protocol = PLAINTEXT
retries = 0
max.request.size = 1048576
value.serializer = class org.apache.kafka.common.serialization.StringSerializer
ssl.truststore.location = null
ssl.keystore.password = null
ssl.keymanager.algorithm = SunX509
metrics.sample.window.ms = 30000
partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
send.buffer.bytes = 131072
linger.ms = 1
2016-08-02 05:38:08 INFO AppInfoParser:82 - Kafka version : 0.9.0.1
2016-08-02 05:38:08 INFO AppInfoParser:83 - Kafka commitId : 23c69d62a0cabf06
2016-08-02 05:38:08 INFO TestSendingReceiving:100 - Before sending the string
2016-08-02 05:38:08 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:setData cxid:0x40 zxid:0x18 txntype:-1 reqpath:n/a Error Path:/config/topics/test Error:KeeperErrorCode = NoNode for /config/topics/test
2016-08-02 05:38:08 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x41 zxid:0x19 txntype:-1 reqpath:n/a Error Path:/config/topics Error:KeeperErrorCode = NodeExists for /config/topics
2016-08-02 05:38:08 INFO AdminUtils$:68 - Topic creation {"version":1,"partitions":{"0":[0]}}
2016-08-02 05:38:08 INFO KafkaApis:68 - [KafkaApi-0] Auto creation of topic test with 1 partitions and replication factor 1 is successful!
2016-08-02 05:38:08 INFO PartitionStateMachine$TopicChangeListener:68 - [TopicChangeListener on Controller 0]: New topics: [Set(test)], deleted topics: [Set()], new partition replica assignment [Map([test,0] -> List(0))]
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: New topic creation callback for [test,0]
2016-08-02 05:38:08 INFO KafkaController:68 - [Controller 0]: New partition creation callback for [test,0]
2016-08-02 05:38:08 INFO PartitionStateMachine:68 - [Partition state machine on Controller 0]: Invoking state change to NewPartition for partitions [test,0]
2016-08-02 05:38:08 INFO ReplicaStateMachine:68 - [Replica state machine on controller 0]: Invoking state change to NewReplica for replicas [Topic=test,Partition=0,Replica=0]
2016-08-02 05:38:08 WARN NetworkClient:582 - Error while fetching metadata with correlation id 0 : {test=LEADER_NOT_AVAILABLE}
2016-08-02 05:38:08 INFO PartitionStateMachine:68 - [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions [test,0]
2016-08-02 05:38:08 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x49 zxid:0x1c txntype:-1 reqpath:n/a Error Path:/brokers/topics/test/partitions/0 Error:KeeperErrorCode = NoNode for /brokers/topics/test/partitions/0
2016-08-02 05:38:08 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x4a zxid:0x1d txntype:-1 reqpath:n/a Error Path:/brokers/topics/test/partitions Error:KeeperErrorCode = NoNode for /brokers/topics/test/partitions
2016-08-02 05:38:08 INFO ReplicaStateMachine:68 - [Replica state machine on controller 0]: Invoking state change to OnlineReplica for replicas [Topic=test,Partition=0,Replica=0]
2016-08-02 05:38:08 WARN NetworkClient:582 - Error while fetching metadata with correlation id 1 : {test=LEADER_NOT_AVAILABLE}
2016-08-02 05:38:08 INFO ReplicaFetcherManager:68 - [ReplicaFetcherManager on broker 0] Removed fetcher for partitions [test,0]
2016-08-02 05:38:08 INFO Log:68 - Completed load of log test-0 with log end offset 0
2016-08-02 05:38:08 INFO LogManager:68 - Created log for partition [test,0] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> producer, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> delete, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 1073741824, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:08 INFO Partition:68 - Partition [test,0] on broker 0: No checkpointed highwatermark is found for partition [test,0]
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='0', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 0
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='1', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 1
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='2', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 2
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='3', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 3
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='4', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 4
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='5', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 5
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='6', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 6
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='7', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 7
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='8', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 8
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='9', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 9
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='10', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 10
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='11', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 11
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='12', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 12
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='13', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 13
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='14', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 14
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='15', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 15
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='16', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 16
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='17', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 17
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='18', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 18
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='19', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 19
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='20', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 20
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='21', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 21
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='22', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 22
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='23', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 23
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='24', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 24
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='25', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 25
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='26', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 26
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='27', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 27
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='28', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 28
2016-08-02 05:38:09 INFO MetaDataLoginCbk:19 - MetaDataLoginCbk{offset='29', partition='0', topicPartition='test'}
2016-08-02 05:38:09 INFO TestSendingReceiving:91 - receive the call
2016-08-02 05:38:09 INFO TestSendingReceiving:93 - current offset: 29
2016-08-02 05:38:11 INFO TestSendingReceiving:104 - After sending the string
2016-08-02 05:38:11 INFO ConfigLoader:99 - Load conf at : kafka-consumer-1.json
2016-08-02 05:38:11 INFO ConfigLoader:100 - Config(SimpleConfigObject({"awt":{"toolkit":"sun.awt.X11.XToolkit"},"file":{"encoding":{"pkg":"sun.io"},"separator":"/"},"idea":{"launcher":{"bin":{"path":"/opt/idea-IC-162.1121.32/bin"},"port":"7532"}},"java":{"awt":{"graphicsenv":"sun.awt.X11GraphicsEnvironment","printerjob":"sun.print.PSPrinterJob"},"class":{"path":"/home/sam/.IdeaIC2016.2/config/plugins/Scala/lib/scala-plugin-runners.jar:/usr/lib/jvm/java-8-oracle/jre/lib/charsets.jar:/usr/lib/jvm/java-8-oracle/jre/lib/deploy.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/cldrdata.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/dnsns.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/jaccess.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/jfxrt.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/localedata.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/nashorn.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunec.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunjce_provider.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/sunpkcs11.jar:/usr/lib/jvm/java-8-oracle/jre/lib/ext/zipfs.jar:/usr/lib/jvm/java-8-oracle/jre/lib/javaws.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jce.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jfr.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jfxswt.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jsse.jar:/usr/lib/jvm/java-8-oracle/jre/lib/management-agent.jar:/usr/lib/jvm/java-8-oracle/jre/lib/plugin.jar:/usr/lib/jvm/java-8-oracle/jre/lib/resources.jar:/usr/lib/jvm/java-8-oracle/jre/lib/rt.jar:/home/sam/IdeaProjects/affinytix-stream-kafka/target/scala-2.10/test-classes:/home/sam/IdeaProjects/affinytix-stream-kafka/target/scala-2.10/classes:/home/sam/.sbt/boot/scala-2.10.6/lib/scala-library.jar:/home/sam/.ivy2/cache/xml-apis/xml-apis/jars/xml-apis-1.3.04.jar:/home/sam/.ivy2/cache/xmlenc/xmlenc/jars/xmlenc-0.52.jar:/home/sam/.ivy2/cache/xerces/xercesImpl/jars/xercesImpl-2.9.1.jar:/home/sam/.ivy2/cache/org.sonatype.sisu.inject/cglib/jars/cglib-2.2.1-v20090111.jar:/home/sam/.ivy2/cache/org.fusesource.leveldbjni/leveldbjni-all/bundles/leveldbjni-all-1.8.jar:/home/sam/.ivy2/cache/org.codehaus.jettison/jettison/bundles/jettison-1.1.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-xc/jars/jackson-xc-1.9.13.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-jaxrs/jars/jackson-jaxrs-1.9.13.jar:/home/sam/.ivy2/cache/org.apache.zookeeper/zookeeper/jars/zookeeper-3.4.6.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.httpcomponents/httpcore/jars/httpcore-4.2.4.jar:/home/sam/.ivy2/cache/org.apache.httpcomponents/httpclient/jars/httpclient-4.2.5.jar:/home/sam/.ivy2/cache/org.apache.htrace/htrace-core/jars/htrace-core-3.1.0-incubating.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-server-common/jars/hadoop-yarn-server-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-registry/jars/hadoop-yarn-registry-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-common/jars/hadoop-yarn-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-client/jars/hadoop-yarn-client-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-yarn-api/jars/hadoop-yarn-api-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-shuffle/jars/hadoop-mapreduce-client-shuffle-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-jobclient/jars/hadoop-mapreduce-client-jobclient-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-core/jars/hadoop-mapreduce-client-core-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-common/jars/hadoop-mapreduce-client-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-mapreduce-client-app/jars/hadoop-mapreduce-client-app-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-hdfs/jars/hadoop-hdfs-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-common/jars/hadoop-common-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-client/jars/hadoop-client-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-auth/jars/hadoop-auth-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.hadoop/hadoop-annotations/jars/hadoop-annotations-2.7.1.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.directory.server/apacheds-kerberos-codec/bundles/apacheds-kerberos-codec-2.0.0-M15.jar:/home/sam/.ivy2/cache/org.apache.directory.server/apacheds-i18n/bundles/apacheds-i18n-2.0.0-M15.jar:/home/sam/.ivy2/cache/org.apache.directory.api/api-util/bundles/api-util-1.0.0-M20.jar:/home/sam/.ivy2/cache/org.apache.directory.api/api-asn1-api/bundles/api-asn1-api-1.0.0-M20.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-recipes/bundles/curator-recipes-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-framework/bundles/curator-framework-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-client/bundles/curator-client-2.7.1.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-math3/jars/commons-math3-3.1.1.jar:/home/sam/.ivy2/cache/log4j/log4j/bundles/log4j-1.2.17.jar:/home/sam/.ivy2/cache/junit/junit/jars/junit-3.8.1.jar:/home/sam/.ivy2/cache/javax.xml.stream/stax-api/jars/stax-api-1.0-2.jar:/home/sam/.ivy2/cache/javax.xml.bind/jaxb-api/jars/jaxb-api-2.2.2.jar:/home/sam/.ivy2/cache/javax.servlet.jsp/jsp-api/jars/jsp-api-2.1.jar:/home/sam/.ivy2/cache/javax.servlet/servlet-api/jars/servlet-api-2.5.jar:/home/sam/.ivy2/cache/javax.inject/javax.inject/jars/javax.inject-1.jar:/home/sam/.ivy2/cache/javax.activation/activation/jars/activation-1.1.jar:/home/sam/.ivy2/cache/io.netty/netty-all/jars/netty-all-4.0.23.Final.jar:/home/sam/.ivy2/cache/io.netty/netty/bundles/netty-3.7.0.Final.jar:/home/sam/.ivy2/cache/commons-net/commons-net/jars/commons-net-3.1.jar:/home/sam/.ivy2/cache/commons-logging/commons-logging/jars/commons-logging-1.1.3.jar:/home/sam/.ivy2/cache/commons-io/commons-io/jars/commons-io-2.4.jar:/home/sam/.ivy2/cache/commons-digester/commons-digester/jars/commons-digester-1.8.jar:/home/sam/.ivy2/cache/commons-configuration/commons-configuration/jars/commons-configuration-1.6.jar:/home/sam/.ivy2/cache/commons-collections/commons-collections/jars/commons-collections-3.2.2.jar:/home/sam/.ivy2/cache/commons-beanutils/commons-beanutils-core/jars/commons-beanutils-core-1.8.0.jar:/home/sam/.ivy2/cache/commons-beanutils/commons-beanutils/jars/commons-beanutils-1.7.0.jar:/home/sam/.ivy2/cache/com.sun.xml.bind/jaxb-impl/jars/jaxb-impl-2.2.3-1.jar:/home/sam/.ivy2/cache/com.sun.jersey.contribs/jersey-guice/jars/jersey-guice-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-server/bundles/jersey-server-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-json/bundles/jersey-json-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-core/bundles/jersey-core-1.9.jar:/home/sam/.ivy2/cache/com.sun.jersey/jersey-client/bundles/jersey-client-1.9.jar:/home/sam/.ivy2/cache/com.squareup.okio/okio/jars/okio-1.4.0.jar:/home/sam/.ivy2/cache/com.squareup.okhttp/okhttp/jars/okhttp-2.4.0.jar:/home/sam/.ivy2/cache/com.microsoft.windowsazure.storage/microsoft-windowsazure-storage-sdk/jars/microsoft-windowsazure-storage-sdk-0.6.0.jar:/home/sam/.ivy2/cache/com.jamesmurty.utils/java-xmlbuilder/jars/java-xmlbuilder-0.4.jar:/home/sam/.ivy2/cache/com.google.protobuf/protobuf-java/bundles/protobuf-java-2.5.0.jar:/home/sam/.ivy2/cache/com.google.inject/guice/jars/guice-3.0.jar:/home/sam/.ivy2/cache/com.google.code.gson/gson/jars/gson-2.2.4.jar:/home/sam/.ivy2/cache/com.google.code.findbugs/jsr305/jars/jsr305-3.0.0.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-common/jars/hadoop-mini-clusters-common-0.1.7.jar:/home/sam/.ivy2/cache/com.fasterxml.jackson.core/jackson-core/jars/jackson-core-2.2.3.jar:/home/sam/.ivy2/cache/asm/asm/jars/asm-3.1.jar:/home/sam/.ivy2/cache/aopalliance/aopalliance/jars/aopalliance-1.0.jar:/home/sam/.ivy2/cache/com.affinytix.model/affinytix-model-msg_2.10/jars/affinytix-model-msg_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.google.guava/guava/bundles/guava-19.0.jar:/home/sam/.ivy2/cache/net.jpountz.lz4/lz4/jars/lz4-1.2.0.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka-clients/jars/kafka-clients-0.9.0.1.jar:/home/sam/.sbt/boot/scala-2.10.6/lib/scala-reflect.jar:/home/sam/.ivy2/cache/org.scalatest/scalatest_2.10/bundles/scalatest_2.10-2.2.6.jar:/home/sam/.ivy2/cache/org.xerial.snappy/snappy-java/bundles/snappy-java-1.1.1.7.jar:/home/sam/.ivy2/cache/com.typesafe/config/bundles/config-1.3.0.jar:/home/sam/.ivy2/cache/com.affinytix.exception/affinytix-exception_2.10/jars/affinytix-exception_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.affinytix.util/affinytix-util_2.10/jars/affinytix-util_2.10-1.1.0.jar:/home/sam/.ivy2/cache/com.affinytix.stream/affinytix-stream-serializer_2.10/jars/affinytix-stream-serializer_2.10-1.0.0.jar:/home/sam/.ivy2/cache/com.github.stephenc.findbugs/findbugs-annotations/jars/findbugs-annotations-1.3.9-1.jar:/home/sam/.ivy2/cache/com.thoughtworks.paranamer/paranamer/bundles/paranamer-2.7.jar:/home/sam/.ivy2/cache/commons-cli/commons-cli/jars/commons-cli-1.2.jar:/home/sam/.ivy2/cache/commons-codec/commons-codec/jars/commons-codec-1.9.jar:/home/sam/.ivy2/cache/commons-collections/commons-collections/jars/commons-collections-3.2.1.jar:/home/sam/.ivy2/cache/commons-httpclient/commons-httpclient/jars/commons-httpclient-3.1.jar:/home/sam/.ivy2/cache/commons-lang/commons-lang/jars/commons-lang-2.6.jar:/home/sam/.ivy2/cache/commons-logging/commons-logging/jars/commons-logging-1.1.1.jar:/home/sam/.ivy2/cache/io.netty/netty/bundles/netty-3.5.13.Final.jar:/home/sam/.ivy2/cache/joda-time/joda-time/jars/joda-time-2.7.jar:/home/sam/.ivy2/cache/net.sf.jopt-simple/jopt-simple/jars/jopt-simple-4.7.jar:/home/sam/.ivy2/cache/org.apache.avro/avro/jars/avro-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-compiler/bundles/avro-compiler-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-ipc/jars/avro-ipc-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-mapred/jars/avro-mapred-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/avro-tools/jars/avro-tools-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-avro/jars/trevni-avro-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-avro/jars/trevni-avro-1.8.1-tests.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-core/jars/trevni-core-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.avro/trevni-core/jars/trevni-core-1.8.1-tests.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-compress/jars/commons-compress-1.8.1.jar:/home/sam/.ivy2/cache/org.apache.velocity/velocity/jars/velocity-1.7.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-core-asl/jars/jackson-core-asl-1.9.13.jar:/home/sam/.ivy2/cache/org.codehaus.jackson/jackson-mapper-asl/jars/jackson-mapper-asl-1.9.13.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/jetty/jars/jetty-6.1.26.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/jetty-util/jars/jetty-util-6.1.26.jar:/home/sam/.ivy2/cache/org.mortbay.jetty/servlet-api/jars/servlet-api-2.5-20081211.jar:/home/sam/.ivy2/cache/org.tukaani/xz/jars/xz-1.5.jar:/home/sam/.ivy2/cache/com.101tec/zkclient/jars/zkclient-0.7.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-kafka/jars/hadoop-mini-clusters-kafka-0.1.7.jar:/home/sam/.ivy2/cache/com.github.sakserv/hadoop-mini-clusters-zookeeper/jars/hadoop-mini-clusters-zookeeper-0.1.7.jar:/home/sam/.ivy2/cache/com.yammer.metrics/metrics-core/jars/metrics-core-2.2.0.jar:/home/sam/.ivy2/cache/net.sf.jopt-simple/jopt-simple/jars/jopt-simple-4.9.jar:/home/sam/.ivy2/cache/org.apache.commons/commons-math/jars/commons-math-2.2.jar:/home/sam/.ivy2/cache/org.apache.curator/curator-test/jars/curator-test-2.5.0.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka-clients/jars/kafka-clients-0.9.0.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.apache.kafka/kafka_2.10/jars/kafka_2.10-0.9.0.2.4.2.0-258.jar:/home/sam/.ivy2/cache/org.javassist/javassist/bundles/javassist-3.18.1-GA.jar:/home/sam/.ivy2/cache/org.slf4j/slf4j-api/jars/slf4j-api-1.7.6.jar:/home/sam/.ivy2/cache/org.xerial.snappy/snappy-java/bundles/snappy-java-1.1.2.jar:/opt/idea-IC-162.1121.32/lib/idea_rt.jar","version":"52.0"},"endorsed":{"dirs":"/usr/lib/jvm/java-8-oracle/jre/lib/endorsed"},"ext":{"dirs":"/usr/lib/jvm/java-8-oracle/jre/lib/ext:/usr/java/packages/lib/ext"},"home":"/usr/lib/jvm/java-8-oracle/jre","io":{"tmpdir":"/tmp"},"library":{"path":"/opt/idea-IC-162.1121.32/bin::/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib"},"runtime":{"name":"Java(TM) SE Runtime Environment","version":"1.8.0_101-b13"},"specification":{"name":"Java Platform API Specification","vendor":"Oracle Corporation","version":"1.8"},"vendor":{"url":{"bug":"http://bugreport.sun.com/bugreport/"}},"version":"1.8.0_101","vm":{"info":"mixed mode","name":"Java HotSpot(TM) 64-Bit Server VM","specification":{"name":"Java Virtual Machine Specification","vendor":"Oracle Corporation","version":"1.8"},"vendor":"Oracle Corporation","version":"25.101-b13"}},"kafka-consumers":[{"auto_commit_interval_ms":"10","bootstrap_servers":["localhost:11111","localhost:11112","localhost:11113"],"client_id":"server.reco.top","enable_auto_commit":"true","group_id":"my test group","key_deserializer":"org.apache.kafka.common.serialization.StringDeserializer","name":"my consumer testing configuration","session_timeout_ms":"30000","topic":["test"],"value_deserializer":"org.apache.kafka.common.serialization.StringDeserializer"}],"line":{"separator":"\n"},"os":{"arch":"amd64","name":"Linux","version":"4.4.0-31-generic"},"path":{"separator":":"},"sun":{"arch":{"data":{"model":"64"}},"boot":{"class":{"path":"/usr/lib/jvm/java-8-oracle/jre/lib/resources.jar:/usr/lib/jvm/java-8-oracle/jre/lib/rt.jar:/usr/lib/jvm/java-8-oracle/jre/lib/sunrsasign.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jsse.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jce.jar:/usr/lib/jvm/java-8-oracle/jre/lib/charsets.jar:/usr/lib/jvm/java-8-oracle/jre/lib/jfr.jar:/usr/lib/jvm/java-8-oracle/jre/classes"},"library":{"path":"/usr/lib/jvm/java-8-oracle/jre/lib/amd64"}},"cpu":{"endian":"little","isalist":""},"desktop":"gnome","io":{"unicode":{"encoding":"UnicodeLittle"}},"java":{"command":"com.intellij.rt.execution.application.AppMain org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner -s TestSendingReceiving -testName A receiver should be able to consume on on topic with one partition -showProgressMessages true -C org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestReporter","launcher":"SUN_STANDARD"},"jnu":{"encoding":"UTF-8"},"management":{"compiler":"HotSpot 64-Bit Tiered Compilers"},"os":{"patch":{"level":"unknown"}}},"user":{"country":"US","dir":"/home/sam/IdeaProjects/affinytix-stream-kafka","home":"/home/sam","language":"en","name":"sam","timezone":"Asia/Jerusalem"}}))
2016-08-02 05:38:11 INFO ConsumerConfig:165 - ConsumerConfig values:
metric.reporters = []
metadata.max.age.ms = 300000
value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
group.id = my test group
partition.assignment.strategy = [org.apache.kafka.clients.consumer.RangeAssignor]
reconnect.backoff.ms = 50
sasl.kerberos.ticket.renew.window.factor = 0.8
max.partition.fetch.bytes = 1048576
bootstrap.servers = [localhost:11111, localhost:11112, localhost:11113]
retry.backoff.ms = 100
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
ssl.keystore.type = JKS
ssl.trustmanager.algorithm = PKIX
enable.auto.commit = true
ssl.key.password = null
fetch.max.wait.ms = 500
sasl.kerberos.min.time.before.relogin = 60000
connections.max.idle.ms = 540000
ssl.truststore.password = null
session.timeout.ms = 30000
metrics.num.samples = 2
client.id = server.reco.top
ssl.endpoint.identification.algorithm = null
key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
ssl.protocol = TLS
check.crcs = true
request.timeout.ms = 40000
ssl.provider = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.keystore.location = null
heartbeat.interval.ms = 3000
auto.commit.interval.ms = 10
receive.buffer.bytes = 32768
ssl.cipher.suites = null
ssl.truststore.type = JKS
security.protocol = PLAINTEXT
ssl.truststore.location = null
ssl.keystore.password = null
ssl.keymanager.algorithm = SunX509
metrics.sample.window.ms = 30000
fetch.min.bytes = 1
send.buffer.bytes = 131072
auto.offset.reset = latest
2016-08-02 05:38:11 INFO AppInfoParser:82 - Kafka version : 0.9.0.1
2016-08-02 05:38:11 INFO AppInfoParser:83 - Kafka commitId : 23c69d62a0cabf06
2016-08-02 05:38:11 INFO ConsumerConfig:165 - ConsumerConfig values:
metric.reporters = []
metadata.max.age.ms = 300000
value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
group.id = my test group
partition.assignment.strategy = [org.apache.kafka.clients.consumer.RangeAssignor]
reconnect.backoff.ms = 50
sasl.kerberos.ticket.renew.window.factor = 0.8
max.partition.fetch.bytes = 1048576
bootstrap.servers = [localhost:11111, localhost:11112, localhost:11113]
retry.backoff.ms = 100
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
ssl.keystore.type = JKS
ssl.trustmanager.algorithm = PKIX
enable.auto.commit = true
ssl.key.password = null
fetch.max.wait.ms = 500
sasl.kerberos.min.time.before.relogin = 60000
connections.max.idle.ms = 540000
ssl.truststore.password = null
session.timeout.ms = 30000
metrics.num.samples = 2
client.id = server.reco.top
ssl.endpoint.identification.algorithm = null
key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
ssl.protocol = TLS
check.crcs = true
request.timeout.ms = 40000
ssl.provider = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.keystore.location = null
heartbeat.interval.ms = 3000
auto.commit.interval.ms = 10
receive.buffer.bytes = 32768
ssl.cipher.suites = null
ssl.truststore.type = JKS
security.protocol = PLAINTEXT
ssl.truststore.location = null
ssl.keystore.password = null
ssl.keymanager.algorithm = SunX509
metrics.sample.window.ms = 30000
fetch.min.bytes = 1
send.buffer.bytes = 131072
auto.offset.reset = latest
2016-08-02 05:38:11 INFO AppInfoParser:82 - Kafka version : 0.9.0.1
2016-08-02 05:38:11 INFO AppInfoParser:83 - Kafka commitId : 23c69d62a0cabf06
2016-08-02 05:38:11 INFO MaxConsumerReceiver:42 - Created consumer: [topic:test, partition:0]
2016-08-02 05:38:11 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:setData cxid:0x54 zxid:0x21 txntype:-1 reqpath:n/a Error Path:/config/topics/__consumer_offsets Error:KeeperErrorCode = NoNode for /config/topics/__consumer_offsets
2016-08-02 05:38:11 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x55 zxid:0x22 txntype:-1 reqpath:n/a Error Path:/config/topics Error:KeeperErrorCode = NodeExists for /config/topics
2016-08-02 05:38:11 INFO AdminUtils$:68 - Topic creation {"version":1,"partitions":{"45":[0],"34":[0],"12":[0],"8":[0],"19":[0],"23":[0],"4":[0],"40":[0],"15":[0],"11":[0],"9":[0],"44":[0],"33":[0],"22":[0],"26":[0],"37":[0],"13":[0],"46":[0],"24":[0],"35":[0],"16":[0],"5":[0],"10":[0],"48":[0],"21":[0],"43":[0],"32":[0],"49":[0],"6":[0],"36":[0],"1":[0],"39":[0],"17":[0],"25":[0],"14":[0],"47":[0],"31":[0],"42":[0],"0":[0],"20":[0],"27":[0],"2":[0],"38":[0],"18":[0],"30":[0],"7":[0],"29":[0],"41":[0],"3":[0],"28":[0]}}
2016-08-02 05:38:11 INFO KafkaApis:68 - [KafkaApi-0] Auto creation of topic __consumer_offsets with 50 partitions and replication factor 1 is successful!
2016-08-02 05:38:11 INFO PartitionStateMachine$TopicChangeListener:68 - [TopicChangeListener on Controller 0]: New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map([__consumer_offsets,19] -> List(0), [__consumer_offsets,30] -> List(0), [__consumer_offsets,47] -> List(0), [__consumer_offsets,29] -> List(0), [__consumer_offsets,41] -> List(0), [__consumer_offsets,39] -> List(0), [__consumer_offsets,10] -> List(0), [__consumer_offsets,17] -> List(0), [__consumer_offsets,14] -> List(0), [__consumer_offsets,40] -> List(0), [__consumer_offsets,18] -> List(0), [__consumer_offsets,26] -> List(0), [__consumer_offsets,0] -> List(0), [__consumer_offsets,24] -> List(0), [__consumer_offsets,33] -> List(0), [__consumer_offsets,20] -> List(0), [__consumer_offsets,21] -> List(0), [__consumer_offsets,3] -> List(0), [__consumer_offsets,5] -> List(0), [__consumer_offsets,22] -> List(0), [__consumer_offsets,12] -> List(0), [__consumer_offsets,8] -> List(0), [__consumer_offsets,23] -> List(0), [__consumer_offsets,15] -> List(0), [__consumer_offsets,48] -> List(0), [__consumer_offsets,11] -> List(0), [__consumer_offsets,13] -> List(0), [__consumer_offsets,49] -> List(0), [__consumer_offsets,6] -> List(0), [__consumer_offsets,28] -> List(0), [__consumer_offsets,4] -> List(0), [__consumer_offsets,37] -> List(0), [__consumer_offsets,31] -> List(0), [__consumer_offsets,44] -> List(0), [__consumer_offsets,42] -> List(0), [__consumer_offsets,34] -> List(0), [__consumer_offsets,46] -> List(0), [__consumer_offsets,25] -> List(0), [__consumer_offsets,45] -> List(0), [__consumer_offsets,27] -> List(0), [__consumer_offsets,32] -> List(0), [__consumer_offsets,43] -> List(0), [__consumer_offsets,36] -> List(0), [__consumer_offsets,35] -> List(0), [__consumer_offsets,7] -> List(0), [__consumer_offsets,9] -> List(0), [__consumer_offsets,38] -> List(0), [__consumer_offsets,1] -> List(0), [__consumer_offsets,16] -> List(0), [__consumer_offsets,2] -> List(0))]
2016-08-02 05:38:11 INFO KafkaController:68 - [Controller 0]: New topic creation callback for [__consumer_offsets,32],[__consumer_offsets,16],[__consumer_offsets,49],[__consumer_offsets,44],[__consumer_offsets,28],[__consumer_offsets,17],[__consumer_offsets,23],[__consumer_offsets,7],[__consumer_offsets,4],[__consumer_offsets,29],[__consumer_offsets,35],[__consumer_offsets,3],[__consumer_offsets,24],[__consumer_offsets,41],[__consumer_offsets,0],[__consumer_offsets,38],[__consumer_offsets,13],[__consumer_offsets,8],[__consumer_offsets,5],[__consumer_offsets,39],[__consumer_offsets,36],[__consumer_offsets,40],[__consumer_offsets,45],[__consumer_offsets,15],[__consumer_offsets,33],[__consumer_offsets,37],[__consumer_offsets,21],[__consumer_offsets,6],[__consumer_offsets,11],[__consumer_offsets,20],[__consumer_offsets,47],[__consumer_offsets,2],[__consumer_offsets,27],[__consumer_offsets,34],[__consumer_offsets,9],[__consumer_offsets,22],[__consumer_offsets,42],[__consumer_offsets,14],[__consumer_offsets,25],[__consumer_offsets,10],[__consumer_offsets,48],[__consumer_offsets,31],[__consumer_offsets,18],[__consumer_offsets,19],[__consumer_offsets,12],[__consumer_offsets,46],[__consumer_offsets,43],[__consumer_offsets,1],[__consumer_offsets,26],[__consumer_offsets,30]
2016-08-02 05:38:11 INFO KafkaController:68 - [Controller 0]: New partition creation callback for [__consumer_offsets,32],[__consumer_offsets,16],[__consumer_offsets,49],[__consumer_offsets,44],[__consumer_offsets,28],[__consumer_offsets,17],[__consumer_offsets,23],[__consumer_offsets,7],[__consumer_offsets,4],[__consumer_offsets,29],[__consumer_offsets,35],[__consumer_offsets,3],[__consumer_offsets,24],[__consumer_offsets,41],[__consumer_offsets,0],[__consumer_offsets,38],[__consumer_offsets,13],[__consumer_offsets,8],[__consumer_offsets,5],[__consumer_offsets,39],[__consumer_offsets,36],[__consumer_offsets,40],[__consumer_offsets,45],[__consumer_offsets,15],[__consumer_offsets,33],[__consumer_offsets,37],[__consumer_offsets,21],[__consumer_offsets,6],[__consumer_offsets,11],[__consumer_offsets,20],[__consumer_offsets,47],[__consumer_offsets,2],[__consumer_offsets,27],[__consumer_offsets,34],[__consumer_offsets,9],[__consumer_offsets,22],[__consumer_offsets,42],[__consumer_offsets,14],[__consumer_offsets,25],[__consumer_offsets,10],[__consumer_offsets,48],[__consumer_offsets,31],[__consumer_offsets,18],[__consumer_offsets,19],[__consumer_offsets,12],[__consumer_offsets,46],[__consumer_offsets,43],[__consumer_offsets,1],[__consumer_offsets,26],[__consumer_offsets,30]
2016-08-02 05:38:11 INFO PartitionStateMachine:68 - [Partition state machine on Controller 0]: Invoking state change to NewPartition for partitions [__consumer_offsets,32],[__consumer_offsets,16],[__consumer_offsets,49],[__consumer_offsets,44],[__consumer_offsets,28],[__consumer_offsets,17],[__consumer_offsets,23],[__consumer_offsets,7],[__consumer_offsets,4],[__consumer_offsets,29],[__consumer_offsets,35],[__consumer_offsets,3],[__consumer_offsets,24],[__consumer_offsets,41],[__consumer_offsets,0],[__consumer_offsets,38],[__consumer_offsets,13],[__consumer_offsets,8],[__consumer_offsets,5],[__consumer_offsets,39],[__consumer_offsets,36],[__consumer_offsets,40],[__consumer_offsets,45],[__consumer_offsets,15],[__consumer_offsets,33],[__consumer_offsets,37],[__consumer_offsets,21],[__consumer_offsets,6],[__consumer_offsets,11],[__consumer_offsets,20],[__consumer_offsets,47],[__consumer_offsets,2],[__consumer_offsets,27],[__consumer_offsets,34],[__consumer_offsets,9],[__consumer_offsets,22],[__consumer_offsets,42],[__consumer_offsets,14],[__consumer_offsets,25],[__consumer_offsets,10],[__consumer_offsets,48],[__consumer_offsets,31],[__consumer_offsets,18],[__consumer_offsets,19],[__consumer_offsets,12],[__consumer_offsets,46],[__consumer_offsets,43],[__consumer_offsets,1],[__consumer_offsets,26],[__consumer_offsets,30]
2016-08-02 05:38:11 INFO ReplicaStateMachine:68 - [Replica state machine on controller 0]: Invoking state change to NewReplica for replicas [Topic=__consumer_offsets,Partition=25,Replica=0],[Topic=__consumer_offsets,Partition=12,Replica=0],[Topic=__consumer_offsets,Partition=31,Replica=0],[Topic=__consumer_offsets,Partition=40,Replica=0],[Topic=__consumer_offsets,Partition=35,Replica=0],[Topic=__consumer_offsets,Partition=9,Replica=0],[Topic=__consumer_offsets,Partition=43,Replica=0],[Topic=__consumer_offsets,Partition=2,Replica=0],[Topic=__consumer_offsets,Partition=11,Replica=0],[Topic=__consumer_offsets,Partition=29,Replica=0],[Topic=__consumer_offsets,Partition=30,Replica=0],[Topic=__consumer_offsets,Partition=4,Replica=0],[Topic=__consumer_offsets,Partition=42,Replica=0],[Topic=__consumer_offsets,Partition=26,Replica=0],[Topic=__consumer_offsets,Partition=34,Replica=0],[Topic=__consumer_offsets,Partition=17,Replica=0],[Topic=__consumer_offsets,Partition=37,Replica=0],[Topic=__consumer_offsets,Partition=27,Replica=0],[Topic=__consumer_offsets,Partition=10,Replica=0],[Topic=__consumer_offsets,Partition=41,Replica=0],[Topic=__consumer_offsets,Partition=20,Replica=0],[Topic=__consumer_offsets,Partition=28,Replica=0],[Topic=__consumer_offsets,Partition=46,Replica=0],[Topic=__consumer_offsets,Partition=39,Replica=0],[Topic=__consumer_offsets,Partition=47,Replica=0],[Topic=__consumer_offsets,Partition=49,Replica=0],[Topic=__consumer_offsets,Partition=22,Replica=0],[Topic=__consumer_offsets,Partition=1,Replica=0],[Topic=__consumer_offsets,Partition=24,Replica=0],[Topic=__consumer_offsets,Partition=6,Replica=0],[Topic=__consumer_offsets,Partition=36,Replica=0],[Topic=__consumer_offsets,Partition=8,Replica=0],[Topic=__consumer_offsets,Partition=38,Replica=0],[Topic=__consumer_offsets,Partition=16,Replica=0],[Topic=__consumer_offsets,Partition=21,Replica=0],[Topic=__consumer_offsets,Partition=18,Replica=0],[Topic=__consumer_offsets,Partition=0,Replica=0],[Topic=__consumer_offsets,Partition=48,Replica=0],[Topic=__consumer_offsets,Partition=5,Replica=0],[Topic=__consumer_offsets,Partition=13,Replica=0],[Topic=__consumer_offsets,Partition=3,Replica=0],[Topic=__consumer_offsets,Partition=44,Replica=0],[Topic=__consumer_offsets,Partition=15,Replica=0],[Topic=__consumer_offsets,Partition=7,Replica=0],[Topic=__consumer_offsets,Partition=19,Replica=0],[Topic=__consumer_offsets,Partition=33,Replica=0],[Topic=__consumer_offsets,Partition=45,Replica=0],[Topic=__consumer_offsets,Partition=23,Replica=0],[Topic=__consumer_offsets,Partition=32,Replica=0],[Topic=__consumer_offsets,Partition=14,Replica=0]
2016-08-02 05:38:11 INFO PartitionStateMachine:68 - [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions [__consumer_offsets,32],[__consumer_offsets,16],[__consumer_offsets,49],[__consumer_offsets,44],[__consumer_offsets,28],[__consumer_offsets,17],[__consumer_offsets,23],[__consumer_offsets,7],[__consumer_offsets,4],[__consumer_offsets,29],[__consumer_offsets,35],[__consumer_offsets,3],[__consumer_offsets,24],[__consumer_offsets,41],[__consumer_offsets,0],[__consumer_offsets,38],[__consumer_offsets,13],[__consumer_offsets,8],[__consumer_offsets,5],[__consumer_offsets,39],[__consumer_offsets,36],[__consumer_offsets,40],[__consumer_offsets,45],[__consumer_offsets,15],[__consumer_offsets,33],[__consumer_offsets,37],[__consumer_offsets,21],[__consumer_offsets,6],[__consumer_offsets,11],[__consumer_offsets,20],[__consumer_offsets,47],[__consumer_offsets,2],[__consumer_offsets,27],[__consumer_offsets,34],[__consumer_offsets,9],[__consumer_offsets,22],[__consumer_offsets,42],[__consumer_offsets,14],[__consumer_offsets,25],[__consumer_offsets,10],[__consumer_offsets,48],[__consumer_offsets,31],[__consumer_offsets,18],[__consumer_offsets,19],[__consumer_offsets,12],[__consumer_offsets,46],[__consumer_offsets,43],[__consumer_offsets,1],[__consumer_offsets,26],[__consumer_offsets,30]
2016-08-02 05:38:11 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x92 zxid:0x25 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/32 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/32
2016-08-02 05:38:11 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x93 zxid:0x26 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions
2016-08-02 05:38:11 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x98 zxid:0x2a txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/16 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/16
2016-08-02 05:38:11 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x9c zxid:0x2d txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/49 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/49
2016-08-02 05:38:11 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x9f zxid:0x30 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/44 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/44
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xa3 zxid:0x33 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/28 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/28
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xa7 zxid:0x36 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/17 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/17
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xaa zxid:0x39 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/23 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/23
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xad zxid:0x3c txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/7 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/7
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xb2 zxid:0x3f txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/4 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/4
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xb5 zxid:0x42 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/29 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/29
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xb8 zxid:0x45 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/35 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/35
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xbd zxid:0x48 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/3 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/3
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xc0 zxid:0x4b txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/24 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/24
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xc5 zxid:0x4e txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/41 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/41
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xc8 zxid:0x51 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/0 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/0
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xcb zxid:0x54 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/38 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/38
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xd0 zxid:0x57 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/13 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/13
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xd3 zxid:0x5a txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/8 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/8
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xd6 zxid:0x5d txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/5 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/5
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xdb zxid:0x60 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/39 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/39
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xde zxid:0x63 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/36 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/36
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xe2 zxid:0x66 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/40 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/40
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xe6 zxid:0x69 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/45 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/45
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xea zxid:0x6c txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/15 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/15
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xee zxid:0x6f txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/33 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/33
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xf1 zxid:0x72 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/37 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/37
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xf6 zxid:0x75 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/21 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/21
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xf9 zxid:0x78 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/6 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/6
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0xfc zxid:0x7b txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/11 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/11
2016-08-02 05:38:12 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x100 zxid:0x7e txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/20 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/20
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x104 zxid:0x81 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/47 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/47
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x107 zxid:0x84 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/2 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/2
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x10c zxid:0x87 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/27 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/27
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x10f zxid:0x8a txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/34 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/34
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x114 zxid:0x8d txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/9 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/9
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x117 zxid:0x90 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/22 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/22
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x11a zxid:0x93 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/42 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/42
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x11f zxid:0x96 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/14 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/14
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x122 zxid:0x99 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/25 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/25
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x125 zxid:0x9c txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/10 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/10
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x12a zxid:0x9f txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/48 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/48
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x12d zxid:0xa2 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/31 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/31
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x131 zxid:0xa5 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/18 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/18
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x135 zxid:0xa8 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/19 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/19
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x138 zxid:0xab txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/12 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/12
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x13d zxid:0xae txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/46 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/46
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x140 zxid:0xb1 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/43 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/43
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x143 zxid:0xb4 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/1 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/1
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x147 zxid:0xb7 txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/26 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/26
2016-08-02 05:38:13 INFO PrepRequestProcessor:645 - Got user-level KeeperException when processing sessionid:0x156491d83840000 type:create cxid:0x14b zxid:0xba txntype:-1 reqpath:n/a Error Path:/brokers/topics/__consumer_offsets/partitions/30 Error:KeeperErrorCode = NoNode for /brokers/topics/__consumer_offsets/partitions/30
2016-08-02 05:38:13 INFO ReplicaStateMachine:68 - [Replica state machine on controller 0]: Invoking state change to OnlineReplica for replicas [Topic=__consumer_offsets,Partition=25,Replica=0],[Topic=__consumer_offsets,Partition=12,Replica=0],[Topic=__consumer_offsets,Partition=31,Replica=0],[Topic=__consumer_offsets,Partition=40,Replica=0],[Topic=__consumer_offsets,Partition=35,Replica=0],[Topic=__consumer_offsets,Partition=9,Replica=0],[Topic=__consumer_offsets,Partition=43,Replica=0],[Topic=__consumer_offsets,Partition=2,Replica=0],[Topic=__consumer_offsets,Partition=11,Replica=0],[Topic=__consumer_offsets,Partition=29,Replica=0],[Topic=__consumer_offsets,Partition=30,Replica=0],[Topic=__consumer_offsets,Partition=4,Replica=0],[Topic=__consumer_offsets,Partition=42,Replica=0],[Topic=__consumer_offsets,Partition=26,Replica=0],[Topic=__consumer_offsets,Partition=34,Replica=0],[Topic=__consumer_offsets,Partition=17,Replica=0],[Topic=__consumer_offsets,Partition=37,Replica=0],[Topic=__consumer_offsets,Partition=27,Replica=0],[Topic=__consumer_offsets,Partition=10,Replica=0],[Topic=__consumer_offsets,Partition=41,Replica=0],[Topic=__consumer_offsets,Partition=20,Replica=0],[Topic=__consumer_offsets,Partition=28,Replica=0],[Topic=__consumer_offsets,Partition=46,Replica=0],[Topic=__consumer_offsets,Partition=39,Replica=0],[Topic=__consumer_offsets,Partition=47,Replica=0],[Topic=__consumer_offsets,Partition=49,Replica=0],[Topic=__consumer_offsets,Partition=22,Replica=0],[Topic=__consumer_offsets,Partition=1,Replica=0],[Topic=__consumer_offsets,Partition=24,Replica=0],[Topic=__consumer_offsets,Partition=6,Replica=0],[Topic=__consumer_offsets,Partition=36,Replica=0],[Topic=__consumer_offsets,Partition=8,Replica=0],[Topic=__consumer_offsets,Partition=38,Replica=0],[Topic=__consumer_offsets,Partition=16,Replica=0],[Topic=__consumer_offsets,Partition=21,Replica=0],[Topic=__consumer_offsets,Partition=18,Replica=0],[Topic=__consumer_offsets,Partition=0,Replica=0],[Topic=__consumer_offsets,Partition=48,Replica=0],[Topic=__consumer_offsets,Partition=5,Replica=0],[Topic=__consumer_offsets,Partition=13,Replica=0],[Topic=__consumer_offsets,Partition=3,Replica=0],[Topic=__consumer_offsets,Partition=44,Replica=0],[Topic=__consumer_offsets,Partition=15,Replica=0],[Topic=__consumer_offsets,Partition=7,Replica=0],[Topic=__consumer_offsets,Partition=19,Replica=0],[Topic=__consumer_offsets,Partition=33,Replica=0],[Topic=__consumer_offsets,Partition=45,Replica=0],[Topic=__consumer_offsets,Partition=23,Replica=0],[Topic=__consumer_offsets,Partition=32,Replica=0],[Topic=__consumer_offsets,Partition=14,Replica=0]
2016-08-02 05:38:13 INFO ReplicaFetcherManager:68 - [ReplicaFetcherManager on broker 0] Removed fetcher for partitions [__consumer_offsets,32],[__consumer_offsets,16],[__consumer_offsets,49],[__consumer_offsets,44],[__consumer_offsets,28],[__consumer_offsets,17],[__consumer_offsets,23],[__consumer_offsets,7],[__consumer_offsets,4],[__consumer_offsets,29],[__consumer_offsets,35],[__consumer_offsets,3],[__consumer_offsets,24],[__consumer_offsets,41],[__consumer_offsets,0],[__consumer_offsets,38],[__consumer_offsets,13],[__consumer_offsets,8],[__consumer_offsets,5],[__consumer_offsets,39],[__consumer_offsets,36],[__consumer_offsets,40],[__consumer_offsets,45],[__consumer_offsets,15],[__consumer_offsets,33],[__consumer_offsets,37],[__consumer_offsets,21],[__consumer_offsets,6],[__consumer_offsets,11],[__consumer_offsets,20],[__consumer_offsets,47],[__consumer_offsets,2],[__consumer_offsets,27],[__consumer_offsets,34],[__consumer_offsets,9],[__consumer_offsets,22],[__consumer_offsets,42],[__consumer_offsets,14],[__consumer_offsets,25],[__consumer_offsets,10],[__consumer_offsets,48],[__consumer_offsets,31],[__consumer_offsets,18],[__consumer_offsets,19],[__consumer_offsets,12],[__consumer_offsets,46],[__consumer_offsets,43],[__consumer_offsets,1],[__consumer_offsets,26],[__consumer_offsets,30]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-0 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,0] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,0] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,0]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-29 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,29] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,29] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,29]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-48 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,48] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,48] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,48]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-10 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,10] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,10] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,10]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-45 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,45] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,45] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,45]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-26 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,26] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,26] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,26]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-7 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,7] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,7] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,7]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-42 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,42] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,42] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,42]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-4 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,4] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,4] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,4]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-23 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,23] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,23] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,23]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-1 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,1] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,1] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,1]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-39 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,39] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,39] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,39]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-20 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,20] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,20] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,20]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-17 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,17] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,17] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,17]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-36 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,36] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,36] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,36]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-14 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,14] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,14] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,14]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-33 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,33] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,33] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,33]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-49 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,49] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,49] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,49]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-11 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,11] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,11] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,11]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-30 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,30] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,30] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,30]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-46 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,46] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,46] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,46]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-27 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,27] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,27] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,27]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-8 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,8] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,8] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,8]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-24 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,24] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,24] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,24]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-43 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,43] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,43] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,43]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-5 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,5] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,5] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,5]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-21 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,21] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,21] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,21]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-40 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,40] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,40] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,40]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-2 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,2] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,2] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,2]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-37 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,37] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,37] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,37]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-18 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,18] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,18] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,18]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-15 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,15] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:13 INFO Partition:68 - Partition [__consumer_offsets,15] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,15]
2016-08-02 05:38:13 INFO Log:68 - Completed load of log __consumer_offsets-34 with log end offset 0
2016-08-02 05:38:13 INFO LogManager:68 - Created log for partition [__consumer_offsets,34] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,34] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,34]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-12 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,12] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,12] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,12]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-31 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,31] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,31] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,31]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-9 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,9] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,9] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,9]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-47 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,47] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,47] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,47]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-19 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,19] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,19] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,19]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-28 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,28] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,28] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,28]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-38 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,38] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,38] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,38]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-35 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,35] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,35] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,35]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-44 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,44] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,44] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,44]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-6 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,6] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,6] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,6]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-25 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,25] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,25] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,25]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-16 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,16] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,16] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,16]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-22 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,22] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,22] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,22]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-41 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,41] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,41] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,41]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-32 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,32] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,32] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,32]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-3 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,3] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,3] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,3]
2016-08-02 05:38:14 INFO Log:68 - Completed load of log __consumer_offsets-13 with log end offset 0
2016-08-02 05:38:14 INFO LogManager:68 - Created log for partition [__consumer_offsets,13] in /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka with properties {compression.type -> uncompressed, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> compact, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 104857600, retention.ms -> 604800000, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}.
2016-08-02 05:38:14 INFO Partition:68 - Partition [__consumer_offsets,13] on broker 0: No checkpointed highwatermark is found for partition [__consumer_offsets,13]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,22]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,22] in 19 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,25]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,25] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,28]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,28] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,31]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,31] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,34]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,34] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,37]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,37] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,40]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,40] in 2 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,43]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,43] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,46]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,46] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,49]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,49] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,41]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,41] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,44]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,44] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,47]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,47] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,1]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,1] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,4]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,4] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,7]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,7] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,10]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,10] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,13]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,13] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,16]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,16] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,19]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,19] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,2]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,2] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,5]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,5] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,8]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,8] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,11]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,11] in 7 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,14]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,14] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,17]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,17] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,20]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,20] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,23]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,23] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,26]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,26] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,29]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,29] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,32]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,32] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,35]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,35] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,38]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,38] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,0]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,0] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,3]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,3] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,6]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,6] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,9]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,9] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,12]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,12] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,15]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,15] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,18]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,18] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,21]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,21] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,24]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,24] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,27]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,27] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,30]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,30] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,33]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,33] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,36]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,36] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,39]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,39] in 5 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,42]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,42] in 0 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,45]
2016-08-02 05:38:14 ERROR KafkaApis:103 - [KafkaApi-0] error when handling request null
java.lang.ClassCastException: org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata cannot be cast to org.apache.kafka.common.requests.JoinGroupRequest$GroupProtocol
at kafka.server.KafkaApis$$anonfun$37.apply(KafkaApis.scala:788)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at scala.collection.Iterator$class.foreach(Iterator.scala:727)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
at scala.collection.AbstractTraversable.map(Traversable.scala:105)
at kafka.server.KafkaApis.handleJoinGroupRequest(KafkaApis.scala:788)
at kafka.server.KafkaApis.handle(KafkaApis.scala:79)
at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60)
at java.lang.Thread.run(Thread.java:745)
2016-08-02 05:38:14 INFO KafkaLocalBroker:195 - KAFKA: Stopping Kafka on port: 11111
2016-08-02 05:38:14 INFO KafkaServer:68 - [Kafka Server 0], shutting down
2016-08-02 05:38:14 INFO KafkaServer:68 - [Kafka Server 0], Starting controlled shutdown
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,45] in 1 milliseconds.
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Loading offsets and group metadata from [__consumer_offsets,48]
2016-08-02 05:38:14 INFO GroupMetadataManager:68 - [Group Metadata Manager on Broker 0]: Finished loading offsets from [__consumer_offsets,48] in 1 milliseconds.
2016-08-02 05:38:14 INFO KafkaController:68 - [Controller 0]: Shutting down broker 0
2016-08-02 05:38:14 INFO KafkaServer:68 - [Kafka Server 0], Controlled shutdown succeeded
2016-08-02 05:38:14 INFO SocketServer:68 - [Socket Server on Broker 0], Shutting down
2016-08-02 05:38:14 INFO SocketServer:68 - [Socket Server on Broker 0], Shutdown completed
2016-08-02 05:38:14 INFO KafkaRequestHandlerPool:68 - [Kafka Request Handler on Broker 0], shutting down
2016-08-02 05:38:14 INFO KafkaRequestHandlerPool:68 - [Kafka Request Handler on Broker 0], shut down completely
2016-08-02 05:38:14 INFO ClientQuotaManager$ThrottledRequestReaper:68 - [ThrottledRequestReaper-Produce], Shutting down
2016-08-02 05:38:14 INFO ClientQuotaManager$ThrottledRequestReaper:68 - [ThrottledRequestReaper-Produce], Stopped
2016-08-02 05:38:14 INFO ClientQuotaManager$ThrottledRequestReaper:68 - [ThrottledRequestReaper-Produce], Shutdown completed
2016-08-02 05:38:14 INFO ClientQuotaManager$ThrottledRequestReaper:68 - [ThrottledRequestReaper-Fetch], Shutting down
2016-08-02 05:38:14 INFO ClientQuotaManager$ThrottledRequestReaper:68 - [ThrottledRequestReaper-Fetch], Stopped
2016-08-02 05:38:14 INFO ClientQuotaManager$ThrottledRequestReaper:68 - [ThrottledRequestReaper-Fetch], Shutdown completed
2016-08-02 05:38:14 INFO KafkaApis:68 - [KafkaApi-0] Shutdown complete.
2016-08-02 05:38:14 INFO ReplicaManager:68 - [Replica Manager on Broker 0]: Shutting down
2016-08-02 05:38:14 INFO ReplicaFetcherManager:68 - [ReplicaFetcherManager on broker 0] shutting down
2016-08-02 05:38:14 INFO ReplicaFetcherManager:68 - [ReplicaFetcherManager on broker 0] shutdown completed
2016-08-02 05:38:14 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Shutting down
2016-08-02 05:38:14 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Stopped
2016-08-02 05:38:14 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Shutdown completed
2016-08-02 05:38:14 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Shutting down
2016-08-02 05:38:14 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Stopped
2016-08-02 05:38:14 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Shutdown completed
2016-08-02 05:38:14 INFO ReplicaManager:68 - [Replica Manager on Broker 0]: Shut down completely
2016-08-02 05:38:14 INFO LogManager:68 - Shutting down.
2016-08-02 05:38:14 INFO LogCleaner:68 - Shutting down the log cleaner.
2016-08-02 05:38:14 INFO LogCleaner:68 - [kafka-log-cleaner-thread-0], Shutting down
2016-08-02 05:38:14 INFO LogCleaner:68 - [kafka-log-cleaner-thread-0], Stopped
2016-08-02 05:38:14 INFO LogCleaner:68 - [kafka-log-cleaner-thread-0], Shutdown completed
2016-08-02 05:38:15 INFO LogManager:68 - Shutdown complete.
2016-08-02 05:38:15 INFO GroupCoordinator:68 - [GroupCoordinator 0]: Shutting down.
2016-08-02 05:38:15 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Shutting down
2016-08-02 05:38:15 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Stopped
2016-08-02 05:38:15 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Shutdown completed
2016-08-02 05:38:15 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Shutting down
2016-08-02 05:38:15 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Stopped
2016-08-02 05:38:15 INFO DelayedOperationPurgatory$ExpiredOperationReaper:68 - [ExpirationReaper-0], Shutdown completed
2016-08-02 05:38:15 INFO GroupCoordinator:68 - [GroupCoordinator 0]: Shutdown complete.
2016-08-02 05:38:15 INFO PartitionStateMachine:68 - [Partition state machine on Controller 0]: Stopped partition state machine
2016-08-02 05:38:15 INFO ReplicaStateMachine:68 - [Replica state machine on controller 0]: Stopped replica state machine
2016-08-02 05:38:15 INFO RequestSendThread:68 - [kafka-mini-cluster:Controller-0-to-broker-0-send-thread], Shutting down
2016-08-02 05:38:15 INFO RequestSendThread:68 - [kafka-mini-cluster:Controller-0-to-broker-0-send-thread], Stopped
2016-08-02 05:38:15 INFO RequestSendThread:68 - [kafka-mini-cluster:Controller-0-to-broker-0-send-thread], Shutdown completed
2016-08-02 05:38:15 INFO KafkaController:68 - [Controller 0]: Broker 0 resigned as the controller
2016-08-02 05:38:15 INFO ZkEventThread:82 - Terminate ZkClient event thread.
2016-08-02 05:38:15 INFO PrepRequestProcessor:494 - Processed session termination for sessionid: 0x156491d83840000
2016-08-02 05:38:15 INFO ZooKeeper:684 - Session: 0x156491d83840000 closed
2016-08-02 05:38:15 INFO ClientCnxn:524 - EventThread shut down
2016-08-02 05:38:15 INFO NIOServerCnxn:1007 - Closed socket connection for client /127.0.0.1:37628 which had sessionid 0x156491d83840000
2016-08-02 05:38:15 INFO KafkaServer:68 - [Kafka Server 0], shut down completed
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-36
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-3
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-41
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-9
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-20
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-11
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-22
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-7
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-5
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-19
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-12
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-21
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-8
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-40
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-25
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-45
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-18
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-42
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-0
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-10
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-47
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-31
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-38
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-29
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-6
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-24
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-16
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-13
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-44
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/test-0
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-14
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-39
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-15
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-27
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-35
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-32
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-43
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-46
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-37
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-49
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-48
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-2
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-1
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-34
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-28
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-17
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-23
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-26
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-4
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-30
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_kafka/__consumer_offsets-33
2016-08-02 05:38:15 INFO ZookeeperLocalCluster:187 - ZOOKEEPER: Stopping Zookeeper on port: 23456
2016-08-02 05:38:15 INFO NIOServerCnxnFactory:224 - NIOServerCnxn factory exited run method
2016-08-02 05:38:15 INFO ZooKeeperServer:441 - shutting down
2016-08-02 05:38:15 INFO SessionTrackerImpl:225 - Shutting down
2016-08-02 05:38:15 INFO PrepRequestProcessor:761 - Shutting down
2016-08-02 05:38:15 INFO SyncRequestProcessor:209 - Shutting down
2016-08-02 05:38:15 INFO PrepRequestProcessor:143 - PrepRequestProcessor exited loop!
2016-08-02 05:38:15 INFO ZooKeeperServer:441 - shutting down
2016-08-02 05:38:15 INFO SessionTrackerImpl:225 - Shutting down
2016-08-02 05:38:15 INFO SyncRequestProcessor:187 - SyncRequestProcessor exited!
2016-08-02 05:38:15 INFO PrepRequestProcessor:761 - Shutting down
2016-08-02 05:38:15 INFO FinalRequestProcessor:415 - shutdown of request processor complete
2016-08-02 05:38:15 INFO SyncRequestProcessor:209 - Shutting down
2016-08-02 05:38:15 INFO FinalRequestProcessor:415 - shutdown of request processor complete
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_zookeeper
2016-08-02 05:38:15 INFO FileUtils:17 - FILEUTILS: Deleting contents of directory: /home/sam/IdeaProjects/affinytix-stream-kafka/embedded_zookeeper/version-2
2016-08-02 05:38:15 INFO TestSendingReceiving:75 - /home/sam/IdeaProjects/affinytix-stream-kafka
Unexpected error in join group response: The server experienced an unexpected error when processing the request
org.apache.kafka.common.KafkaException: Unexpected error in join group response: The server experienced an unexpected error when processing the request
at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:376)
at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:324)
at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:665)
at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:644)
at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:167)
at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:133)
at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:107)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.onComplete(ConsumerNetworkClient.java:380)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:274)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:320)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:213)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:193)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:163)
at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:222)
at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.ensurePartitionAssignment(ConsumerCoordinator.java:311)
at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:890)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:853)
at com.affinytix.stream.kafka.consumer.partition.BasicPartitionConsumer.consumer(BasicPartitionConsumer.java:32)
at com.affinytix.stream.kafka.consumer.receiver.MaxConsumerReceiver.process(MaxConsumerReceiver.java:52)
at TestSendingReceiving$$anonfun$2.apply$mcV$sp(TestSendingReceiving.scala:118)
at TestSendingReceiving$$anonfun$2.apply(TestSendingReceiving.scala:82)
at TestSendingReceiving$$anonfun$2.apply(TestSendingReceiving.scala:82)
at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22)
at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
at org.scalatest.Transformer.apply(Transformer.scala:22)
at org.scalatest.Transformer.apply(Transformer.scala:20)
at org.scalatest.FlatSpecLike$$anon$1.apply(FlatSpecLike.scala:1647)
at org.scalatest.Suite$class.withFixture(Suite.scala:1122)
at TestSendingReceiving.withFixture(TestSendingReceiving.scala:59)
at org.scalatest.FlatSpecLike$class.invokeWithFixture$1(FlatSpecLike.scala:1644)
at org.scalatest.FlatSpecLike$$anonfun$runTest$1.apply(FlatSpecLike.scala:1656)
at org.scalatest.FlatSpecLike$$anonfun$runTest$1.apply(FlatSpecLike.scala:1656)
at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306)
at org.scalatest.FlatSpecLike$class.runTest(FlatSpecLike.scala:1656)
at TestSendingReceiving.org$scalatest$BeforeAndAfter$$super$runTest(TestSendingReceiving.scala:17)
at org.scalatest.BeforeAndAfter$class.runTest(BeforeAndAfter.scala:200)
at TestSendingReceiving.runTest(TestSendingReceiving.scala:17)
at org.scalatest.FlatSpecLike$$anonfun$runTests$1.apply(FlatSpecLike.scala:1714)
at org.scalatest.FlatSpecLike$$anonfun$runTests$1.apply(FlatSpecLike.scala:1714)
at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:413)
at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:401)
at scala.collection.immutable.List.foreach(List.scala:318)
at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:390)
at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:427)
at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:401)
at scala.collection.immutable.List.foreach(List.scala:318)
at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:396)
at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:483)
at org.scalatest.FlatSpecLike$class.runTests(FlatSpecLike.scala:1714)
at org.scalatest.FlatSpec.runTests(FlatSpec.scala:1683)
at org.scalatest.Suite$class.run(Suite.scala:1424)
at org.scalatest.FlatSpec.org$scalatest$FlatSpecLike$$super$run(FlatSpec.scala:1683)
at org.scalatest.FlatSpecLike$$anonfun$run$1.apply(FlatSpecLike.scala:1760)
at org.scalatest.FlatSpecLike$$anonfun$run$1.apply(FlatSpecLike.scala:1760)
at org.scalatest.SuperEngine.runImpl(Engine.scala:545)
at org.scalatest.FlatSpecLike$class.run(FlatSpecLike.scala:1760)
at TestSendingReceiving.org$scalatest$BeforeAndAfter$$super$run(TestSendingReceiving.scala:17)
at org.scalatest.BeforeAndAfter$class.run(BeforeAndAfter.scala:241)
at TestSendingReceiving.run(TestSendingReceiving.scala:17)
at org.scalatest.tools.SuiteRunner.run(SuiteRunner.scala:55)
at org.scalatest.tools.Runner$$anonfun$doRunRunRunDaDoRunRun$3.apply(Runner.scala:2563)
at org.scalatest.tools.Runner$$anonfun$doRunRunRunDaDoRunRun$3.apply(Runner.scala:2557)
at scala.collection.immutable.List.foreach(List.scala:318)
at org.scalatest.tools.Runner$.doRunRunRunDaDoRunRun(Runner.scala:2557)
at org.scalatest.tools.Runner$$anonfun$runOptionallyWithPassFailReporter$2.apply(Runner.scala:1044)
at org.scalatest.tools.Runner$$anonfun$runOptionallyWithPassFailReporter$2.apply(Runner.scala:1043)
at org.scalatest.tools.Runner$.withClassLoaderAndDispatchReporter(Runner.scala:2722)
at org.scalatest.tools.Runner$.runOptionallyWithPassFailReporter(Runner.scala:1043)
at org.scalatest.tools.Runner$.run(Runner.scala:883)
at org.scalatest.tools.Runner.run(Runner.scala)
at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.runScalaTest2(ScalaTestRunner.java:138)
at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.main(ScalaTestRunner.java:28)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147)
Process finished with exit code 0
Would it be possible to share the code?
I expect that this could be related to the use of the new consumer API in conjunction with this version of Kafka, as it wasn't fully baked as of this version (what we have here is Kakfa 0.8.2 with the SSL/Kerberos bits back ported).
Hello and thanks for your quick answer,
My excuses for my fault it was the conjunction of two bugs (using the new API):
- I didn't know that subscribing by topic does not imply an immediate assignment of partition to the consumers but wait for call to poll() or position() say. It gave me a list of consumer but the seek operation I did after that could not do anything (post-writing on the partition). I used the more secure assign().
- The use of sbt also erred me in a way because I didn't know test were executed in parallel by default and did not measured the consequence with all this little lighted server around...
I can add doc to the wiki if you wish to give examples of my test in scala that are working know but I have to admit I don't know a lot about collaborating on github to a project. But in case it could help just tell me.
Nice project by the way it helps me a lot know.
@samouille666 - no problem! Glad to hear you got it working.
I'd love to add some scala examples, either in the wiki or the README. If you'd like to put them in the README, the easiest way would be to fork the project, update the README with your additions, commit, and then open a pull request. I can merge it into the code base from the pull request (and you get credit for the contribution). Otherwise, feel free to send me some examples directly (or via this ticket) and I'll get them added.
Thanks for the kind words regarding the project!