05:29:35,027 [ main] DEBUG KafkaMessagingTest - testing: KafkaMessagingTest1398310175026
05:29:35,043 [ main] DEBUG ZkConnection - Creating new ZookKeeper instance to connect to gk.
05:29:35,043 [23-gk] INFO  ZkEventThread - Starting ZkClient event thread.
05:29:35,058 [ main] INFO  ZooKeeper - Client environment:zookeeper.version=3.4.5-1392090, built on 09/30/2012 17:52 GMT
05:29:35,058 [ main] INFO  ZooKeeper - Client environment:host.name=dev
05:29:35,059 [ main] INFO  ZooKeeper - Client environment:java.version=1.7.0_51
05:29:35,059 [ main] INFO  ZooKeeper - Client environment:java.vendor=Oracle Corporation
05:29:35,059 [ main] INFO  ZooKeeper - Client environment:java.home=/usr/lib/jvm/java-1.7.0-openjdk-1.7.0.51.x86_64/jre
05:29:35,059 [ main] INFO  ZooKeeper - Client environment:java.class.path=/var/lib/jenkins/jobs/sysnature.integration/workspace/aa.sysnature.messaging/target/test-classes:/var/lib/jenkins/jobs/sysnature.integration/workspace/aa.sysnature.messaging/target/classes:/var/lib/jenkins/jobs/sysnature.integration/workspace/aa.sysnature.core/target/classes:/var/lib/jenkins/jobs/sysnature.integration/workspace/aa.sysnature.util/target/classes:/var/lib/jenkins/.m2/repository/com/g414/hash/g414-hash/0.7.4.1-SNAPSHOT/g414-hash-0.7.4.1-SNAPSHOT.jar:/var/lib/jenkins/.m2/repository/com/fasterxml/uuid/java-uuid-generator/3.1.3/java-uuid-generator-3.1.3.jar:/var/lib/jenkins/.m2/repository/org/aspectj/aspectjrt/1.7.3/aspectjrt-1.7.3.jar:/var/lib/jenkins/.m2/repository/org/aspectj/aspectjweaver/1.7.3/aspectjweaver-1.7.3.jar:/var/lib/jenkins/.m2/repository/org/springframework/spring-aspects/3.2.4.RELEASE/spring-aspects-3.2.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/spring-context-support/3.2.4.RELEASE/spring-context-support-3.2.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/commons-lang/commons-lang/2.6/commons-lang-2.6.jar:/var/lib/jenkins/.m2/repository/org/apache/commons/commons-lang3/3.1/commons-lang3-3.1.jar:/var/lib/jenkins/.m2/repository/com/nuodb/nuodb-jdbc/2.0.0/nuodb-jdbc-2.0.0.jar:/var/lib/jenkins/.m2/repository/com/nuodb/nuodb-hibernate/2.0.0/nuodb-hibernate-2.0.0.jar:/var/lib/jenkins/.m2/repository/org/clapper/javautil/3.1.1/javautil-3.1.1.jar:/var/lib/jenkins/.m2/repository/javax/activation/activation/1.1-rev-1/activation-1.1-rev-1.jar:/var/lib/jenkins/.m2/repository/asm/asm/3.3.1/asm-3.3.1.jar:/var/lib/jenkins/.m2/repository/asm/asm-commons/3.3.1/asm-commons-3.3.1.jar:/var/lib/jenkins/.m2/repository/asm/asm-tree/3.3.1/asm-tree-3.3.1.jar:/var/lib/jenkins/.m2/repository/org/freemarker/freemarker/2.3.19/freemarker-2.3.19.jar:/var/lib/jenkins/.m2/repository/com/esotericsoftware/kryo/kryo/2.16/kryo-2.16.jar:/var/lib/jenkins/.m2/repository/com/esotericsoftware/reflectasm/reflectasm/1.06/reflectasm-1.06-shaded.jar:/var/lib/jenkins/.m2/repository/org/ow2/asm/asm/4.0/asm-4.0.jar:/var/lib/jenkins/.m2/repository/com/esotericsoftware/minlog/minlog/1.2/minlog-1.2.jar:/var/lib/jenkins/.m2/repository/org/objenesis/objenesis/1.2/objenesis-1.2.jar:/var/lib/jenkins/.m2/repository/com/google/code/findbugs/jsr305/1.3.7/jsr305-1.3.7.jar:/var/lib/jenkins/.m2/repository/xerces/xercesImpl/2.10.0/xercesImpl-2.10.0.jar:/var/lib/jenkins/.m2/repository/xml-apis/xml-apis/1.4.01/xml-apis-1.4.01.jar:/var/lib/jenkins/.m2/repository/org/iq80/snappy/snappy/0.3/snappy-0.3.jar:/var/lib/jenkins/.m2/repository/org/twitter4j/twitter4j-core/2.2.5/twitter4j-core-2.2.5.jar:/var/lib/jenkins/.m2/repository/org/twitter4j/twitter4j-httpclient-support/2.2.5/twitter4j-httpclient-support-2.2.5.jar:/var/lib/jenkins/.m2/repository/net/sf/trove4j/trove4j/3.0.3/trove4j-3.0.3.jar:/var/lib/jenkins/.m2/repository/com/thoughtworks/xstream/xstream/1.4.4/xstream-1.4.4.jar:/var/lib/jenkins/.m2/repository/xmlpull/xmlpull/1.1.3.1/xmlpull-1.1.3.1.jar:/var/lib/jenkins/.m2/repository/xpp3/xpp3_min/1.1.4c/xpp3_min-1.1.4c.jar:/var/lib/jenkins/.m2/repository/org/mockito/mockito-all/1.8.5/mockito-all-1.8.5.jar:/var/lib/jenkins/.m2/repository/org/functionaljava/functionaljava/3.0/functionaljava-3.0.jar:/var/lib/jenkins/.m2/repository/cglib/cglib-nodep/2.2/cglib-nodep-2.2.jar:/var/lib/jenkins/.m2/repository/org/javassist/javassist/3.15.0-GA/javassist-3.15.0-GA.jar:/var/lib/jenkins/.m2/repository/org/datanucleus/datanucleus-rdbms/3.0.4/datanucleus-rdbms-3.0.4.jar:/var/lib/jenkins/.m2/repository/org/datanucleus/datanucleus-enhancer/3.0.1/datanucleus-enhancer-3.0.1.jar:/var/lib/jenkins/.m2/repository/org/datanucleus/datanucleus-core/3.0.4/datanucleus-core-3.0.4.jar:/var/lib/jenkins/.m2/repository/org/datanucleus/datanucleus-api-jdo/3.0.4/datanucleus-api-jdo-3.0.4.jar:/var/lib/jenkins/.m2/repository/org/datanucleus/datanucleus-api-jpa/3.0.4/datanucleus-api-jpa-3.0.4.jar:/var/lib/jenkins/.m2/repository/javax/jdo/jdo-api/3.0/jdo-api-3.0.jar:/var/lib/jenkins/.m2/repository/javax/transaction/transaction-api/1.1/transaction-api-1.1.jar:/var/lib/jenkins/.m2/repository/org/scribe/scribe/1.2.3/scribe-1.2.3.jar:/var/lib/jenkins/.m2/repository/commons-codec/commons-codec/1.4/commons-codec-1.4.jar:/var/lib/jenkins/.m2/repository/org/mozilla/rhino/1.7R4/rhino-1.7R4.jar:/var/lib/jenkins/.m2/repository/org/apache/solr/solr-solrj/3.1.0/solr-solrj-3.1.0.jar:/var/lib/jenkins/.m2/repository/org/apache/lucene/lucene-core/3.1.0/lucene-core-3.1.0.jar:/var/lib/jenkins/.m2/repository/org/apache/geronimo/specs/geronimo-stax-api_1.0_spec/1.0.1/geronimo-stax-api_1.0_spec-1.0.1.jar:/var/lib/jenkins/.m2/repository/commons-io/commons-io/2.1/commons-io-2.1.jar:/var/lib/jenkins/.m2/repository/ha-javamail/ha-javamail/1.0-beta-1/ha-javamail-1.0-beta-1.jar:/var/lib/jenkins/.m2/repository/com/googlecode/json-simple/json-simple/1.1/json-simple-1.1.jar:/var/lib/jenkins/.m2/repository/net/sf/json-lib/json-lib/2.4/json-lib-2.4-jdk15.jar:/var/lib/jenkins/.m2/repository/commons-beanutils/commons-beanutils/1.8.0/commons-beanutils-1.8.0.jar:/var/lib/jenkins/.m2/repository/commons-collections/commons-collections/3.2.1/commons-collections-3.2.1.jar:/var/lib/jenkins/.m2/repository/net/sf/ezmorph/ezmorph/1.0.6/ezmorph-1.0.6.jar:/var/lib/jenkins/.m2/repository/org/codehaus/jackson/jackson-core-asl/1.9.7/jackson-core-asl-1.9.7.jar:/var/lib/jenkins/.m2/repository/org/codehaus/jackson/jackson-mapper-asl/1.9.7/jackson-mapper-asl-1.9.7.jar:/var/lib/jenkins/.m2/repository/org/codehaus/jackson/jackson-smile/1.9.7/jackson-smile-1.9.7.jar:/var/lib/jenkins/.m2/repository/org/codehaus/jackson/jackson-xc/1.9.7/jackson-xc-1.9.7.jar:/var/lib/jenkins/.m2/repository/com/fasterxml/jackson-xml-databind/0.6.2/jackson-xml-databind-0.6.2.jar:/var/lib/jenkins/.m2/repository/de/undercouch/bson4jackson/1.1.2/bson4jackson-1.1.2.jar:/var/lib/jenkins/.m2/repository/org/apache/openjpa/openjpa/2.1.0/openjpa-2.1.0.jar:/var/lib/jenkins/.m2/repository/net/sourceforge/serp/serp/1.13.1/serp-1.13.1.jar:/var/lib/jenkins/.m2/repository/org/apache/geronimo/specs/geronimo-jta_1.1_spec/1.1.1/geronimo-jta_1.1_spec-1.1.1.jar:/var/lib/jenkins/.m2/repository/org/apache/geronimo/specs/geronimo-jpa_2.0_spec/1.1/geronimo-jpa_2.0_spec-1.1.jar:/var/lib/jenkins/.m2/repository/com/urbanmania/spring-property-annotations/0.1.8/spring-property-annotations-0.1.8.jar:/var/lib/jenkins/.m2/repository/opensymphony/oscache/2.4.1/oscache-2.4.1.jar:/var/lib/jenkins/.m2/repository/javax/inject/javax.inject/1/javax.inject-1.jar:/var/lib/jenkins/.m2/repository/javax/mail/mail/1.4.3/mail-1.4.3.jar:/var/lib/jenkins/.m2/repository/commons-httpclient/commons-httpclient/3.1/commons-httpclient-3.1.jar:/var/lib/jenkins/.m2/repository/com/ocpsoft/ocpsoft-pretty-time/1.0.6/ocpsoft-pretty-time-1.0.6.jar:/var/lib/jenkins/.m2/repository/com/eaio/uuid/uuid/3.2/uuid-3.2.jar:/var/lib/jenkins/.m2/repository/org/springframework/social/spring-social-core/1.0.2.RELEASE/spring-social-core-1.0.2.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/social/spring-social-facebook/1.0.2.RELEASE/spring-social-facebook-1.0.2.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/social/spring-social-facebook-web/1.0.2.RELEASE/spring-social-facebook-web-1.0.2.RELEASE.jar:/var/lib/jenkins/.m2/repository/javax/servlet/jsp/jsp-api/2.2/jsp-api-2.2.jar:/var/lib/jenkins/.m2/repository/org/springframework/social/spring-social-twitter/1.0.2.RELEASE/spring-social-twitter-1.0.2.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/social/spring-social-web/1.0.2.RELEASE/spring-social-web-1.0.2.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/apache/wicket/wicket-util/1.5-rc2/wicket-util-1.5-rc2.jar:/var/lib/jenkins/.m2/repository/mysql/mysql-connector-java/5.1.14/mysql-connector-java-5.1.14.jar:/var/lib/jenkins/.m2/repository/javax/jdo/jdo2-api/2.3-ea/jdo2-api-2.3-ea.jar:/var/lib/jenkins/.m2/repository/org/slf4j/jul-to-slf4j/1.7.5/jul-to-slf4j-1.7.5.jar:/var/lib/jenkins/.m2/repository/net/sf/flexjson/flexjson/2.1/flexjson-2.1.jar:/var/lib/jenkins/.m2/repository/org/springframework/spring-webmvc/3.2.4.RELEASE/spring-webmvc-3.2.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/spring-expression/3.2.4.RELEASE/spring-expression-3.2.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/spring-core/3.2.4.RELEASE/spring-core-3.2.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/spring-context/3.2.4.RELEASE/spring-context-3.2.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/spring-aop/3.2.4.RELEASE/spring-aop-3.2.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/aopalliance/aopalliance/1.0/aopalliance-1.0.jar:/var/lib/jenkins/.m2/repository/org/springframework/spring-tx/3.2.4.RELEASE/spring-tx-3.2.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/spring-jms/3.2.4.RELEASE/spring-jms-3.2.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/hibernate/hibernate-core/3.6.6.Final/hibernate-core-3.6.6.Final.jar:/var/lib/jenkins/.m2/repository/antlr/antlr/2.7.6/antlr-2.7.6.jar:/var/lib/jenkins/.m2/repository/dom4j/dom4j/1.6.1/dom4j-1.6.1.jar:/var/lib/jenkins/.m2/repository/org/hibernate/hibernate-commons-annotations/3.2.0.Final/hibernate-commons-annotations-3.2.0.Final.jar:/var/lib/jenkins/.m2/repository/org/hibernate/hibernate-entitymanager/3.6.6.Final/hibernate-entitymanager-3.6.6.Final.jar:/var/lib/jenkins/.m2/repository/org/hibernate/javax/persistence/hibernate-jpa-2.0-api/1.0.0.Final/hibernate-jpa-2.0-api-1.0.0.Final.jar:/var/lib/jenkins/.m2/repository/org/hibernate/hibernate-validator/4.2.0.Final/hibernate-validator-4.2.0.Final.jar:/var/lib/jenkins/.m2/repository/javax/validation/validation-api/1.0.0.GA/validation-api-1.0.0.GA.jar:/var/lib/jenkins/.m2/repository/javax/transaction/jta/1.1/jta-1.1.jar:/var/lib/jenkins/.m2/repository/org/springframework/spring-jdbc/3.2.4.RELEASE/spring-jdbc-3.2.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/spring-orm/3.2.4.RELEASE/spring-orm-3.2.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/commons-pool/commons-pool/1.5.4/commons-pool-1.5.4.jar:/var/lib/jenkins/.m2/repository/com/jolbox/bonecp/0.8.0-rc3/bonecp-0.8.0-rc3.jar:/var/lib/jenkins/.m2/repository/commons-dbcp/commons-dbcp/1.3/commons-dbcp-1.3.jar:/var/lib/jenkins/.m2/repository/org/springframework/spring-web/3.2.4.RELEASE/spring-web-3.2.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/commons-digester/commons-digester/2.0/commons-digester-2.0.jar:/var/lib/jenkins/.m2/repository/commons-fileupload/commons-fileupload/1.2.1/commons-fileupload-1.2.1.jar:/var/lib/jenkins/.m2/repository/javax/servlet/jstl/1.2/jstl-1.2.jar:/var/lib/jenkins/.m2/repository/joda-time/joda-time/1.6/joda-time-1.6.jar:/var/lib/jenkins/.m2/repository/org/springframework/security/spring-security-core/3.1.4.RELEASE/spring-security-core-3.1.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/security/spring-security-config/3.1.4.RELEASE/spring-security-config-3.1.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/security/spring-security-web/3.1.4.RELEASE/spring-security-web-3.1.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/security/spring-security-crypto/3.1.4.RELEASE/spring-security-crypto-3.1.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/security/spring-security-taglibs/3.1.4.RELEASE/spring-security-taglibs-3.1.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/security/spring-security-acl/3.1.4.RELEASE/spring-security-acl-3.1.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/spring-beans/3.2.4.RELEASE/spring-beans-3.2.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/springframework/spring-oxm/3.2.4.RELEASE/spring-oxm-3.2.4.RELEASE.jar:/var/lib/jenkins/.m2/repository/org/apache/geronimo/specs/geronimo-jms_1.1_spec/1.1/geronimo-jms_1.1_spec-1.1.jar:/var/lib/jenkins/.m2/repository/org/apache/activemq/activemq-optional/5.7.0/activemq-optional-5.7.0.jar:/var/lib/jenkins/.m2/repository/org/apache/activemq/activemq-console/5.7.0/activemq-console-5.7.0.jar:/var/lib/jenkins/.m2/repository/commons-daemon/commons-daemon/1.0.10/commons-daemon-1.0.10.jar:/var/lib/jenkins/.m2/repository/xpp3/xpp3/1.1.4c/xpp3-1.1.4c.jar:/var/lib/jenkins/.m2/repository/org/eclipse/jetty/aggregate/jetty-all-server/7.6.7.v20120910/jetty-all-server-7.6.7.v20120910.jar:/var/lib/jenkins/.m2/repository/org/eclipse/jetty/orbit/javax.security.auth.message/1.0.0.v201108011116/javax.security.auth.message-1.0.0.v201108011116.jar:/var/lib/jenkins/.m2/repository/org/eclipse/jetty/orbit/javax.activation/1.1.0.v201105071233/javax.activation-1.1.0.v201105071233.jar:/var/lib/jenkins/.m2/repository/org/eclipse/jetty/orbit/javax.annotation/1.1.0.v201108011116/javax.annotation-1.1.0.v201108011116.jar:/var/lib/jenkins/.m2/repository/org/eclipse/jetty/jetty-webapp/7.3.0.v20110203/jetty-webapp-7.3.0.v20110203.jar:/var/lib/jenkins/.m2/repository/org/eclipse/jetty/jetty-xml/7.3.0.v20110203/jetty-xml-7.3.0.v20110203.jar:/var/lib/jenkins/.m2/repository/org/eclipse/jetty/jetty-servlet/8.1.7.v20120910/jetty-servlet-8.1.7.v20120910.jar:/var/lib/jenkins/.m2/repository/org/eclipse/jetty/jetty-websocket/7.6.7.v20120910/jetty-websocket-7.6.7.v20120910.jar:/var/lib/jenkins/.m2/repository/org/eclipse/jetty/jetty-util/7.3.0.v20110203/jetty-util-7.3.0.v20110203.jar:/var/lib/jenkins/.m2/repository/org/eclipse/jetty/jetty-io/7.6.7.v20120910/jetty-io-7.6.7.v20120910.jar:/var/lib/jenkins/.m2/repository/org/eclipse/jetty/jetty-http/7.6.7.v20120910/jetty-http-7.6.7.v20120910.jar:/var/lib/jenkins/.m2/repository/org/apache/httpcomponents/httpclient/4.2/httpclient-4.2.jar:/var/lib/jenkins/.m2/repository/org/apache/httpcomponents/httpcore/4.2/httpcore-4.2.jar:/var/lib/jenkins/.m2/repository/org/apache/velocity/velocity/1.7/velocity-1.7.jar:/var/lib/jenkins/.m2/repository/org/apache/servicemix/bundles/org.apache.servicemix.bundles.josql/1.5_5/org.apache.servicemix.bundles.josql-1.5_5.jar:/var/lib/jenkins/.m2/repository/org/apache/activemq/activemq-web/5.7.0/activemq-web-5.7.0.jar:/var/lib/jenkins/.m2/repository/org/apache/activemq/activemq-camel/5.7.0/activemq-camel-5.7.0.jar:/var/lib/jenkins/.m2/repository/org/apache/camel/camel-jms/2.10.1/camel-jms-2.10.1.jar:/var/lib/jenkins/.m2/repository/org/apache/camel/camel-core/2.10.1/camel-core-2.10.1.jar:/var/lib/jenkins/.m2/repository/org/apache/camel/camel-spring/2.10.1/camel-spring-2.10.1.jar:/var/lib/jenkins/.m2/repository/org/apache/activemq/activemq-pool/5.7.0/activemq-pool-5.7.0.jar:/var/lib/jenkins/.m2/repository/org/apache/geronimo/specs/geronimo-jta_1.0.1B_spec/1.0.1/geronimo-jta_1.0.1B_spec-1.0.1.jar:/var/lib/jenkins/.m2/repository/org/eclipse/jetty/jetty-continuation/7.6.7.v20120910/jetty-continuation-7.6.7.v20120910.jar:/var/lib/jenkins/.m2/repository/rome/rome/1.0/rome-1.0.jar:/var/lib/jenkins/.m2/repository/jdom/jdom/1.0/jdom-1.0.jar:/var/lib/jenkins/.m2/repository/org/apache/activemq/apollo-util/1.5/apollo-util-1.5.jar:/var/lib/jenkins/.m2/repository/org/apache/xbean/xbean-spring/3.6/xbean-spring-3.6.jar:/var/lib/jenkins/.m2/repository/org/apache/cxf/cxf-rt-frontend-jaxrs/2.6.2/cxf-rt-frontend-jaxrs-2.6.2.jar:/var/lib/jenkins/.m2/repository/org/apache/cxf/cxf-api/2.6.2/cxf-api-2.6.2.jar:/var/lib/jenkins/.m2/repository/org/apache/ws/xmlschema/xmlschema-core/2.0.3/xmlschema-core-2.0.3.jar:/var/lib/jenkins/.m2/repository/wsdl4j/wsdl4j/1.6.2/wsdl4j-1.6.2.jar:/var/lib/jenkins/.m2/repository/org/apache/cxf/cxf-rt-core/2.6.2/cxf-rt-core-2.6.2.jar:/var/lib/jenkins/.m2/repository/com/sun/xml/bind/jaxb-impl/2.2.5/jaxb-impl-2.2.5.jar:/var/lib/jenkins/.m2/repository/javax/ws/rs/jsr311-api/1.1.1/jsr311-api-1.1.1.jar:/var/lib/jenkins/.m2/repository/org/apache/cxf/cxf-rt-bindings-xml/2.6.2/cxf-rt-bindings-xml-2.6.2.jar:/var/lib/jenkins/.m2/repository/org/apache/cxf/cxf-rt-transports-http/2.6.2/cxf-rt-transports-http-2.6.2.jar:/var/lib/jenkins/.m2/repository/org/apache/cxf/cxf-rt-transports-http-jetty/2.6.2/cxf-rt-transports-http-jetty-2.6.2.jar:/var/lib/jenkins/.m2/repository/org/eclipse/jetty/jetty-server/7.3.0.v20110203/jetty-server-7.3.0.v20110203.jar:/var/lib/jenkins/.m2/repository/org/eclipse/jetty/jetty-security/7.5.4.v20111024/jetty-security-7.5.4.v20111024.jar:/var/lib/jenkins/.m2/repository/org/apache/cxf/cxf-rt-transports-local/2.6.2/cxf-rt-transports-local-2.6.2.jar:/var/lib/jenkins/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.2.0/jackson-annotations-2.2.0.jar:/var/lib/jenkins/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.2.0/jackson-core-2.2.0.jar:/var/lib/jenkins/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.2.0/jackson-databind-2.2.0.jar:/var/lib/jenkins/.m2/repository/com/fasterxml/jackson/dataformat/jackson-dataformat-xml/2.2.0/jackson-dataformat-xml-2.2.0.jar:/var/lib/jenkins/.m2/repository/com/fasterxml/jackson/module/jackson-module-jaxb-annotations/2.2.0/jackson-module-jaxb-annotations-2.2.0.jar:/var/lib/jenkins/.m2/repository/com/fasterxml/jackson/jaxrs/jackson-jaxrs-xml-provider/2.2.0/jackson-jaxrs-xml-provider-2.2.0.jar:/var/lib/jenkins/.m2/repository/com/fasterxml/jackson/jaxrs/jackson-jaxrs-base/2.2.0/jackson-jaxrs-base-2.2.0.jar:/var/lib/jenkins/.m2/repository/com/fasterxml/jackson/jaxrs/jackson-jaxrs-json-provider/2.2.0/jackson-jaxrs-json-provider-2.2.0.jar:/var/lib/jenkins/.m2/repository/javax/servlet/javax.servlet-api/3.1-b02/javax.servlet-api-3.1-b02.jar:/var/lib/jenkins/.m2/repository/org/apache/incubator/kafka/kafka/2.9.2-0.8.1/kafka-2.9.2-0.8.1.jar:/var/lib/jenkins/.m2/repository/com/yammer/metrics/metrics-core/2.2.0/metrics-core-2.2.0.jar:/var/lib/jenkins/.m2/repository/org/slf4j/slf4j-api/1.7.5/slf4j-api-1.7.5.jar:/var/lib/jenkins/.m2/repository/com/yammer/metrics/metrics-annotation/2.2.0/metrics-annotation-2.2.0.jar:/var/lib/jenkins/.m2/repository/org/scala-lang/scala-library/2.9.2/scala-library-2.9.2.jar:/var/lib/jenkins/.m2/repository/com/101tec/zkclient/0.3/zkclient-0.3.jar:/var/lib/jenkins/.m2/repository/log4j/log4j/1.2.17/log4j-1.2.17.jar:/var/lib/jenkins/.m2/repository/net/sf/jopt-simple/jopt-simple/3.2/jopt-simple-3.2.jar:/var/lib/jenkins/.m2/repository/org/xerial/snappy/snappy-java/1.0.5/snappy-java-1.0.5.jar:/var/lib/jenkins/.m2/repository/org/apache/bookkeeper/hedwig-protocol/4.1.0-SNAPSHOT/hedwig-protocol-4.1.0-SNAPSHOT.jar:/var/lib/jenkins/.m2/repository/com/google/protobuf/protobuf-java/2.3.0/protobuf-java-2.3.0.jar:/var/lib/jenkins/.m2/repository/org/apache/bookkeeper/hedwig-client/4.1.0-SNAPSHOT/hedwig-client-4.1.0-SNAPSHOT.jar:/var/lib/jenkins/.m2/repository/org/jboss/netty/netty/3.2.4.Final/netty-3.2.4.Final.jar:/var/lib/jenkins/.m2/repository/commons-configuration/commons-configuration/1.9/commons-configuration-1.9.jar:/var/lib/jenkins/.m2/repository/commons-logging/commons-logging/1.1.1/commons-logging-1.1.1.jar:/var/lib/jenkins/.m2/repository/org/apache/bookkeeper/bookkeeper-server/4.1.0-SNAPSHOT/bookkeeper-server-4.1.0-SNAPSHOT.jar:/var/lib/jenkins/.m2/repository/commons-cli/commons-cli/1.2/commons-cli-1.2.jar:/var/lib/jenkins/.m2/repository/org/apache/bookkeeper/hedwig-client-jms/4.1.0-SNAPSHOT/hedwig-client-jms-4.1.0-SNAPSHOT.jar:/var/lib/jenkins/.m2/repository/javax/jms/jms/1.1/jms-1.1.jar:/var/lib/jenkins/.m2/repository/com/google/guava/guava/15.0/guava-15.0.jar:/var/lib/jenkins/.m2/repository/xalan/xalan/2.7.1/xalan-2.7.1.jar:/var/lib/jenkins/.m2/repository/xalan/serializer/2.7.1/serializer-2.7.1.jar:/var/lib/jenkins/.m2/repository/org/apache/bookkeeper/hedwig-server/4.1.0-SNAPSHOT/hedwig-server-4.1.0-SNAPSHOT.jar:/var/lib/jenkins/.m2/repository/junit/junit/4.8.1/junit-4.8.1.jar:/var/lib/jenkins/.m2/repository/org/slf4j/slf4j-log4j12/1.7.5/slf4j-log4j12-1.7.5.jar:/var/lib/jenkins/.m2/repository/org/apache/derby/derby/10.4.2.0/derby-10.4.2.0.jar:/var/lib/jenkins/.m2/repository/org/apache/zookeeper/zookeeper/3.4.5/zookeeper-3.4.5.jar:/var/lib/jenkins/.m2/repository/org/apache/zookeeper/zookeeper/3.4.0/zookeeper-3.4.0-tests.jar:/var/lib/jenkins/.m2/repository/jline/jline/0.9.94/jline-0.9.94.jar:/var/lib/jenkins/.m2/repository/org/fusesource/mqtt-client/mqtt-client/1.4/mqtt-client-1.4.jar:/var/lib/jenkins/.m2/repository/org/fusesource/hawtdispatch/hawtdispatch-transport/1.12/hawtdispatch-transport-1.12.jar:/var/lib/jenkins/.m2/repository/org/fusesource/hawtdispatch/hawtdispatch/1.12/hawtdispatch-1.12.jar:/var/lib/jenkins/.m2/repository/org/fusesource/hawtbuf/hawtbuf/1.9/hawtbuf-1.9.jar:/var/lib/jenkins/.m2/repository/org/mapdb/mapdb/0.9.11/mapdb-0.9.11.jar:/var/lib/jenkins/.m2/repository/org/igniterealtime/smack/smack/3.2.1/smack-3.2.1.jar:/var/lib/jenkins/.m2/repository/org/igniterealtime/smack/smackx/3.2.1/smackx-3.2.1.jar:/var/lib/jenkins/.m2/repository/org/apache/activemq/activemq-xmpp/5.6.0/activemq-xmpp-5.6.0.jar:/var/lib/jenkins/.m2/repository/org/apache/activemq/activemq-core/5.7.0/activemq-core-5.7.0.jar:/var/lib/jenkins/.m2/repository/org/apache/activemq/kahadb/5.7.0/kahadb-5.7.0.jar:/var/lib/jenkins/.m2/repository/org/apache/activemq/protobuf/activemq-protobuf/1.1/activemq-protobuf-1.1.jar:/var/lib/jenkins/.m2/repository/org/apache/geronimo/specs/geronimo-j2ee-management_1.1_spec/1.0.1/geronimo-j2ee-management_1.1_spec-1.0.1.jar:/var/lib/jenkins/.m2/repository/commons-net/commons-net/3.1/commons-net-3.1.jar:/var/lib/jenkins/.m2/repository/org/jasypt/jasypt/1.9.0/jasypt-1.9.0.jar:/var/lib/jenkins/.m2/repository/org/apache/activemq/activeio-core/3.1.4/activeio-core-3.1.4.jar:/var/lib/jenkins/.m2/repository/org/codehaus/woodstox/woodstox-core-asl/4.1.3/woodstox-core-asl-4.1.3.jar:/var/lib/jenkins/.m2/repository/javax/xml/stream/stax-api/1.0-2/stax-api-1.0-2.jar:/var/lib/jenkins/.m2/repository/org/codehaus/woodstox/stax2-api/3.0.2/stax2-api-3.0.2.jar:/var/lib/jenkins/.m2/repository/org/apache/geronimo/specs/geronimo-activation_1.1_spec/1.0.2/geronimo-activation_1.1_spec-1.0.2.jar:/var/lib/jenkins/.m2/repository/org/testng/testng/6.8/testng-6.8.jar:/var/lib/jenkins/.m2/repository/org/beanshell/bsh/2.0b4/bsh-2.0b4.jar:/var/lib/jenkins/.m2/repository/com/beust/jcommander/1.27/jcommander-1.27.jar:/var/lib/jenkins/.m2/repository/org/yaml/snakeyaml/1.6/snakeyaml-1.6.jar:
05:29:35,060 [ main] INFO  ZooKeeper - Client environment:java.library.path=/usr/lib/jvm/java-1.7.0-openjdk-1.7.0.51.x86_64/jre/lib/amd64/server:/usr/lib/jvm/java-1.7.0-openjdk-1.7.0.51.x86_64/jre/lib/amd64:/usr/lib/jvm/java-1.7.0-openjdk-1.7.0.51.x86_64/jre/../lib/amd64:/usr/lib/jvm/java-1.6.0-openjdk-1.6.0.0.x86_64/jre/lib/amd64/server:/usr/lib/jvm/java-1.6.0-openjdk-1.6.0.0.x86_64/jre/lib/amd64:/usr/lib/jvm/java-1.6.0-openjdk-1.6.0.0.x86_64/jre/../lib/amd64:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
05:29:35,060 [ main] INFO  ZooKeeper - Client environment:java.io.tmpdir=/tmp
05:29:35,060 [ main] INFO  ZooKeeper - Client environment:java.compiler=<NA>
05:29:35,060 [ main] INFO  ZooKeeper - Client environment:os.name=Linux
05:29:35,060 [ main] INFO  ZooKeeper - Client environment:os.arch=amd64
05:29:35,060 [ main] INFO  ZooKeeper - Client environment:os.version=2.6.18-308.11.1.el5
05:29:35,061 [ main] INFO  ZooKeeper - Client environment:user.name=jenkins
05:29:35,061 [ main] INFO  ZooKeeper - Client environment:user.home=/var/lib/jenkins
05:29:35,061 [ main] INFO  ZooKeeper - Client environment:user.dir=/var/lib/jenkins/jobs/sysnature.integration/workspace/aa.sysnature.messaging
05:29:35,061 [ main] INFO  ZooKeeper - Initiating client connection, connectString=gk sessionTimeout=3000 watcher=org.I0Itec.zkclient.ZkClient@180510a0
05:29:35,068 [ main] DEBUG ClientCnxn - zookeeper.disableAutoWatchReset is false
05:29:35,084 [ main] DEBUG ZkClient - Awaiting connection to Zookeeper server
05:29:35,084 [ main] DEBUG ZkClient - Waiting for keeper state SyncConnected
05:29:35,087 [2181)] INFO  ClientCnxn - Opening socket connection to server gk/145.76.94.98:2181. Will not attempt to authenticate using SASL (unknown error)
05:29:35,092 [2181)] INFO  ClientCnxn - Socket connection established to gk/145.76.94.98:2181, initiating session
05:29:35,093 [2181)] DEBUG ClientCnxn - Session establishment request sent on gk/145.76.94.98:2181
05:29:35,162 [2181)] INFO  ClientCnxn - Session establishment complete on server gk/145.76.94.98:2181, sessionid = 0x14591c791710008, negotiated timeout = 4000
05:29:35,165 [hread] DEBUG ZkClient - Received event: WatchedEvent state:SyncConnected type:None path:null
05:29:35,166 [hread] INFO  ZkClient - zookeeper state changed (SyncConnected)
05:29:35,166 [hread] DEBUG ZkClient - Leaving process event
05:29:35,166 [ main] DEBUG ZkClient - State is SyncConnected
05:29:35,524 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710008, packet:: clientPath:null serverPath:null finished:false header:: 1,8  replyHeader:: 1,25769803825,0  request:: '/brokers/ids,F  response:: v{'0} 
05:29:35,582 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710008, packet:: clientPath:null serverPath:null finished:false header:: 2,3  replyHeader:: 2,25769803825,-101  request:: '/brokers/topics/KafkaMessagingTest1398310175026,F  response::  
05:29:35,688 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710008, packet:: clientPath:null serverPath:null finished:false header:: 3,5  replyHeader:: 3,25769803826,-101  request:: '/config/topics/KafkaMessagingTest1398310175026,#7b2276657273696f6e223a312c22636f6e666967223a7b7d7d,-1  response::  
05:29:35,725 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710008, packet:: clientPath:null serverPath:null finished:false header:: 4,1  replyHeader:: 4,25769803827,-110  request:: '/config/topics,,v{s{31,s{'world,'anyone}}},0  response::  
05:29:35,747 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710008, packet:: clientPath:null serverPath:null finished:false header:: 5,1  replyHeader:: 5,25769803828,0  request:: '/config/topics/KafkaMessagingTest1398310175026,#7b2276657273696f6e223a312c22636f6e666967223a7b7d7d,v{s{31,s{'world,'anyone}}},0  response:: '/config/topics/KafkaMessagingTest1398310175026 
05:29:35,752 [ main] INFO  AdminUtils$ - Topic creation {"version":1,"partitions":{"0":[0]}}
05:29:35,772 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710008, packet:: clientPath:null serverPath:null finished:false header:: 6,1  replyHeader:: 6,25769803829,0  request:: '/brokers/topics/KafkaMessagingTest1398310175026,#7b2276657273696f6e223a312c22706172746974696f6e73223a7b2230223a5b305d7d7d,v{s{31,s{'world,'anyone}}},0  response:: '/brokers/topics/KafkaMessagingTest1398310175026 
05:29:35,774 [ main] DEBUG AdminUtils$ - Updated path /brokers/topics/KafkaMessagingTest1398310175026 with {"version":1,"partitions":{"0":[0]}} for replica assignment
Created topic "KafkaMessagingTest1398310175026".05:29:35,786 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710008, packet:: clientPath:null serverPath:null finished:false header:: 7,8  replyHeader:: 7,25769803829,0  request:: '/brokers/ids,F  response:: v{'0} 
05:29:35,793 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710008, packet:: clientPath:null serverPath:null finished:false header:: 8,4  replyHeader:: 8,25769803829,0  request:: '/brokers/ids/0,F  response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938333130313534353631222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398310154575,1398310154575,0,0,0,91639653755584517,79,0,25769803806} 
05:29:35,928 [ main] INFO  VerifiableProperties - Verifying properties
05:29:35,930 [ main] INFO  VerifiableProperties - Property auto.commit.enable is overridden to false
05:29:35,930 [ main] INFO  VerifiableProperties - Property auto.offset.reset is overridden to smallest
05:29:35,930 [ main] INFO  VerifiableProperties - Property group.id is overridden to Q
05:29:35,930 [ main] INFO  VerifiableProperties - Property zookeeper.connect is overridden to gk
05:29:35,944 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Connecting to zookeeper instance at gk
05:29:35,944 [ead-2] DEBUG ZkConnection - Creating new ZookKeeper instance to connect to gk.
05:29:35,944 [28-gk] INFO  ZkEventThread - Starting ZkClient event thread.
05:29:35,944 [ead-2] INFO  ZooKeeper - Initiating client connection, connectString=gk sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@61b52c64
05:29:35,945 [ead-2] DEBUG ZkClient - Awaiting connection to Zookeeper server
05:29:35,945 [ead-2] DEBUG ZkClient - Waiting for keeper state SyncConnected
05:29:35,945 [2181)] INFO  ClientCnxn - Opening socket connection to server gk/145.76.94.98:2181. Will not attempt to authenticate using SASL (unknown error)
05:29:35,946 [2181)] INFO  ClientCnxn - Socket connection established to gk/145.76.94.98:2181, initiating session
05:29:35,946 [2181)] DEBUG ClientCnxn - Session establishment request sent on gk/145.76.94.98:2181
05:29:35,966 [2181)] INFO  ClientCnxn - Session establishment complete on server gk/145.76.94.98:2181, sessionid = 0x14591c791710009, negotiated timeout = 6000
05:29:35,967 [hread] DEBUG ZkClient - Received event: WatchedEvent state:SyncConnected type:None path:null
05:29:35,967 [hread] INFO  ZkClient - zookeeper state changed (SyncConnected)
05:29:35,967 [hread] DEBUG ZkClient - Leaving process event
05:29:35,967 [ead-2] DEBUG ZkClient - State is SyncConnected
05:29:36,027 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], entering consume 
05:29:36,050 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], begin registering consumer Q_dev-1398310175943-63c52397 in ZK
05:29:36,071 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 1,1  replyHeader:: 1,25769803836,-101  request:: '/consumers/Q/ids/Q_dev-1398310175943-63c52397,#7b2276657273696f6e223a312c22737562736372697074696f6e223a7b224b61666b614d6573736167696e675465737431333938333130313735303236223a317d2c227061747465726e223a22737461746963222c2274696d657374616d70223a2231333938333130313736303530227d,v{s{31,s{'world,'anyone}}},1  response::  
05:29:36,092 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 2,1  replyHeader:: 2,25769803837,-101  request:: '/consumers/Q/ids,,v{s{31,s{'world,'anyone}}},0  response::  
05:29:36,114 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 3,1  replyHeader:: 3,25769803838,0  request:: '/consumers/Q,,v{s{31,s{'world,'anyone}}},0  response:: '/consumers/Q 
05:29:36,134 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 4,1  replyHeader:: 4,25769803839,0  request:: '/consumers/Q/ids,,v{s{31,s{'world,'anyone}}},0  response:: '/consumers/Q/ids 
05:29:36,156 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 5,1  replyHeader:: 5,25769803840,0  request:: '/consumers/Q/ids/Q_dev-1398310175943-63c52397,#7b2276657273696f6e223a312c22737562736372697074696f6e223a7b224b61666b614d6573736167696e675465737431333938333130313735303236223a317d2c227061747465726e223a22737461746963222c2274696d657374616d70223a2231333938333130313736303530227d,v{s{31,s{'world,'anyone}}},1  response:: '/consumers/Q/ids/Q_dev-1398310175943-63c52397 
05:29:36,156 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], end registering consumer Q_dev-1398310175943-63c52397 in ZK
05:29:36,159 [cutor] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], starting watcher executor thread for consumer Q_dev-1398310175943-63c52397
05:29:36,175 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Adding topicThreadId (KafkaMessagingTest1398310175026,Q_dev-1398310175943-63c52397-0) and queue [] to topicThreadIdAndQueues data structure
05:29:36,179 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], adding topic KafkaMessagingTest1398310175026 and 1 streams to map.
05:29:36,181 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 6,3  replyHeader:: 6,25769803840,0  request:: '/consumers/Q/ids,T  response:: s{25769803839,25769803839,1398310291713,1398310291713,0,1,0,0,0,1,25769803840} 
05:29:36,182 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 7,8  replyHeader:: 7,25769803840,0  request:: '/consumers/Q/ids,T  response:: v{'Q_dev-1398310175943-63c52397} 
05:29:36,185 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 8,3  replyHeader:: 8,25769803840,0  request:: '/brokers/topics/KafkaMessagingTest1398310175026,T  response:: s{25769803829,25769803829,1398310291351,1398310291351,0,1,0,0,36,1,25769803832} 
05:29:36,185 [ead-2] DEBUG ZkClient - Subscribed data changes for /brokers/topics/KafkaMessagingTest1398310175026
05:29:36,186 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], begin rebalancing consumer Q_dev-1398310175943-63c52397 try #0
05:29:36,188 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 9,8  replyHeader:: 9,25769803840,0  request:: '/brokers/ids,F  response:: v{'0} 
05:29:36,190 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 10,4  replyHeader:: 10,25769803840,0  request:: '/brokers/ids/0,F  response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938333130313534353631222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398310154575,1398310154575,0,0,0,91639653755584517,79,0,25769803806} 
05:29:36,211 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 11,4  replyHeader:: 11,25769803840,0  request:: '/consumers/Q/ids/Q_dev-1398310175943-63c52397,F  response:: #7b2276657273696f6e223a312c22737562736372697074696f6e223a7b224b61666b614d6573736167696e675465737431333938333130313735303236223a317d2c227061747465726e223a22737461746963222c2274696d657374616d70223a2231333938333130313736303530227d,s{25769803840,25769803840,1398310291733,1398310291733,0,0,0,91639653755584521,113,0,25769803840} 
05:29:36,234 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 12,8  replyHeader:: 12,25769803840,0  request:: '/consumers/Q/ids,T  response:: v{'Q_dev-1398310175943-63c52397} 
05:29:36,237 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 13,4  replyHeader:: 13,25769803840,0  request:: '/consumers/Q/ids/Q_dev-1398310175943-63c52397,F  response:: #7b2276657273696f6e223a312c22737562736372697074696f6e223a7b224b61666b614d6573736167696e675465737431333938333130313735303236223a317d2c227061747465726e223a22737461746963222c2274696d657374616d70223a2231333938333130313736303530227d,s{25769803840,25769803840,1398310291733,1398310291733,0,0,0,91639653755584521,113,0,25769803840} 
05:29:36,260 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 14,8  replyHeader:: 14,25769803840,0  request:: '/brokers/ids,F  response:: v{'0} 
05:29:36,262 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 15,4  replyHeader:: 15,25769803840,0  request:: '/brokers/ids/0,F  response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938333130313534353631222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398310154575,1398310154575,0,0,0,91639653755584517,79,0,25769803806} 
05:29:36,282 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 16,4  replyHeader:: 16,25769803840,0  request:: '/brokers/topics/KafkaMessagingTest1398310175026,T  response:: #7b2276657273696f6e223a312c22706172746974696f6e73223a7b2230223a5b305d7d7d,s{25769803829,25769803829,1398310291351,1398310291351,0,1,0,0,36,1,25769803832} 
05:29:36,294 [ead-2] DEBUG ZkUtils$ - Partition map for /brokers/topics/KafkaMessagingTest1398310175026 is Map(0 -> List(0))
05:29:36,300 [ead-2] INFO  ConsumerFetcherManager - [ConsumerFetcherManager-1398310175975] Stopping leader finder thread
05:29:36,301 [ead-2] INFO  ConsumerFetcherManager - [ConsumerFetcherManager-1398310175975] Stopping all fetchers
05:29:36,302 [ead-2] INFO  ConsumerFetcherManager - [ConsumerFetcherManager-1398310175975] All connections stopped
05:29:36,303 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Cleared all relevant queues for this fetcher
05:29:36,304 [ead-2] DEBUG ConsumerIterator - Clearing the current data chunk for this consumer iterator
05:29:36,305 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Cleared the data chunks in all the consumer message iterators
05:29:36,305 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Committing all offsets after clearing the fetcher queues
05:29:36,306 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Releasing partition ownership
05:29:36,309 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Consumer Q_dev-1398310175943-63c52397 rebalancing the following partitions: ArrayBuffer(0) for topic KafkaMessagingTest1398310175026 with consumers: List(Q_dev-1398310175943-63c52397-0)
05:29:36,311 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Q_dev-1398310175943-63c52397-0 attempting to claim partition 0
05:29:36,313 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 17,4  replyHeader:: 17,25769803840,-101  request:: '/consumers/Q/offsets/KafkaMessagingTest1398310175026/0,F  response::  
05:29:36,315 [ead-2] DEBUG PartitionTopicInfo - initial consumer offset of KafkaMessagingTest1398310175026:0: fetched offset = -1: consumed offset = -1 is -1
05:29:36,315 [ead-2] DEBUG PartitionTopicInfo - initial fetch offset of KafkaMessagingTest1398310175026:0: fetched offset = -1: consumed offset = -1 is -1
05:29:36,316 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], KafkaMessagingTest1398310175026:0: fetched offset = -1: consumed offset = -1 selected new offset -1
05:29:36,367 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 18,1  replyHeader:: 18,25769803841,-101  request:: '/consumers/Q/owners/KafkaMessagingTest1398310175026/0,#515f6465762d313339383331303137353934332d36336335323339372d30,v{s{31,s{'world,'anyone}}},1  response::  
05:29:36,383 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 19,1  replyHeader:: 19,25769803842,-101  request:: '/consumers/Q/owners/KafkaMessagingTest1398310175026,,v{s{31,s{'world,'anyone}}},0  response::  
05:29:36,404 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 20,1  replyHeader:: 20,25769803843,0  request:: '/consumers/Q/owners,,v{s{31,s{'world,'anyone}}},0  response:: '/consumers/Q/owners 
05:29:36,425 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 21,1  replyHeader:: 21,25769803844,0  request:: '/consumers/Q/owners/KafkaMessagingTest1398310175026,,v{s{31,s{'world,'anyone}}},0  response:: '/consumers/Q/owners/KafkaMessagingTest1398310175026 
05:29:36,446 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 22,1  replyHeader:: 22,25769803845,0  request:: '/consumers/Q/owners/KafkaMessagingTest1398310175026/0,#515f6465762d313339383331303137353934332d36336335323339372d30,v{s{31,s{'world,'anyone}}},1  response:: '/consumers/Q/owners/KafkaMessagingTest1398310175026/0 
05:29:36,447 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Q_dev-1398310175943-63c52397-0 successfully owned partition 0 for topic KafkaMessagingTest1398310175026
05:29:36,448 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Updating the cache
05:29:36,449 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Partitions per topic cache Map(KafkaMessagingTest1398310175026 -> ArrayBuffer(0))
05:29:36,449 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Consumers per topic cache Map(KafkaMessagingTest1398310175026 -> List(Q_dev-1398310175943-63c52397-0))
05:29:36,452 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Consumer Q_dev-1398310175943-63c52397 selected partitions : KafkaMessagingTest1398310175026:0: fetched offset = -1: consumed offset = -1
05:29:36,455 [hread] INFO  ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398310175943-63c52397-leader-finder-thread], Starting 
05:29:36,457 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], end rebalancing consumer Q_dev-1398310175943-63c52397 try #0
05:29:36,458 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 23,8  replyHeader:: 23,25769803845,0  request:: '/brokers/ids,F  response:: v{'0} 
05:29:36,460 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 24,4  replyHeader:: 24,25769803845,0  request:: '/brokers/ids/0,F  response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938333130313534353631222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398310154575,1398310154575,0,0,0,91639653755584517,79,0,25769803806} 
05:29:36,469 [ main] INFO  VerifiableProperties - Verifying properties
05:29:36,469 [ main] INFO  VerifiableProperties - Property compression.codec is overridden to none
05:29:36,469 [ main] INFO  VerifiableProperties - Property metadata.broker.list is overridden to gk:9092
05:29:36,469 [ main] INFO  VerifiableProperties - Property producer.type is overridden to sync
05:29:36,470 [ main] INFO  VerifiableProperties - Property request.required.acks is overridden to 1
05:29:36,470 [ main] INFO  VerifiableProperties - Property serializer.class is overridden to com.sysnature.messaging.kafka.SerializerEncoder
05:29:36,473 [hread] INFO  VerifiableProperties - Verifying properties
05:29:36,474 [hread] INFO  VerifiableProperties - Property client.id is overridden to Q
05:29:36,474 [hread] INFO  VerifiableProperties - Property metadata.broker.list is overridden to gk:9092
05:29:36,474 [hread] INFO  VerifiableProperties - Property request.timeout.ms is overridden to 30000
05:29:36,485 [ main] DEBUG KafkaPublisher - send message to [KafkaMessagingTest1398310175026]: create
05:29:36,498 [hread] INFO  ClientUtils$ - Fetching metadata from broker id:0,host:gk,port:9092 with correlation id 0 for 1 topic(s) Set(KafkaMessagingTest1398310175026)
05:29:36,503 [hread] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 30000 (requested 30000), SO_RCVBUF = 43690 (requested -1), SO_SNDBUF = 102400 (requested 102400).
05:29:36,504 [hread] INFO  SyncProducer - Connected to gk:9092 for producing
05:29:36,518 [ main] DEBUG DefaultEventHandler - Handling 1 events
05:29:36,520 [ main] INFO  ClientUtils$ - Fetching metadata from broker id:0,host:gk,port:9092 with correlation id 0 for 1 topic(s) Set(KafkaMessagingTest1398310175026)
05:29:36,521 [ main] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 10000 (requested 10000), SO_RCVBUF = 43690 (requested -1), SO_SNDBUF = 102400 (requested 102400).
05:29:36,521 [ main] INFO  SyncProducer - Connected to gk:9092 for producing
05:29:36,547 [ main] INFO  SyncProducer - Disconnecting from gk:9092
05:29:36,547 [hread] INFO  SyncProducer - Disconnecting from gk:9092
05:29:36,550 [hread] DEBUG ClientUtils$ - Successfully fetched metadata for 1 topic(s) Set(KafkaMessagingTest1398310175026)
05:29:36,550 [ main] DEBUG ClientUtils$ - Successfully fetched metadata for 1 topic(s) Set(KafkaMessagingTest1398310175026)
05:29:36,562 [hread] DEBUG ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398310175943-63c52397-leader-finder-thread], {TopicMetadata for topic KafkaMessagingTest1398310175026 -> 
Metadata for partition [KafkaMessagingTest1398310175026,0] is 	partition 0	leader: 0 (gk:9092)	replicas: 0 (gk:9092)	isr: 0 (gk:9092)	isUnderReplicated: false}
05:29:36,563 [ main] DEBUG BrokerPartitionInfo - Getting broker partition info for topic KafkaMessagingTest1398310175026
05:29:36,564 [ main] DEBUG BrokerPartitionInfo - Partition [KafkaMessagingTest1398310175026,0] has leader 0
05:29:36,566 [ main] DEBUG DefaultEventHandler - Broker partitions registered for topic: KafkaMessagingTest1398310175026 are 0
05:29:36,572 [ main] DEBUG DefaultEventHandler - Sending 1 messages with no compression to [KafkaMessagingTest1398310175026,0]
05:29:36,576 [7-0-0] INFO  ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398310175943-63c52397-0-0], Starting 
05:29:36,579 [hread] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 30000 (requested 30000), SO_RCVBUF = 65536 (requested 65536), SO_SNDBUF = 8192 (requested -1).
05:29:36,580 [ main] DEBUG DefaultEventHandler - Producer sending messages with correlation id 2 for topics [KafkaMessagingTest1398310175026,0] to broker 0 on gk:9092
05:29:36,587 [ main] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 10000 (requested 10000), SO_RCVBUF = 43690 (requested -1), SO_SNDBUF = 102400 (requested 102400).
05:29:36,587 [ main] INFO  SyncProducer - Connected to gk:9092 for producing
05:29:36,614 [hread] DEBUG PartitionTopicInfo - reset fetch offset of ( KafkaMessagingTest1398310175026:0: fetched offset = 0: consumed offset = -1 ) to 0
05:29:36,615 [hread] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398310175026:0: fetched offset = 0: consumed offset = 0 to 0
05:29:36,616 [hread] INFO  ConsumerFetcherManager - [ConsumerFetcherManager-1398310175975] Added fetcher for partitions ArrayBuffer([[KafkaMessagingTest1398310175026,0], initOffset -1 to broker id:0,host:gk,port:9092] )
05:29:36,626 [ main] DEBUG DefaultEventHandler - Producer sent messages with correlation id 2 for topics [KafkaMessagingTest1398310175026,0] to broker 0 on gk:9092
05:29:36,629 [ main] DEBUG KafkaPublisher - sent message to [KafkaMessagingTest1398310175026]: create
05:29:36,675 [7-0-0] DEBUG PartitionTopicInfo - updated fetch offset of (KafkaMessagingTest1398310175026:0: fetched offset = 1: consumed offset = 0) to 1
05:29:36,676 [026-0] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398310175026:0: fetched offset = 1: consumed offset = 1 to 1
05:29:36,679 [026-0] DEBUG KafkaSubscriber - received in [KafkaMessagingTest1398310175026]: create
05:29:36,679 [ main] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], ZKConsumerConnector shutting down
05:29:36,679 [ main] INFO  ConsumerFetcherManager - [ConsumerFetcherManager-1398310175975] Stopping leader finder thread
05:29:36,680 [ main] INFO  ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398310175943-63c52397-leader-finder-thread], Shutting down
05:29:36,681 [ main] INFO  ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398310175943-63c52397-leader-finder-thread], Shutdown completed
05:29:36,681 [ main] INFO  ConsumerFetcherManager - [ConsumerFetcherManager-1398310175975] Stopping all fetchers
05:29:36,681 [ main] INFO  ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398310175943-63c52397-0-0], Shutting down
05:29:36,681 [hread] INFO  ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398310175943-63c52397-leader-finder-thread], Stopped 
05:29:36,783 [7-0-0] WARN  SimpleConsumer - Reconnect due to socket error: null
05:29:36,784 [7-0-0] DEBUG SimpleConsumer - Disconnecting from gk:9092
05:29:36,784 [7-0-0] INFO  ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398310175943-63c52397-0-0], Stopped 
05:29:36,784 [ main] INFO  ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398310175943-63c52397-0-0], Shutdown completed
05:29:36,784 [ main] INFO  ConsumerFetcherManager - [ConsumerFetcherManager-1398310175975] All connections stopped
05:29:36,785 [ main] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Clearing up queue
05:29:36,786 [ main] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Cleared queue and sent shutdown command
05:29:36,786 [ main] DEBUG ZkClient - Closing ZkClient...
05:29:36,786 [28-gk] INFO  ZkEventThread - Terminate ZkClient event thread.
05:29:36,786 [ main] DEBUG ZkConnection - Closing ZooKeeper connected to gk
05:29:36,786 [ main] DEBUG ZooKeeper - Closing session: 0x14591c791710009
05:29:36,786 [ main] DEBUG ClientCnxn - Closing client for session: 0x14591c791710009
05:29:36,849 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 25,5  replyHeader:: 25,25769803846,-101  request:: '/consumers/Q/offsets/KafkaMessagingTest1398310175026/0,#31,-1  response::  
05:29:36,850 [026-0] DEBUG ZkClient - Waiting for keeper state SyncConnected
05:29:36,858 [2181)] DEBUG ClientCnxn - Got notification sessionid:0x14591c791710009
05:29:36,859 [2181)] DEBUG ClientCnxn - Got WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/consumers/Q/ids for sessionid 0x14591c791710009
05:29:36,860 [hread] DEBUG ZkClient - Received event: WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/consumers/Q/ids
05:29:36,860 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710009, packet:: clientPath:null serverPath:null finished:false header:: 26,-11  replyHeader:: 26,25769803847,0  request:: null response:: null
05:29:36,860 [ main] DEBUG ClientCnxn - Disconnecting client for session: 0x14591c791710009
05:29:36,860 [ main] INFO  ZooKeeper - Session: 0x14591c791710009 closed
05:29:36,860 [2181)] DEBUG ClientCnxn - An exception was thrown while closing send thread for session 0x14591c791710009 : Unable to read additional data from server sessionid 0x14591c791710009, likely server has closed socket
05:29:36,860 [026-0] DEBUG ZkClient - State is SyncConnected
05:29:36,860 [ main] DEBUG ZkClient - Closing ZkClient...done
05:29:36,861 [ main] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], ZKConsumerConnector shut down completed
05:29:36,862 [hread] DEBUG ZkClient - ignoring event '{NodeChildrenChanged | /consumers/Q/ids}' since shutdown triggered
05:29:36,862 [hread] DEBUG ZkClient - Leaving process event
05:29:36,862 [hread] INFO  ClientCnxn - EventThread shut down
05:29:36,862 [ main] INFO  Producer - Shutting down producer
05:29:36,862 [026-0] WARN  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], exception during commitOffsets
java.lang.NullPointerException
	at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
	at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
	at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
	at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
	at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
	at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
	at kafka.utils.ZkUtils$.updatePersistentPath(ZkUtils.scala:360)
	at kafka.consumer.ZookeeperConsumerConnector$$anonfun$commitOffsets$3$$anonfun$apply$5.apply(ZookeeperConsumerConnector.scala:263)
	at kafka.consumer.ZookeeperConsumerConnector$$anonfun$commitOffsets$3$$anonfun$apply$5.apply(ZookeeperConsumerConnector.scala:259)
	at scala.collection.Iterator$class.foreach(Iterator.scala:772)
	at scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:573)
	at scala.collection.IterableLike$class.foreach(IterableLike.scala:73)
	at scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:615)
	at kafka.consumer.ZookeeperConsumerConnector$$anonfun$commitOffsets$3.apply(ZookeeperConsumerConnector.scala:259)
	at kafka.consumer.ZookeeperConsumerConnector$$anonfun$commitOffsets$3.apply(ZookeeperConsumerConnector.scala:257)
	at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:59)
	at scala.collection.immutable.List.foreach(List.scala:76)
	at kafka.consumer.ZookeeperConsumerConnector.commitOffsets(ZookeeperConsumerConnector.scala:257)
	at kafka.javaapi.consumer.ZookeeperConsumerConnector.commitOffsets(ZookeeperConsumerConnector.scala:106)
	at com.sysnature.messaging.kafka.KafkaSubscriber$1.operationFinished(KafkaSubscriber.java:133)
	at com.sysnature.messaging.support.SubscriberToDequeuerAdapter$1.onMessage(SubscriberToDequeuerAdapter.java:64)
	at com.sysnature.messaging.kafka.KafkaSubscriber$Receiver$1.run(KafkaSubscriber.java:109)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:744)
05:29:36,863 [ main] INFO  ProducerPool - Closing all sync producers
05:29:36,865 [026-0] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], Committed offset 1 for topic KafkaMessagingTest1398310175026:0: fetched offset = 1: consumed offset = 1
05:29:36,865 [026-0] DEBUG KafkaSubscriber - commit
05:29:36,867 [ main] INFO  SyncProducer - Disconnecting from gk:9092
05:29:36,867 [ main] DEBUG ZkClient - Closing ZkClient...
05:29:36,867 [23-gk] INFO  ZkEventThread - Terminate ZkClient event thread.
05:29:36,868 [ main] DEBUG ZkConnection - Closing ZooKeeper connected to gk
05:29:36,868 [ main] DEBUG ZooKeeper - Closing session: 0x14591c791710008
05:29:36,868 [ main] DEBUG ClientCnxn - Closing client for session: 0x14591c791710008
05:29:36,887 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c791710008, packet:: clientPath:null serverPath:null finished:false header:: 9,-11  replyHeader:: 9,25769803848,0  request:: null response:: null
05:29:36,888 [ main] DEBUG ClientCnxn - Disconnecting client for session: 0x14591c791710008
05:29:36,888 [ main] INFO  ZooKeeper - Session: 0x14591c791710008 closed
05:29:36,888 [ main] DEBUG ZkClient - Closing ZkClient...done
05:29:36,888 [hread] INFO  ClientCnxn - EventThread shut down
05:29:36,888 [ main] DEBUG ZkConnection - Creating new ZookKeeper instance to connect to gk.
05:29:36,888 [38-gk] INFO  ZkEventThread - Starting ZkClient event thread.
05:29:36,888 [ main] INFO  ZooKeeper - Initiating client connection, connectString=gk sessionTimeout=3000 watcher=org.I0Itec.zkclient.ZkClient@28aa0527
05:29:36,889 [ main] DEBUG ZkClient - Awaiting connection to Zookeeper server
05:29:36,889 [ main] DEBUG ZkClient - Waiting for keeper state SyncConnected
05:29:36,889 [2181)] INFO  ClientCnxn - Opening socket connection to server gk/145.76.94.98:2181. Will not attempt to authenticate using SASL (unknown error)
05:29:36,890 [2181)] INFO  ClientCnxn - Socket connection established to gk/145.76.94.98:2181, initiating session
05:29:36,890 [2181)] DEBUG ClientCnxn - Session establishment request sent on gk/145.76.94.98:2181
05:29:36,908 [2181)] INFO  ClientCnxn - Session establishment complete on server gk/145.76.94.98:2181, sessionid = 0x14591c79171000a, negotiated timeout = 4000
05:29:36,908 [hread] DEBUG ZkClient - Received event: WatchedEvent state:SyncConnected type:None path:null
05:29:36,909 [hread] INFO  ZkClient - zookeeper state changed (SyncConnected)
05:29:36,909 [hread] DEBUG ZkClient - Leaving process event
05:29:36,909 [ main] DEBUG ZkClient - State is SyncConnected
05:29:36,910 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000a, packet:: clientPath:null serverPath:null finished:false header:: 1,8  replyHeader:: 1,25769803849,0  request:: '/brokers/ids,F  response:: v{'0} 
05:29:36,911 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000a, packet:: clientPath:null serverPath:null finished:false header:: 2,4  replyHeader:: 2,25769803849,0  request:: '/brokers/ids/0,F  response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938333130313534353631222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398310154575,1398310154575,0,0,0,91639653755584517,79,0,25769803806} 
05:29:36,918 [ main] DEBUG ZkClient - Closing ZkClient...
05:29:36,919 [38-gk] INFO  ZkEventThread - Terminate ZkClient event thread.
05:29:36,919 [ main] DEBUG ZkConnection - Closing ZooKeeper connected to gk
05:29:36,919 [ main] DEBUG ZooKeeper - Closing session: 0x14591c79171000a
05:29:36,919 [ main] DEBUG ClientCnxn - Closing client for session: 0x14591c79171000a
05:29:36,937 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000a, packet:: clientPath:null serverPath:null finished:false header:: 3,-11  replyHeader:: 3,25769803850,0  request:: null response:: null
05:29:36,938 [ main] DEBUG ClientCnxn - Disconnecting client for session: 0x14591c79171000a
05:29:36,938 [ main] INFO  ZooKeeper - Session: 0x14591c79171000a closed
05:29:36,938 [ main] DEBUG ZkClient - Closing ZkClient...done
05:29:36,938 [hread] INFO  ClientCnxn - EventThread shut down
05:29:36,939 [ main] INFO  VerifiableProperties - Verifying properties
05:29:36,939 [ main] INFO  VerifiableProperties - Property batch.num.messages is overridden to 2
05:29:36,939 [ main] INFO  VerifiableProperties - Property compression.codec is overridden to none
05:29:36,939 [ main] INFO  VerifiableProperties - Property metadata.broker.list is overridden to gk:9092
05:29:36,939 [ main] INFO  VerifiableProperties - Property producer.type is overridden to async
05:29:36,940 [ main] WARN  VerifiableProperties - Property queue.buffer.max.ms is not valid
05:29:36,940 [ main] INFO  VerifiableProperties - Property request.required.acks is overridden to 1
05:29:36,940 [ main] INFO  VerifiableProperties - Property serializer.class is overridden to com.sysnature.messaging.kafka.SerializerEncoder
05:29:36,945 [ main] DEBUG KafkaPublisher - sent message to [KafkaMessagingTest1398310175026]: 1
05:29:36,945 [ main] DEBUG KafkaPublisher - sent message to [KafkaMessagingTest1398310175026]: 2
05:29:36,945 [ main] INFO  VerifiableProperties - Verifying properties
05:29:36,945 [ main] INFO  VerifiableProperties - Property auto.commit.enable is overridden to false
05:29:36,946 [ main] INFO  VerifiableProperties - Property auto.offset.reset is overridden to smallest
05:29:36,946 [ main] INFO  VerifiableProperties - Property group.id is overridden to Q
05:29:36,946 [ main] INFO  VerifiableProperties - Property zookeeper.connect is overridden to gk
05:29:36,947 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Connecting to zookeeper instance at gk
05:29:36,947 [ead-2] DEBUG ZkConnection - Creating new ZookKeeper instance to connect to gk.
05:29:36,947 [ead-2] INFO  ZooKeeper - Initiating client connection, connectString=gk sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@4e048dc6
05:29:36,947 [44-gk] INFO  ZkEventThread - Starting ZkClient event thread.
05:29:36,948 [2181)] INFO  ClientCnxn - Opening socket connection to server gk/145.76.94.98:2181. Will not attempt to authenticate using SASL (unknown error)
05:29:36,949 [read-] DEBUG ProducerSendThread - Batch full. Sending..
05:29:36,948 [ead-2] DEBUG ZkClient - Awaiting connection to Zookeeper server
05:29:36,949 [ead-2] DEBUG ZkClient - Waiting for keeper state SyncConnected
05:29:36,949 [read-] DEBUG ProducerSendThread - Handling 2 events
05:29:36,949 [2181)] INFO  ClientCnxn - Socket connection established to gk/145.76.94.98:2181, initiating session
05:29:36,949 [2181)] DEBUG ClientCnxn - Session establishment request sent on gk/145.76.94.98:2181
05:29:36,950 [read-] DEBUG DefaultEventHandler - Handling 2 events
05:29:36,950 [read-] INFO  ClientUtils$ - Fetching metadata from broker id:0,host:gk,port:9092 with correlation id 0 for 1 topic(s) Set(KafkaMessagingTest1398310175026)
05:29:36,951 [read-] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 10000 (requested 10000), SO_RCVBUF = 43690 (requested -1), SO_SNDBUF = 102400 (requested 102400).
05:29:36,951 [read-] INFO  SyncProducer - Connected to gk:9092 for producing
05:29:36,953 [read-] INFO  SyncProducer - Disconnecting from gk:9092
05:29:36,953 [read-] DEBUG ClientUtils$ - Successfully fetched metadata for 1 topic(s) Set(KafkaMessagingTest1398310175026)
05:29:36,953 [read-] DEBUG BrokerPartitionInfo - Getting broker partition info for topic KafkaMessagingTest1398310175026
05:29:36,954 [read-] DEBUG BrokerPartitionInfo - Partition [KafkaMessagingTest1398310175026,0] has leader 0
05:29:36,954 [read-] DEBUG DefaultEventHandler - Broker partitions registered for topic: KafkaMessagingTest1398310175026 are 0
05:29:36,954 [read-] DEBUG BrokerPartitionInfo - Getting broker partition info for topic KafkaMessagingTest1398310175026
05:29:36,954 [read-] DEBUG BrokerPartitionInfo - Partition [KafkaMessagingTest1398310175026,0] has leader 0
05:29:36,954 [read-] DEBUG DefaultEventHandler - Broker partitions registered for topic: KafkaMessagingTest1398310175026 are 0
05:29:36,955 [read-] DEBUG DefaultEventHandler - Sending 2 messages with no compression to [KafkaMessagingTest1398310175026,0]
05:29:36,955 [read-] DEBUG DefaultEventHandler - Producer sending messages with correlation id 3 for topics [KafkaMessagingTest1398310175026,0] to broker 0 on gk:9092
05:29:36,956 [read-] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 10000 (requested 10000), SO_RCVBUF = 43690 (requested -1), SO_SNDBUF = 102400 (requested 102400).
05:29:36,956 [read-] INFO  SyncProducer - Connected to gk:9092 for producing
05:29:36,959 [read-] DEBUG DefaultEventHandler - Producer sent messages with correlation id 3 for topics [KafkaMessagingTest1398310175026,0] to broker 0 on gk:9092
05:29:36,966 [2181)] INFO  ClientCnxn - Session establishment complete on server gk/145.76.94.98:2181, sessionid = 0x14591c79171000b, negotiated timeout = 6000
05:29:36,967 [hread] DEBUG ZkClient - Received event: WatchedEvent state:SyncConnected type:None path:null
05:29:36,967 [hread] INFO  ZkClient - zookeeper state changed (SyncConnected)
05:29:36,967 [hread] DEBUG ZkClient - Leaving process event
05:29:36,967 [ead-2] DEBUG ZkClient - State is SyncConnected
05:29:36,967 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], entering consume 
05:29:36,967 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], begin registering consumer Q_dev-1398310176947-aedbead6 in ZK
05:29:36,988 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 1,1  replyHeader:: 1,25769803852,0  request:: '/consumers/Q/ids/Q_dev-1398310176947-aedbead6,#7b2276657273696f6e223a312c22737562736372697074696f6e223a7b224b61666b614d6573736167696e675465737431333938333130313735303236223a317d2c227061747465726e223a22737461746963222c2274696d657374616d70223a2231333938333130313736393637227d,v{s{31,s{'world,'anyone}}},1  response:: '/consumers/Q/ids/Q_dev-1398310176947-aedbead6 
05:29:36,988 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], end registering consumer Q_dev-1398310176947-aedbead6 in ZK
05:29:36,988 [cutor] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], starting watcher executor thread for consumer Q_dev-1398310176947-aedbead6
05:29:36,989 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Adding topicThreadId (KafkaMessagingTest1398310175026,Q_dev-1398310176947-aedbead6-0) and queue [] to topicThreadIdAndQueues data structure
05:29:36,989 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], adding topic KafkaMessagingTest1398310175026 and 1 streams to map.
05:29:36,991 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 2,3  replyHeader:: 2,25769803852,0  request:: '/consumers/Q/ids,T  response:: s{25769803839,25769803839,1398310291713,1398310291713,0,3,0,0,0,1,25769803852} 
05:29:36,992 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 3,8  replyHeader:: 3,25769803852,0  request:: '/consumers/Q/ids,T  response:: v{'Q_dev-1398310176947-aedbead6} 
05:29:36,993 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 4,3  replyHeader:: 4,25769803852,0  request:: '/brokers/topics/KafkaMessagingTest1398310175026,T  response:: s{25769803829,25769803829,1398310291351,1398310291351,0,1,0,0,36,1,25769803832} 
05:29:36,993 [ead-2] DEBUG ZkClient - Subscribed data changes for /brokers/topics/KafkaMessagingTest1398310175026
05:29:36,993 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], begin rebalancing consumer Q_dev-1398310176947-aedbead6 try #0
05:29:36,994 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 5,8  replyHeader:: 5,25769803852,0  request:: '/brokers/ids,F  response:: v{'0} 
05:29:36,996 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 6,4  replyHeader:: 6,25769803852,0  request:: '/brokers/ids/0,F  response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938333130313534353631222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398310154575,1398310154575,0,0,0,91639653755584517,79,0,25769803806} 
05:29:37,004 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 7,4  replyHeader:: 7,25769803852,0  request:: '/consumers/Q/ids/Q_dev-1398310176947-aedbead6,F  response:: #7b2276657273696f6e223a312c22737562736372697074696f6e223a7b224b61666b614d6573736167696e675465737431333938333130313735303236223a317d2c227061747465726e223a22737461746963222c2274696d657374616d70223a2231333938333130313736393637227d,s{25769803852,25769803852,1398310292567,1398310292567,0,0,0,91639653755584523,113,0,25769803852} 
05:29:37,012 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 8,8  replyHeader:: 8,25769803852,0  request:: '/consumers/Q/ids,T  response:: v{'Q_dev-1398310176947-aedbead6} 
05:29:37,014 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 9,4  replyHeader:: 9,25769803852,0  request:: '/consumers/Q/ids/Q_dev-1398310176947-aedbead6,F  response:: #7b2276657273696f6e223a312c22737562736372697074696f6e223a7b224b61666b614d6573736167696e675465737431333938333130313735303236223a317d2c227061747465726e223a22737461746963222c2274696d657374616d70223a2231333938333130313736393637227d,s{25769803852,25769803852,1398310292567,1398310292567,0,0,0,91639653755584523,113,0,25769803852} 
05:29:37,023 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 10,8  replyHeader:: 10,25769803852,0  request:: '/brokers/ids,F  response:: v{'0} 
05:29:37,024 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 11,4  replyHeader:: 11,25769803852,0  request:: '/brokers/ids/0,F  response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938333130313534353631222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398310154575,1398310154575,0,0,0,91639653755584517,79,0,25769803806} 
05:29:37,031 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 12,4  replyHeader:: 12,25769803852,0  request:: '/brokers/topics/KafkaMessagingTest1398310175026,T  response:: #7b2276657273696f6e223a312c22706172746974696f6e73223a7b2230223a5b305d7d7d,s{25769803829,25769803829,1398310291351,1398310291351,0,1,0,0,36,1,25769803832} 
05:29:37,035 [ead-2] DEBUG ZkUtils$ - Partition map for /brokers/topics/KafkaMessagingTest1398310175026 is Map(0 -> List(0))
05:29:37,036 [ead-2] INFO  ConsumerFetcherManager - [ConsumerFetcherManager-1398310176967] Stopping leader finder thread
05:29:37,036 [ead-2] INFO  ConsumerFetcherManager - [ConsumerFetcherManager-1398310176967] Stopping all fetchers
05:29:37,036 [ead-2] INFO  ConsumerFetcherManager - [ConsumerFetcherManager-1398310176967] All connections stopped
05:29:37,036 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Cleared all relevant queues for this fetcher
05:29:37,036 [ead-2] DEBUG ConsumerIterator - Clearing the current data chunk for this consumer iterator
05:29:37,036 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Cleared the data chunks in all the consumer message iterators
05:29:37,036 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Committing all offsets after clearing the fetcher queues
05:29:37,036 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Releasing partition ownership
05:29:37,036 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Consumer Q_dev-1398310176947-aedbead6 rebalancing the following partitions: ArrayBuffer(0) for topic KafkaMessagingTest1398310175026 with consumers: List(Q_dev-1398310176947-aedbead6-0)
05:29:37,036 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Q_dev-1398310176947-aedbead6-0 attempting to claim partition 0
05:29:37,037 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 13,4  replyHeader:: 13,25769803852,-101  request:: '/consumers/Q/offsets/KafkaMessagingTest1398310175026/0,F  response::  
05:29:37,038 [ead-2] DEBUG PartitionTopicInfo - initial consumer offset of KafkaMessagingTest1398310175026:0: fetched offset = -1: consumed offset = -1 is -1
05:29:37,038 [ead-2] DEBUG PartitionTopicInfo - initial fetch offset of KafkaMessagingTest1398310175026:0: fetched offset = -1: consumed offset = -1 is -1
05:29:37,038 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], KafkaMessagingTest1398310175026:0: fetched offset = -1: consumed offset = -1 selected new offset -1
05:29:37,059 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 14,1  replyHeader:: 14,25769803853,0  request:: '/consumers/Q/owners/KafkaMessagingTest1398310175026/0,#515f6465762d313339383331303137363934372d61656462656164362d30,v{s{31,s{'world,'anyone}}},1  response:: '/consumers/Q/owners/KafkaMessagingTest1398310175026/0 
05:29:37,059 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Q_dev-1398310176947-aedbead6-0 successfully owned partition 0 for topic KafkaMessagingTest1398310175026
05:29:37,059 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Updating the cache
05:29:37,059 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Partitions per topic cache Map(KafkaMessagingTest1398310175026 -> ArrayBuffer(0))
05:29:37,059 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Consumers per topic cache Map(KafkaMessagingTest1398310175026 -> List(Q_dev-1398310176947-aedbead6-0))
05:29:37,059 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Consumer Q_dev-1398310176947-aedbead6 selected partitions : KafkaMessagingTest1398310175026:0: fetched offset = -1: consumed offset = -1
05:29:37,060 [ead-2] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], end rebalancing consumer Q_dev-1398310176947-aedbead6 try #0
05:29:37,060 [hread] INFO  ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398310176947-aedbead6-leader-finder-thread], Starting 
05:29:37,060 [ main] DEBUG KafkaPublisher - sent message to [KafkaMessagingTest1398310175026]: 1222
05:29:37,060 [ main] DEBUG KafkaPublisher - sent message to [KafkaMessagingTest1398310175026]: 23.45
05:29:37,061 [read-] DEBUG ProducerSendThread - Batch full. Sending..
05:29:37,061 [read-] DEBUG ProducerSendThread - Handling 2 events
05:29:37,061 [read-] DEBUG DefaultEventHandler - Handling 2 events
05:29:37,061 [read-] DEBUG BrokerPartitionInfo - Getting broker partition info for topic KafkaMessagingTest1398310175026
05:29:37,061 [read-] DEBUG BrokerPartitionInfo - Partition [KafkaMessagingTest1398310175026,0] has leader 0
05:29:37,062 [read-] DEBUG DefaultEventHandler - Broker partitions registered for topic: KafkaMessagingTest1398310175026 are 0
05:29:37,062 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 15,8  replyHeader:: 15,25769803853,0  request:: '/brokers/ids,F  response:: v{'0} 
05:29:37,062 [read-] DEBUG BrokerPartitionInfo - Getting broker partition info for topic KafkaMessagingTest1398310175026
05:29:37,062 [read-] DEBUG BrokerPartitionInfo - Partition [KafkaMessagingTest1398310175026,0] has leader 0
05:29:37,062 [read-] DEBUG DefaultEventHandler - Broker partitions registered for topic: KafkaMessagingTest1398310175026 are 0
05:29:37,063 [read-] DEBUG DefaultEventHandler - Sending 2 messages with no compression to [KafkaMessagingTest1398310175026,0]
05:29:37,063 [read-] DEBUG DefaultEventHandler - Producer sending messages with correlation id 6 for topics [KafkaMessagingTest1398310175026,0] to broker 0 on gk:9092
05:29:37,064 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 16,4  replyHeader:: 16,25769803853,0  request:: '/brokers/ids/0,F  response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938333130313534353631222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398310154575,1398310154575,0,0,0,91639653755584517,79,0,25769803806} 
05:29:37,066 [read-] DEBUG DefaultEventHandler - Producer sent messages with correlation id 6 for topics [KafkaMessagingTest1398310175026,0] to broker 0 on gk:9092
05:29:37,071 [hread] INFO  VerifiableProperties - Verifying properties
05:29:37,071 [hread] INFO  VerifiableProperties - Property client.id is overridden to Q
05:29:37,071 [hread] INFO  VerifiableProperties - Property metadata.broker.list is overridden to gk:9092
05:29:37,071 [hread] INFO  VerifiableProperties - Property request.timeout.ms is overridden to 30000
05:29:37,072 [hread] INFO  ClientUtils$ - Fetching metadata from broker id:0,host:gk,port:9092 with correlation id 0 for 1 topic(s) Set(KafkaMessagingTest1398310175026)
05:29:37,073 [hread] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 30000 (requested 30000), SO_RCVBUF = 43690 (requested -1), SO_SNDBUF = 102400 (requested 102400).
05:29:37,073 [hread] INFO  SyncProducer - Connected to gk:9092 for producing
05:29:37,075 [hread] INFO  SyncProducer - Disconnecting from gk:9092
05:29:37,076 [hread] DEBUG ClientUtils$ - Successfully fetched metadata for 1 topic(s) Set(KafkaMessagingTest1398310175026)
05:29:37,076 [hread] DEBUG ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398310176947-aedbead6-leader-finder-thread], {TopicMetadata for topic KafkaMessagingTest1398310175026 -> 
Metadata for partition [KafkaMessagingTest1398310175026,0] is 	partition 0	leader: 0 (gk:9092)	replicas: 0 (gk:9092)	isr: 0 (gk:9092)	isUnderReplicated: false}
05:29:37,080 [6-0-0] INFO  ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398310176947-aedbead6-0-0], Starting 
05:29:37,080 [hread] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 30000 (requested 30000), SO_RCVBUF = 65536 (requested 65536), SO_SNDBUF = 8192 (requested -1).
05:29:37,083 [hread] DEBUG PartitionTopicInfo - reset fetch offset of ( KafkaMessagingTest1398310175026:0: fetched offset = 0: consumed offset = -1 ) to 0
05:29:37,083 [hread] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398310175026:0: fetched offset = 0: consumed offset = 0 to 0
05:29:37,083 [hread] INFO  ConsumerFetcherManager - [ConsumerFetcherManager-1398310176967] Added fetcher for partitions ArrayBuffer([[KafkaMessagingTest1398310175026,0], initOffset -1 to broker id:0,host:gk,port:9092] )
05:29:37,087 [026-0] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398310175026:0: fetched offset = 5: consumed offset = 1 to 1
05:29:37,087 [6-0-0] DEBUG PartitionTopicInfo - updated fetch offset of (KafkaMessagingTest1398310175026:0: fetched offset = 5: consumed offset = 1) to 5
05:29:37,087 [026-0] DEBUG KafkaSubscriber - received in [KafkaMessagingTest1398310175026]: create
05:29:37,108 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 17,5  replyHeader:: 17,25769803854,-101  request:: '/consumers/Q/offsets/KafkaMessagingTest1398310175026/0,#31,-1  response::  
05:29:37,129 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 18,1  replyHeader:: 18,25769803855,-101  request:: '/consumers/Q/offsets/KafkaMessagingTest1398310175026,,v{s{31,s{'world,'anyone}}},0  response::  
05:29:37,151 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 19,1  replyHeader:: 19,25769803856,0  request:: '/consumers/Q/offsets,,v{s{31,s{'world,'anyone}}},0  response:: '/consumers/Q/offsets 
05:29:37,163 [cutor] INFO  ZookeeperConsumerConnector - [Q_dev-1398310175943-63c52397], stopping watcher executor thread for consumer Q_dev-1398310175943-63c52397
05:29:37,171 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 20,1  replyHeader:: 20,25769803857,0  request:: '/consumers/Q/offsets/KafkaMessagingTest1398310175026,,v{s{31,s{'world,'anyone}}},0  response:: '/consumers/Q/offsets/KafkaMessagingTest1398310175026 
05:29:37,189 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 21,1  replyHeader:: 21,25769803858,0  request:: '/consumers/Q/offsets/KafkaMessagingTest1398310175026/0,#31,v{s{31,s{'world,'anyone}}},0  response:: '/consumers/Q/offsets/KafkaMessagingTest1398310175026/0 
05:29:37,189 [026-0] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Committed offset 1 for topic KafkaMessagingTest1398310175026:0: fetched offset = 5: consumed offset = 1
05:29:37,189 [026-0] DEBUG KafkaSubscriber - commit
05:29:37,189 [026-0] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398310175026:0: fetched offset = 5: consumed offset = 2 to 2
05:29:37,189 [026-0] DEBUG KafkaSubscriber - received in [KafkaMessagingTest1398310175026]: 1
05:29:37,209 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 22,5  replyHeader:: 22,25769803859,0  request:: '/consumers/Q/offsets/KafkaMessagingTest1398310175026/0,#32,-1  response:: s{25769803858,25769803859,1398310292771,1398310292788,1,0,0,0,1,0,25769803858} 
05:29:37,209 [026-0] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Committed offset 2 for topic KafkaMessagingTest1398310175026:0: fetched offset = 5: consumed offset = 2
05:29:37,209 [026-0] DEBUG KafkaSubscriber - commit
05:29:37,209 [026-0] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398310175026:0: fetched offset = 5: consumed offset = 3 to 3
05:29:37,209 [026-0] DEBUG KafkaSubscriber - received in [KafkaMessagingTest1398310175026]: 2
05:29:37,230 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 23,5  replyHeader:: 23,25769803860,0  request:: '/consumers/Q/offsets/KafkaMessagingTest1398310175026/0,#33,-1  response:: s{25769803858,25769803860,1398310292771,1398310292808,2,0,0,0,1,0,25769803858} 
05:29:37,230 [026-0] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Committed offset 3 for topic KafkaMessagingTest1398310175026:0: fetched offset = 5: consumed offset = 3
05:29:37,230 [026-0] DEBUG KafkaSubscriber - commit
05:29:37,230 [026-0] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398310175026:0: fetched offset = 5: consumed offset = 4 to 4
05:29:37,230 [026-0] DEBUG KafkaSubscriber - received in [KafkaMessagingTest1398310175026]: 1222
StopWatch '': running time (millis) = 170; [send & receive 2 messages] took 170 = 100%05:29:37,231 [ main] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], ZKConsumerConnector shutting down
05:29:37,231 [ main] INFO  ConsumerFetcherManager - [ConsumerFetcherManager-1398310176967] Stopping leader finder thread
05:29:37,231 [ main] INFO  ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398310176947-aedbead6-leader-finder-thread], Shutting down
05:29:37,231 [hread] INFO  ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398310176947-aedbead6-leader-finder-thread], Stopped 
05:29:37,231 [ main] INFO  ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398310176947-aedbead6-leader-finder-thread], Shutdown completed
05:29:37,231 [ main] INFO  ConsumerFetcherManager - [ConsumerFetcherManager-1398310176967] Stopping all fetchers
05:29:37,231 [ main] INFO  ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398310176947-aedbead6-0-0], Shutting down
05:29:37,250 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 24,5  replyHeader:: 24,25769803861,0  request:: '/consumers/Q/offsets/KafkaMessagingTest1398310175026/0,#34,-1  response:: s{25769803858,25769803861,1398310292771,1398310292830,3,0,0,0,1,0,25769803858} 
05:29:37,250 [026-0] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Committed offset 4 for topic KafkaMessagingTest1398310175026:0: fetched offset = 5: consumed offset = 4
05:29:37,250 [026-0] DEBUG KafkaSubscriber - commit
05:29:37,250 [026-0] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398310175026:0: fetched offset = 5: consumed offset = 5 to 5
05:29:37,250 [026-0] DEBUG KafkaSubscriber - received in [KafkaMessagingTest1398310175026]: 23.45
05:29:37,271 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 25,5  replyHeader:: 25,25769803862,0  request:: '/consumers/Q/offsets/KafkaMessagingTest1398310175026/0,#35,-1  response:: s{25769803858,25769803862,1398310292771,1398310292850,4,0,0,0,1,0,25769803858} 
05:29:37,271 [026-0] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Committed offset 5 for topic KafkaMessagingTest1398310175026:0: fetched offset = 5: consumed offset = 5
05:29:37,271 [026-0] DEBUG KafkaSubscriber - commit
05:29:37,292 [6-0-0] WARN  SimpleConsumer - Reconnect due to socket error: null
05:29:37,292 [6-0-0] DEBUG SimpleConsumer - Disconnecting from gk:9092
05:29:37,292 [6-0-0] INFO  ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398310176947-aedbead6-0-0], Stopped 
05:29:37,292 [ main] INFO  ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398310176947-aedbead6-0-0], Shutdown completed
05:29:37,292 [ main] INFO  ConsumerFetcherManager - [ConsumerFetcherManager-1398310176967] All connections stopped
05:29:37,292 [ main] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Clearing up queue
05:29:37,292 [ main] DEBUG ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], Cleared queue and sent shutdown command
05:29:37,293 [ main] DEBUG ZkClient - Closing ZkClient...
05:29:37,293 [44-gk] INFO  ZkEventThread - Terminate ZkClient event thread.
05:29:37,293 [ main] DEBUG ZkConnection - Closing ZooKeeper connected to gk
05:29:37,293 [ main] DEBUG ZooKeeper - Closing session: 0x14591c79171000b
05:29:37,293 [ main] DEBUG ClientCnxn - Closing client for session: 0x14591c79171000b
05:29:37,293 [026-0] DEBUG ConsumerIterator - Received the shutdown command
05:29:37,312 [2181)] DEBUG ClientCnxn - Got notification sessionid:0x14591c79171000b
05:29:37,312 [2181)] DEBUG ClientCnxn - Got WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/consumers/Q/ids for sessionid 0x14591c79171000b
05:29:37,312 [hread] DEBUG ZkClient - Received event: WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/consumers/Q/ids
05:29:37,313 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000b, packet:: clientPath:null serverPath:null finished:false header:: 26,-11  replyHeader:: 26,25769803863,0  request:: null response:: null
05:29:37,313 [ main] DEBUG ClientCnxn - Disconnecting client for session: 0x14591c79171000b
05:29:37,313 [ main] INFO  ZooKeeper - Session: 0x14591c79171000b closed
05:29:37,313 [ main] DEBUG ZkClient - Closing ZkClient...done
05:29:37,313 [hread] DEBUG ZkClient - ignoring event '{NodeChildrenChanged | /consumers/Q/ids}' since shutdown triggered
05:29:37,313 [ main] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], ZKConsumerConnector shut down completed
05:29:37,313 [hread] DEBUG ZkClient - Leaving process event
05:29:37,313 [ main] INFO  Producer - Shutting down producer
05:29:37,313 [hread] INFO  ClientCnxn - EventThread shut down
05:29:37,314 [ main] INFO  ProducerSendThread - Begin shutting down ProducerSendThread
05:29:37,314 [read-] DEBUG ProducerSendThread - Handling 0 events
05:29:37,314 [ main] INFO  ProducerSendThread - Shutdown ProducerSendThread complete
05:29:37,314 [ main] INFO  ProducerPool - Closing all sync producers
05:29:37,315 [ main] INFO  SyncProducer - Disconnecting from gk:9092
05:29:37,315 [ main] DEBUG KafkaMessagingTest - deleting: KafkaMessagingTest1398310175026
05:29:37,316 [ main] DEBUG ZkConnection - Creating new ZookKeeper instance to connect to gk.
05:29:37,316 [51-gk] INFO  ZkEventThread - Starting ZkClient event thread.
05:29:37,316 [ main] INFO  ZooKeeper - Initiating client connection, connectString=gk sessionTimeout=3000 watcher=org.I0Itec.zkclient.ZkClient@7d7cdb46
05:29:37,317 [ main] DEBUG ZkClient - Awaiting connection to Zookeeper server
05:29:37,317 [ main] DEBUG ZkClient - Waiting for keeper state SyncConnected
05:29:37,317 [2181)] INFO  ClientCnxn - Opening socket connection to server gk/145.76.94.98:2181. Will not attempt to authenticate using SASL (unknown error)
05:29:37,318 [2181)] INFO  ClientCnxn - Socket connection established to gk/145.76.94.98:2181, initiating session
05:29:37,318 [2181)] DEBUG ClientCnxn - Session establishment request sent on gk/145.76.94.98:2181
05:29:37,367 [2181)] INFO  ClientCnxn - Session establishment complete on server gk/145.76.94.98:2181, sessionid = 0x14591c79171000c, negotiated timeout = 4000
05:29:37,368 [hread] DEBUG ZkClient - Received event: WatchedEvent state:SyncConnected type:None path:null
05:29:37,368 [hread] INFO  ZkClient - zookeeper state changed (SyncConnected)
05:29:37,368 [hread] DEBUG ZkClient - Leaving process event
05:29:37,368 [ main] DEBUG ZkClient - State is SyncConnected
05:29:37,369 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000c, packet:: clientPath:null serverPath:null finished:false header:: 1,8  replyHeader:: 1,25769803864,0  request:: '/brokers/topics,F  response:: v{'KafkaMessagingTest1398310175026} 
05:29:37,371 [ main] DEBUG Whitelist - KafkaMessagingTest1398310175026 allowed
05:29:37,417 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x14591c79171000c, packet:: clientPath:null serverPath:null finished:false header:: 2,1  replyHeader:: 2,25769803865,0  request:: '/admin/delete_topics/KafkaMessagingTest1398310175026,,v{s{31,s{'world,'anyone}}},0  response:: '/admin/delete_topics/KafkaMessagingTest1398310175026 
Topic "KafkaMessagingTest1398310175026" queued for deletion.05:29:37,991 [cutor] INFO  ZookeeperConsumerConnector - [Q_dev-1398310176947-aedbead6], stopping watcher executor thread for consumer Q_dev-1398310176947-aedbead6
05:29:38,954 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 248ms
05:29:40,041 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 0ms
05:29:41,380 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 7ms
05:29:42,921 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 214ms
05:29:44,055 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 15ms
05:29:45,374 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 1ms
05:29:46,714 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 7ms
05:29:48,040 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 0ms
05:29:49,373 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 0ms
05:29:50,729 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 23ms
05:29:52,039 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 0ms
05:29:53,372 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 0ms
05:29:54,746 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 41ms
05:29:56,038 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 0ms
05:29:57,371 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 0ms
05:29:58,721 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 17ms
05:30:00,037 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 0ms
05:30:01,370 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x14591c79171000c after 0ms