02:05:58,827 [ main] DEBUG KafkaMessagingTest - testing: KafkaMessagingTest1398297958826 02:05:58,841 [ main] DEBUG ZkConnection - Creating new ZookKeeper instance to connect to gk. 02:05:58,842 [23-gk] INFO ZkEventThread - Starting ZkClient event thread. 02:05:58,853 [ main] INFO ZooKeeper - Client environment:zookeeper.version=3.4.5-1392090, built on 09/30/2012 17:52 GMT 02:05:58,853 [ main] INFO ZooKeeper - Client environment:host.name=dev 02:05:58,853 [ main] INFO ZooKeeper - Client environment:java.version=1.7.0_51 02:05:58,853 [ main] INFO ZooKeeper - Client environment:java.vendor=Oracle Corporation 02:05:58,853 [ main] INFO ZooKeeper - Client environment:java.home=/usr/lib/jvm/java-1.7.0-openjdk-1.7.0.51.x86_64/jre 02:05:58,853 [ 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.4/zkclient-0.4.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: 02:05:58,854 [ 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 02:05:58,854 [ main] INFO ZooKeeper - Client environment:java.io.tmpdir=/tmp 02:05:58,854 [ main] INFO ZooKeeper - Client environment:java.compiler= 02:05:58,854 [ main] INFO ZooKeeper - Client environment:os.name=Linux 02:05:58,854 [ main] INFO ZooKeeper - Client environment:os.arch=amd64 02:05:58,854 [ main] INFO ZooKeeper - Client environment:os.version=2.6.18-308.11.1.el5 02:05:58,854 [ main] INFO ZooKeeper - Client environment:user.name=jenkins 02:05:58,854 [ main] INFO ZooKeeper - Client environment:user.home=/var/lib/jenkins 02:05:58,854 [ main] INFO ZooKeeper - Client environment:user.dir=/var/lib/jenkins/jobs/sysnature.integration/workspace/aa.sysnature.messaging 02:05:58,855 [ main] INFO ZooKeeper - Initiating client connection, connectString=gk sessionTimeout=3000 watcher=org.I0Itec.zkclient.ZkClient@180510a0 02:05:58,860 [ main] DEBUG ClientCnxn - zookeeper.disableAutoWatchReset is false 02:05:58,874 [ main] DEBUG ZkClient - Awaiting connection to Zookeeper server 02:05:58,874 [ main] DEBUG ZkClient - Waiting for keeper state SyncConnected 02:05:58,878 [2181)] INFO ClientCnxn - Opening socket connection to server gk/145.76.94.98:2181. Will not attempt to authenticate using SASL (unknown error) 02:05:58,883 [2181)] INFO ClientCnxn - Socket connection established to gk/145.76.94.98:2181, initiating session 02:05:58,885 [2181)] DEBUG ClientCnxn - Session establishment request sent on gk/145.76.94.98:2181 02:05:58,962 [2181)] INFO ClientCnxn - Session establishment complete on server gk/145.76.94.98:2181, sessionid = 0x145910d2da80008, negotiated timeout = 4000 02:05:58,966 [hread] DEBUG ZkClient - Received event: WatchedEvent state:SyncConnected type:None path:null 02:05:58,967 [hread] INFO ZkClient - zookeeper state changed (SyncConnected) 02:05:58,967 [hread] DEBUG ZkClient - Leaving process event 02:05:58,967 [ main] DEBUG ZkClient - State is SyncConnected 02:05:59,329 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80008, packet:: clientPath:null serverPath:null finished:false header:: 1,8 replyHeader:: 1,25769803825,0 request:: '/brokers/ids,F response:: v{'0} 02:05:59,388 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80008, packet:: clientPath:null serverPath:null finished:false header:: 2,3 replyHeader:: 2,25769803825,-101 request:: '/brokers/topics/KafkaMessagingTest1398297958826,F response:: 02:05:59,496 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80008, packet:: clientPath:null serverPath:null finished:false header:: 3,5 replyHeader:: 3,25769803826,-101 request:: '/config/topics/KafkaMessagingTest1398297958826,#7b2276657273696f6e223a312c22636f6e666967223a7b7d7d,-1 response:: 02:05:59,533 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80008, 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:: 02:05:59,558 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80008, packet:: clientPath:null serverPath:null finished:false header:: 5,1 replyHeader:: 5,25769803828,0 request:: '/config/topics/KafkaMessagingTest1398297958826,#7b2276657273696f6e223a312c22636f6e666967223a7b7d7d,v{s{31,s{'world,'anyone}}},0 response:: '/config/topics/KafkaMessagingTest1398297958826 02:05:59,563 [ main] INFO AdminUtils$ - Topic creation {"version":1,"partitions":{"0":[0]}} 02:05:59,592 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80008, packet:: clientPath:null serverPath:null finished:false header:: 6,1 replyHeader:: 6,25769803829,0 request:: '/brokers/topics/KafkaMessagingTest1398297958826,#7b2276657273696f6e223a312c22706172746974696f6e73223a7b2230223a5b305d7d7d,v{s{31,s{'world,'anyone}}},0 response:: '/brokers/topics/KafkaMessagingTest1398297958826 02:05:59,593 [ main] DEBUG AdminUtils$ - Updated path /brokers/topics/KafkaMessagingTest1398297958826 with {"version":1,"partitions":{"0":[0]}} for replica assignment Created topic "KafkaMessagingTest1398297958826".02:05:59,605 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80008, packet:: clientPath:null serverPath:null finished:false header:: 7,8 replyHeader:: 7,25769803829,0 request:: '/brokers/ids,F response:: v{'0} 02:05:59,613 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80008, packet:: clientPath:null serverPath:null finished:false header:: 8,4 replyHeader:: 8,25769803829,0 request:: '/brokers/ids/0,F response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938323937393339303230222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398297939035,1398297939035,0,0,0,91638853217550341,79,0,25769803806} 02:05:59,747 [ main] INFO VerifiableProperties - Verifying properties 02:05:59,748 [ main] INFO VerifiableProperties - Property auto.commit.enable is overridden to false 02:05:59,748 [ main] INFO VerifiableProperties - Property auto.offset.reset is overridden to smallest 02:05:59,748 [ main] INFO VerifiableProperties - Property group.id is overridden to Q 02:05:59,749 [ main] INFO VerifiableProperties - Property zookeeper.connect is overridden to gk 02:05:59,763 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Connecting to zookeeper instance at gk 02:05:59,763 [ead-2] DEBUG ZkConnection - Creating new ZookKeeper instance to connect to gk. 02:05:59,763 [28-gk] INFO ZkEventThread - Starting ZkClient event thread. 02:05:59,764 [ead-2] INFO ZooKeeper - Initiating client connection, connectString=gk sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@6c05762a 02:05:59,764 [ead-2] DEBUG ZkClient - Awaiting connection to Zookeeper server 02:05:59,764 [ead-2] DEBUG ZkClient - Waiting for keeper state SyncConnected 02:05:59,764 [2181)] INFO ClientCnxn - Opening socket connection to server gk/145.76.94.98:2181. Will not attempt to authenticate using SASL (unknown error) 02:05:59,770 [2181)] INFO ClientCnxn - Socket connection established to gk/145.76.94.98:2181, initiating session 02:05:59,770 [2181)] DEBUG ClientCnxn - Session establishment request sent on gk/145.76.94.98:2181 02:05:59,808 [2181)] INFO ClientCnxn - Session establishment complete on server gk/145.76.94.98:2181, sessionid = 0x145910d2da80009, negotiated timeout = 6000 02:05:59,808 [hread] DEBUG ZkClient - Received event: WatchedEvent state:SyncConnected type:None path:null 02:05:59,808 [hread] INFO ZkClient - zookeeper state changed (SyncConnected) 02:05:59,808 [hread] DEBUG ZkClient - Leaving process event 02:05:59,808 [ead-2] DEBUG ZkClient - State is SyncConnected 02:05:59,870 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], entering consume 02:05:59,893 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], begin registering consumer Q_dev-1398297959762-9699d19f in ZK 02:05:59,922 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 1,1 replyHeader:: 1,25769803836,-101 request:: '/consumers/Q/ids/Q_dev-1398297959762-9699d19f,#7b2276657273696f6e223a312c22737562736372697074696f6e223a7b224b61666b614d6573736167696e675465737431333938323937393538383236223a317d2c227061747465726e223a22737461746963222c2274696d657374616d70223a2231333938323937393539383933227d,v{s{31,s{'world,'anyone}}},1 response:: 02:05:59,942 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, 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:: 02:05:59,968 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, 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 02:05:59,992 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, 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 02:06:00,009 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 5,1 replyHeader:: 5,25769803840,0 request:: '/consumers/Q/ids/Q_dev-1398297959762-9699d19f,#7b2276657273696f6e223a312c22737562736372697074696f6e223a7b224b61666b614d6573736167696e675465737431333938323937393538383236223a317d2c227061747465726e223a22737461746963222c2274696d657374616d70223a2231333938323937393539383933227d,v{s{31,s{'world,'anyone}}},1 response:: '/consumers/Q/ids/Q_dev-1398297959762-9699d19f 02:06:00,010 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], end registering consumer Q_dev-1398297959762-9699d19f in ZK 02:06:00,013 [cutor] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], starting watcher executor thread for consumer Q_dev-1398297959762-9699d19f 02:06:00,024 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Adding topicThreadId (KafkaMessagingTest1398297958826,Q_dev-1398297959762-9699d19f-0) and queue [] to topicThreadIdAndQueues data structure 02:06:00,028 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], adding topic KafkaMessagingTest1398297958826 and 1 streams to map. 02:06:00,035 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 6,3 replyHeader:: 6,25769803840,0 request:: '/consumers/Q/ids,T response:: s{25769803839,25769803839,1398298075572,1398298075572,0,1,0,0,0,1,25769803840} 02:06:00,042 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 7,8 replyHeader:: 7,25769803840,0 request:: '/consumers/Q/ids,T response:: v{'Q_dev-1398297959762-9699d19f} 02:06:00,046 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 8,3 replyHeader:: 8,25769803840,0 request:: '/brokers/topics/KafkaMessagingTest1398297958826,T response:: s{25769803829,25769803829,1398298075162,1398298075162,0,1,0,0,36,1,25769803832} 02:06:00,047 [ead-2] DEBUG ZkClient - Subscribed data changes for /brokers/topics/KafkaMessagingTest1398297958826 02:06:00,049 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], begin rebalancing consumer Q_dev-1398297959762-9699d19f try #0 02:06:00,053 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 9,8 replyHeader:: 9,25769803840,0 request:: '/brokers/ids,F response:: v{'0} 02:06:00,059 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 10,4 replyHeader:: 10,25769803840,0 request:: '/brokers/ids/0,F response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938323937393339303230222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398297939035,1398297939035,0,0,0,91638853217550341,79,0,25769803806} 02:06:00,085 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 11,4 replyHeader:: 11,25769803840,0 request:: '/consumers/Q/ids/Q_dev-1398297959762-9699d19f,F response:: #7b2276657273696f6e223a312c22737562736372697074696f6e223a7b224b61666b614d6573736167696e675465737431333938323937393538383236223a317d2c227061747465726e223a22737461746963222c2274696d657374616d70223a2231333938323937393539383933227d,s{25769803840,25769803840,1398298075593,1398298075593,0,0,0,91638853217550345,113,0,25769803840} 02:06:00,112 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 12,8 replyHeader:: 12,25769803840,0 request:: '/consumers/Q/ids,T response:: v{'Q_dev-1398297959762-9699d19f} 02:06:00,119 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 13,4 replyHeader:: 13,25769803840,0 request:: '/consumers/Q/ids/Q_dev-1398297959762-9699d19f,F response:: #7b2276657273696f6e223a312c22737562736372697074696f6e223a7b224b61666b614d6573736167696e675465737431333938323937393538383236223a317d2c227061747465726e223a22737461746963222c2274696d657374616d70223a2231333938323937393539383933227d,s{25769803840,25769803840,1398298075593,1398298075593,0,0,0,91638853217550345,113,0,25769803840} 02:06:00,142 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 14,8 replyHeader:: 14,25769803840,0 request:: '/brokers/ids,F response:: v{'0} 02:06:00,144 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 15,4 replyHeader:: 15,25769803840,0 request:: '/brokers/ids/0,F response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938323937393339303230222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398297939035,1398297939035,0,0,0,91638853217550341,79,0,25769803806} 02:06:00,164 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 16,4 replyHeader:: 16,25769803840,0 request:: '/brokers/topics/KafkaMessagingTest1398297958826,T response:: #7b2276657273696f6e223a312c22706172746974696f6e73223a7b2230223a5b305d7d7d,s{25769803829,25769803829,1398298075162,1398298075162,0,1,0,0,36,1,25769803832} 02:06:00,176 [ead-2] DEBUG ZkUtils$ - Partition map for /brokers/topics/KafkaMessagingTest1398297958826 is Map(0 -> List(0)) 02:06:00,182 [ead-2] INFO ConsumerFetcherManager - [ConsumerFetcherManager-1398297959816] Stopping leader finder thread 02:06:00,183 [ead-2] INFO ConsumerFetcherManager - [ConsumerFetcherManager-1398297959816] Stopping all fetchers 02:06:00,184 [ead-2] INFO ConsumerFetcherManager - [ConsumerFetcherManager-1398297959816] All connections stopped 02:06:00,185 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Cleared all relevant queues for this fetcher 02:06:00,186 [ead-2] DEBUG ConsumerIterator - Clearing the current data chunk for this consumer iterator 02:06:00,187 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Cleared the data chunks in all the consumer message iterators 02:06:00,187 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Committing all offsets after clearing the fetcher queues 02:06:00,188 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Releasing partition ownership 02:06:00,191 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Consumer Q_dev-1398297959762-9699d19f rebalancing the following partitions: ArrayBuffer(0) for topic KafkaMessagingTest1398297958826 with consumers: List(Q_dev-1398297959762-9699d19f-0) 02:06:00,193 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Q_dev-1398297959762-9699d19f-0 attempting to claim partition 0 02:06:00,195 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 17,4 replyHeader:: 17,25769803840,-101 request:: '/consumers/Q/offsets/KafkaMessagingTest1398297958826/0,F response:: 02:06:00,197 [ead-2] DEBUG PartitionTopicInfo - initial consumer offset of KafkaMessagingTest1398297958826:0: fetched offset = -1: consumed offset = -1 is -1 02:06:00,197 [ead-2] DEBUG PartitionTopicInfo - initial fetch offset of KafkaMessagingTest1398297958826:0: fetched offset = -1: consumed offset = -1 is -1 02:06:00,198 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], KafkaMessagingTest1398297958826:0: fetched offset = -1: consumed offset = -1 selected new offset -1 02:06:00,341 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 18,1 replyHeader:: 18,25769803841,-101 request:: '/consumers/Q/owners/KafkaMessagingTest1398297958826/0,#515f6465762d313339383239373935393736322d39363939643139662d30,v{s{31,s{'world,'anyone}}},1 response:: 02:06:00,359 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 19,1 replyHeader:: 19,25769803842,-101 request:: '/consumers/Q/owners/KafkaMessagingTest1398297958826,,v{s{31,s{'world,'anyone}}},0 response:: 02:06:00,383 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, 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 02:06:00,401 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 21,1 replyHeader:: 21,25769803844,0 request:: '/consumers/Q/owners/KafkaMessagingTest1398297958826,,v{s{31,s{'world,'anyone}}},0 response:: '/consumers/Q/owners/KafkaMessagingTest1398297958826 02:06:00,425 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 22,1 replyHeader:: 22,25769803845,0 request:: '/consumers/Q/owners/KafkaMessagingTest1398297958826/0,#515f6465762d313339383239373935393736322d39363939643139662d30,v{s{31,s{'world,'anyone}}},1 response:: '/consumers/Q/owners/KafkaMessagingTest1398297958826/0 02:06:00,425 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Q_dev-1398297959762-9699d19f-0 successfully owned partition 0 for topic KafkaMessagingTest1398297958826 02:06:00,426 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Updating the cache 02:06:00,427 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Partitions per topic cache Map(KafkaMessagingTest1398297958826 -> ArrayBuffer(0)) 02:06:00,428 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Consumers per topic cache Map(KafkaMessagingTest1398297958826 -> List(Q_dev-1398297959762-9699d19f-0)) 02:06:00,430 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Consumer Q_dev-1398297959762-9699d19f selected partitions : KafkaMessagingTest1398297958826:0: fetched offset = -1: consumed offset = -1 02:06:00,433 [hread] INFO ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398297959762-9699d19f-leader-finder-thread], Starting 02:06:00,437 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], end rebalancing consumer Q_dev-1398297959762-9699d19f try #0 02:06:00,438 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 23,8 replyHeader:: 23,25769803845,0 request:: '/brokers/ids,F response:: v{'0} 02:06:00,440 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 24,4 replyHeader:: 24,25769803845,0 request:: '/brokers/ids/0,F response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938323937393339303230222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398297939035,1398297939035,0,0,0,91638853217550341,79,0,25769803806} 02:06:00,450 [ main] INFO VerifiableProperties - Verifying properties 02:06:00,450 [ main] INFO VerifiableProperties - Property compression.codec is overridden to none 02:06:00,450 [ main] INFO VerifiableProperties - Property metadata.broker.list is overridden to gk:9092 02:06:00,450 [ main] INFO VerifiableProperties - Property producer.type is overridden to sync 02:06:00,450 [ main] INFO VerifiableProperties - Property request.required.acks is overridden to 1 02:06:00,450 [ main] INFO VerifiableProperties - Property serializer.class is overridden to com.sysnature.messaging.kafka.SerializerEncoder 02:06:00,454 [hread] INFO VerifiableProperties - Verifying properties 02:06:00,454 [hread] INFO VerifiableProperties - Property client.id is overridden to Q 02:06:00,454 [hread] INFO VerifiableProperties - Property metadata.broker.list is overridden to gk:9092 02:06:00,454 [hread] INFO VerifiableProperties - Property request.timeout.ms is overridden to 30000 02:06:00,466 [ main] DEBUG KafkaPublisher - send message to [KafkaMessagingTest1398297958826]: create 02:06:00,479 [hread] INFO ClientUtils$ - Fetching metadata from broker id:0,host:gk,port:9092 with correlation id 0 for 1 topic(s) Set(KafkaMessagingTest1398297958826) 02:06:00,484 [hread] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 30000 (requested 30000), SO_RCVBUF = 43690 (requested -1), SO_SNDBUF = 102400 (requested 102400). 02:06:00,484 [hread] INFO SyncProducer - Connected to gk:9092 for producing 02:06:00,498 [ main] DEBUG DefaultEventHandler - Handling 1 events 02:06:00,500 [ main] INFO ClientUtils$ - Fetching metadata from broker id:0,host:gk,port:9092 with correlation id 0 for 1 topic(s) Set(KafkaMessagingTest1398297958826) 02:06:00,501 [ main] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 10000 (requested 10000), SO_RCVBUF = 43690 (requested -1), SO_SNDBUF = 102400 (requested 102400). 02:06:00,501 [ main] INFO SyncProducer - Connected to gk:9092 for producing 02:06:00,525 [hread] INFO SyncProducer - Disconnecting from gk:9092 02:06:00,525 [ main] INFO SyncProducer - Disconnecting from gk:9092 02:06:00,527 [ main] DEBUG ClientUtils$ - Successfully fetched metadata for 1 topic(s) Set(KafkaMessagingTest1398297958826) 02:06:00,527 [hread] DEBUG ClientUtils$ - Successfully fetched metadata for 1 topic(s) Set(KafkaMessagingTest1398297958826) 02:06:00,539 [hread] DEBUG ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398297959762-9699d19f-leader-finder-thread], {TopicMetadata for topic KafkaMessagingTest1398297958826 -> Metadata for partition [KafkaMessagingTest1398297958826,0] is partition 0 leader: 0 (gk:9092) replicas: 0 (gk:9092) isr: 0 (gk:9092) isUnderReplicated: false} 02:06:00,541 [ main] DEBUG BrokerPartitionInfo - Getting broker partition info for topic KafkaMessagingTest1398297958826 02:06:00,542 [ main] DEBUG BrokerPartitionInfo - Partition [KafkaMessagingTest1398297958826,0] has leader 0 02:06:00,544 [ main] DEBUG DefaultEventHandler - Broker partitions registered for topic: KafkaMessagingTest1398297958826 are 0 02:06:00,549 [ main] DEBUG DefaultEventHandler - Sending 1 messages with no compression to [KafkaMessagingTest1398297958826,0] 02:06:00,554 [f-0-0] INFO ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398297959762-9699d19f-0-0], Starting 02:06:00,557 [hread] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 30000 (requested 30000), SO_RCVBUF = 65536 (requested 65536), SO_SNDBUF = 8192 (requested -1). 02:06:00,558 [ main] DEBUG DefaultEventHandler - Producer sending messages with correlation id 2 for topics [KafkaMessagingTest1398297958826,0] to broker 0 on gk:9092 02:06:00,564 [ main] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 10000 (requested 10000), SO_RCVBUF = 43690 (requested -1), SO_SNDBUF = 102400 (requested 102400). 02:06:00,564 [ main] INFO SyncProducer - Connected to gk:9092 for producing 02:06:00,591 [hread] DEBUG PartitionTopicInfo - reset fetch offset of ( KafkaMessagingTest1398297958826:0: fetched offset = 0: consumed offset = -1 ) to 0 02:06:00,592 [hread] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398297958826:0: fetched offset = 0: consumed offset = 0 to 0 02:06:00,593 [hread] INFO ConsumerFetcherManager - [ConsumerFetcherManager-1398297959816] Added fetcher for partitions ArrayBuffer([[KafkaMessagingTest1398297958826,0], initOffset -1 to broker id:0,host:gk,port:9092] ) 02:06:00,600 [ main] DEBUG DefaultEventHandler - Producer sent messages with correlation id 2 for topics [KafkaMessagingTest1398297958826,0] to broker 0 on gk:9092 02:06:00,602 [ main] DEBUG KafkaPublisher - sent message to [KafkaMessagingTest1398297958826]: create 02:06:00,640 [f-0-0] DEBUG PartitionTopicInfo - updated fetch offset of (KafkaMessagingTest1398297958826:0: fetched offset = 1: consumed offset = 0) to 1 02:06:00,641 [826-0] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398297958826:0: fetched offset = 1: consumed offset = 1 to 1 02:06:00,643 [826-0] DEBUG KafkaSubscriber - received in [KafkaMessagingTest1398297958826]: create 02:06:00,644 [ main] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], ZKConsumerConnector shutting down 02:06:00,644 [ main] INFO ConsumerFetcherManager - [ConsumerFetcherManager-1398297959816] Stopping leader finder thread 02:06:00,645 [ main] INFO ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398297959762-9699d19f-leader-finder-thread], Shutting down 02:06:00,646 [hread] INFO ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398297959762-9699d19f-leader-finder-thread], Stopped 02:06:00,646 [ main] INFO ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398297959762-9699d19f-leader-finder-thread], Shutdown completed 02:06:00,646 [ main] INFO ConsumerFetcherManager - [ConsumerFetcherManager-1398297959816] Stopping all fetchers 02:06:00,647 [ main] INFO ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398297959762-9699d19f-0-0], Shutting down 02:06:00,748 [f-0-0] WARN SimpleConsumer - Reconnect due to socket error: null 02:06:00,748 [f-0-0] DEBUG SimpleConsumer - Disconnecting from gk:9092 02:06:00,748 [f-0-0] INFO ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398297959762-9699d19f-0-0], Stopped 02:06:00,748 [ main] INFO ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398297959762-9699d19f-0-0], Shutdown completed 02:06:00,748 [ main] INFO ConsumerFetcherManager - [ConsumerFetcherManager-1398297959816] All connections stopped 02:06:00,749 [ main] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Clearing up queue 02:06:00,750 [ main] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Cleared queue and sent shutdown command 02:06:00,750 [ main] DEBUG ZkClient - Closing ZkClient... 02:06:00,750 [28-gk] INFO ZkEventThread - Terminate ZkClient event thread. 02:06:00,750 [ main] DEBUG ZkConnection - Closing ZooKeeper connected to gk 02:06:00,750 [ main] DEBUG ZooKeeper - Closing session: 0x145910d2da80009 02:06:00,750 [ main] DEBUG ClientCnxn - Closing client for session: 0x145910d2da80009 02:06:00,783 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 25,5 replyHeader:: 25,25769803846,-101 request:: '/consumers/Q/offsets/KafkaMessagingTest1398297958826/0,#31,-1 response:: 02:06:00,784 [826-0] DEBUG ZkClient - Waiting for keeper state SyncConnected 02:06:00,799 [2181)] DEBUG ClientCnxn - Got notification sessionid:0x145910d2da80009 02:06:00,800 [2181)] DEBUG ClientCnxn - Got WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/consumers/Q/ids for sessionid 0x145910d2da80009 02:06:00,800 [hread] DEBUG ZkClient - Received event: WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/consumers/Q/ids 02:06:00,800 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80009, packet:: clientPath:null serverPath:null finished:false header:: 26,-11 replyHeader:: 26,25769803847,0 request:: null response:: null 02:06:00,801 [ main] DEBUG ClientCnxn - Disconnecting client for session: 0x145910d2da80009 02:06:00,801 [ main] INFO ZooKeeper - Session: 0x145910d2da80009 closed 02:06:00,801 [2181)] DEBUG ClientCnxn - An exception was thrown while closing send thread for session 0x145910d2da80009 : Unable to read additional data from server sessionid 0x145910d2da80009, likely server has closed socket 02:06:00,801 [ main] DEBUG ZkClient - Closing ZkClient...done 02:06:00,801 [826-0] DEBUG ZkClient - State is SyncConnected 02:06:00,801 [hread] DEBUG ZkClient - ignoring event '{NodeChildrenChanged | /consumers/Q/ids}' since shutdown triggered 02:06:00,801 [hread] DEBUG ZkClient - Leaving process event 02:06:00,801 [hread] INFO ClientCnxn - EventThread shut down 02:06:00,801 [ main] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], ZKConsumerConnector shut down completed 02:06:00,802 [ main] INFO Producer - Shutting down producer 02:06:00,802 [ main] INFO ProducerPool - Closing all sync producers 02:06:00,803 [826-0] WARN ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], 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:690) 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) 02:06:00,804 [ main] INFO SyncProducer - Disconnecting from gk:9092 02:06:00,805 [ main] DEBUG ZkClient - Closing ZkClient... 02:06:00,805 [23-gk] INFO ZkEventThread - Terminate ZkClient event thread. 02:06:00,805 [ main] DEBUG ZkConnection - Closing ZooKeeper connected to gk 02:06:00,805 [ main] DEBUG ZooKeeper - Closing session: 0x145910d2da80008 02:06:00,805 [ main] DEBUG ClientCnxn - Closing client for session: 0x145910d2da80008 02:06:00,805 [826-0] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], Committed offset 1 for topic KafkaMessagingTest1398297958826:0: fetched offset = 1: consumed offset = 1 02:06:00,805 [826-0] DEBUG KafkaSubscriber - commit 02:06:00,824 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da80008, packet:: clientPath:null serverPath:null finished:false header:: 9,-11 replyHeader:: 9,25769803848,0 request:: null response:: null 02:06:00,824 [ main] DEBUG ClientCnxn - Disconnecting client for session: 0x145910d2da80008 02:06:00,825 [ main] INFO ZooKeeper - Session: 0x145910d2da80008 closed 02:06:00,825 [ main] DEBUG ZkClient - Closing ZkClient...done 02:06:00,825 [hread] INFO ClientCnxn - EventThread shut down 02:06:00,825 [ main] DEBUG ZkConnection - Creating new ZookKeeper instance to connect to gk. 02:06:00,825 [38-gk] INFO ZkEventThread - Starting ZkClient event thread. 02:06:00,825 [ main] INFO ZooKeeper - Initiating client connection, connectString=gk sessionTimeout=3000 watcher=org.I0Itec.zkclient.ZkClient@341fae71 02:06:00,826 [ main] DEBUG ZkClient - Awaiting connection to Zookeeper server 02:06:00,826 [ main] DEBUG ZkClient - Waiting for keeper state SyncConnected 02:06:00,826 [2181)] INFO ClientCnxn - Opening socket connection to server gk/145.76.94.98:2181. Will not attempt to authenticate using SASL (unknown error) 02:06:00,827 [2181)] INFO ClientCnxn - Socket connection established to gk/145.76.94.98:2181, initiating session 02:06:00,827 [2181)] DEBUG ClientCnxn - Session establishment request sent on gk/145.76.94.98:2181 02:06:00,842 [2181)] INFO ClientCnxn - Session establishment complete on server gk/145.76.94.98:2181, sessionid = 0x145910d2da8000a, negotiated timeout = 4000 02:06:00,843 [hread] DEBUG ZkClient - Received event: WatchedEvent state:SyncConnected type:None path:null 02:06:00,843 [hread] INFO ZkClient - zookeeper state changed (SyncConnected) 02:06:00,843 [ main] DEBUG ZkClient - State is SyncConnected 02:06:00,843 [hread] DEBUG ZkClient - Leaving process event 02:06:00,845 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000a, packet:: clientPath:null serverPath:null finished:false header:: 1,8 replyHeader:: 1,25769803849,0 request:: '/brokers/ids,F response:: v{'0} 02:06:00,846 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000a, packet:: clientPath:null serverPath:null finished:false header:: 2,4 replyHeader:: 2,25769803849,0 request:: '/brokers/ids/0,F response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938323937393339303230222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398297939035,1398297939035,0,0,0,91638853217550341,79,0,25769803806} 02:06:00,855 [ main] DEBUG ZkClient - Closing ZkClient... 02:06:00,855 [38-gk] INFO ZkEventThread - Terminate ZkClient event thread. 02:06:00,855 [ main] DEBUG ZkConnection - Closing ZooKeeper connected to gk 02:06:00,855 [ main] DEBUG ZooKeeper - Closing session: 0x145910d2da8000a 02:06:00,855 [ main] DEBUG ClientCnxn - Closing client for session: 0x145910d2da8000a 02:06:00,875 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000a, packet:: clientPath:null serverPath:null finished:false header:: 3,-11 replyHeader:: 3,25769803850,0 request:: null response:: null 02:06:00,875 [ main] DEBUG ClientCnxn - Disconnecting client for session: 0x145910d2da8000a 02:06:00,876 [ main] INFO ZooKeeper - Session: 0x145910d2da8000a closed 02:06:00,876 [ main] DEBUG ZkClient - Closing ZkClient...done 02:06:00,876 [hread] INFO ClientCnxn - EventThread shut down 02:06:00,876 [ main] INFO VerifiableProperties - Verifying properties 02:06:00,877 [ main] INFO VerifiableProperties - Property batch.num.messages is overridden to 2 02:06:00,877 [ main] INFO VerifiableProperties - Property compression.codec is overridden to none 02:06:00,877 [ main] INFO VerifiableProperties - Property metadata.broker.list is overridden to gk:9092 02:06:00,877 [ main] INFO VerifiableProperties - Property producer.type is overridden to async 02:06:00,878 [ main] WARN VerifiableProperties - Property queue.buffer.max.ms is not valid 02:06:00,878 [ main] INFO VerifiableProperties - Property request.required.acks is overridden to 1 02:06:00,878 [ main] INFO VerifiableProperties - Property serializer.class is overridden to com.sysnature.messaging.kafka.SerializerEncoder 02:06:00,883 [ main] DEBUG KafkaPublisher - sent message to [KafkaMessagingTest1398297958826]: 1 02:06:00,883 [ main] DEBUG KafkaPublisher - sent message to [KafkaMessagingTest1398297958826]: 2 02:06:00,883 [ main] INFO VerifiableProperties - Verifying properties 02:06:00,884 [ main] INFO VerifiableProperties - Property auto.commit.enable is overridden to false 02:06:00,884 [ main] INFO VerifiableProperties - Property auto.offset.reset is overridden to smallest 02:06:00,884 [ main] INFO VerifiableProperties - Property group.id is overridden to Q 02:06:00,884 [ main] INFO VerifiableProperties - Property zookeeper.connect is overridden to gk 02:06:00,885 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Connecting to zookeeper instance at gk 02:06:00,886 [ead-2] DEBUG ZkConnection - Creating new ZookKeeper instance to connect to gk. 02:06:00,886 [ead-2] INFO ZooKeeper - Initiating client connection, connectString=gk sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@738f651f 02:06:00,886 [44-gk] INFO ZkEventThread - Starting ZkClient event thread. 02:06:00,886 [ead-2] DEBUG ZkClient - Awaiting connection to Zookeeper server 02:06:00,886 [2181)] INFO ClientCnxn - Opening socket connection to server gk/145.76.94.98:2181. Will not attempt to authenticate using SASL (unknown error) 02:06:00,886 [read-] DEBUG ProducerSendThread - Batch full. Sending.. 02:06:00,887 [ead-2] DEBUG ZkClient - Waiting for keeper state SyncConnected 02:06:00,887 [read-] DEBUG ProducerSendThread - Handling 2 events 02:06:00,888 [read-] DEBUG DefaultEventHandler - Handling 2 events 02:06:00,888 [read-] INFO ClientUtils$ - Fetching metadata from broker id:0,host:gk,port:9092 with correlation id 0 for 1 topic(s) Set(KafkaMessagingTest1398297958826) 02:06:00,891 [2181)] INFO ClientCnxn - Socket connection established to gk/145.76.94.98:2181, initiating session 02:06:00,891 [2181)] DEBUG ClientCnxn - Session establishment request sent on gk/145.76.94.98:2181 02:06:00,891 [read-] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 10000 (requested 10000), SO_RCVBUF = 43690 (requested -1), SO_SNDBUF = 102400 (requested 102400). 02:06:00,891 [read-] INFO SyncProducer - Connected to gk:9092 for producing 02:06:00,896 [read-] INFO SyncProducer - Disconnecting from gk:9092 02:06:00,896 [read-] DEBUG ClientUtils$ - Successfully fetched metadata for 1 topic(s) Set(KafkaMessagingTest1398297958826) 02:06:00,896 [read-] DEBUG BrokerPartitionInfo - Getting broker partition info for topic KafkaMessagingTest1398297958826 02:06:00,897 [read-] DEBUG BrokerPartitionInfo - Partition [KafkaMessagingTest1398297958826,0] has leader 0 02:06:00,897 [read-] DEBUG DefaultEventHandler - Broker partitions registered for topic: KafkaMessagingTest1398297958826 are 0 02:06:00,897 [read-] DEBUG BrokerPartitionInfo - Getting broker partition info for topic KafkaMessagingTest1398297958826 02:06:00,897 [read-] DEBUG BrokerPartitionInfo - Partition [KafkaMessagingTest1398297958826,0] has leader 0 02:06:00,897 [read-] DEBUG DefaultEventHandler - Broker partitions registered for topic: KafkaMessagingTest1398297958826 are 0 02:06:00,898 [read-] DEBUG DefaultEventHandler - Sending 2 messages with no compression to [KafkaMessagingTest1398297958826,0] 02:06:00,898 [read-] DEBUG DefaultEventHandler - Producer sending messages with correlation id 3 for topics [KafkaMessagingTest1398297958826,0] to broker 0 on gk:9092 02:06:00,899 [read-] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 10000 (requested 10000), SO_RCVBUF = 43690 (requested -1), SO_SNDBUF = 102400 (requested 102400). 02:06:00,899 [read-] INFO SyncProducer - Connected to gk:9092 for producing 02:06:00,902 [read-] DEBUG DefaultEventHandler - Producer sent messages with correlation id 3 for topics [KafkaMessagingTest1398297958826,0] to broker 0 on gk:9092 02:06:00,909 [2181)] INFO ClientCnxn - Session establishment complete on server gk/145.76.94.98:2181, sessionid = 0x145910d2da8000b, negotiated timeout = 6000 02:06:00,909 [hread] DEBUG ZkClient - Received event: WatchedEvent state:SyncConnected type:None path:null 02:06:00,910 [hread] INFO ZkClient - zookeeper state changed (SyncConnected) 02:06:00,910 [hread] DEBUG ZkClient - Leaving process event 02:06:00,910 [ead-2] DEBUG ZkClient - State is SyncConnected 02:06:00,911 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], entering consume 02:06:00,911 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], begin registering consumer Q_dev-1398297960885-583b205a in ZK 02:06:00,926 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 1,1 replyHeader:: 1,25769803852,0 request:: '/consumers/Q/ids/Q_dev-1398297960885-583b205a,#7b2276657273696f6e223a312c22737562736372697074696f6e223a7b224b61666b614d6573736167696e675465737431333938323937393538383236223a317d2c227061747465726e223a22737461746963222c2274696d657374616d70223a2231333938323937393630393131227d,v{s{31,s{'world,'anyone}}},1 response:: '/consumers/Q/ids/Q_dev-1398297960885-583b205a 02:06:00,926 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], end registering consumer Q_dev-1398297960885-583b205a in ZK 02:06:00,926 [cutor] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], starting watcher executor thread for consumer Q_dev-1398297960885-583b205a 02:06:00,927 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Adding topicThreadId (KafkaMessagingTest1398297958826,Q_dev-1398297960885-583b205a-0) and queue [] to topicThreadIdAndQueues data structure 02:06:00,928 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], adding topic KafkaMessagingTest1398297958826 and 1 streams to map. 02:06:00,929 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 2,3 replyHeader:: 2,25769803852,0 request:: '/consumers/Q/ids,T response:: s{25769803839,25769803839,1398298075572,1398298075572,0,3,0,0,0,1,25769803852} 02:06:00,930 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 3,8 replyHeader:: 3,25769803852,0 request:: '/consumers/Q/ids,T response:: v{'Q_dev-1398297960885-583b205a} 02:06:00,932 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 4,3 replyHeader:: 4,25769803852,0 request:: '/brokers/topics/KafkaMessagingTest1398297958826,T response:: s{25769803829,25769803829,1398298075162,1398298075162,0,1,0,0,36,1,25769803832} 02:06:00,932 [ead-2] DEBUG ZkClient - Subscribed data changes for /brokers/topics/KafkaMessagingTest1398297958826 02:06:00,932 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], begin rebalancing consumer Q_dev-1398297960885-583b205a try #0 02:06:00,934 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 5,8 replyHeader:: 5,25769803852,0 request:: '/brokers/ids,F response:: v{'0} 02:06:00,936 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 6,4 replyHeader:: 6,25769803852,0 request:: '/brokers/ids/0,F response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938323937393339303230222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398297939035,1398297939035,0,0,0,91638853217550341,79,0,25769803806} 02:06:00,947 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 7,4 replyHeader:: 7,25769803852,0 request:: '/consumers/Q/ids/Q_dev-1398297960885-583b205a,F response:: #7b2276657273696f6e223a312c22737562736372697074696f6e223a7b224b61666b614d6573736167696e675465737431333938323937393538383236223a317d2c227061747465726e223a22737461746963222c2274696d657374616d70223a2231333938323937393630393131227d,s{25769803852,25769803852,1398298076510,1398298076510,0,0,0,91638853217550347,113,0,25769803852} 02:06:00,959 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 8,8 replyHeader:: 8,25769803852,0 request:: '/consumers/Q/ids,T response:: v{'Q_dev-1398297960885-583b205a} 02:06:00,962 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 9,4 replyHeader:: 9,25769803852,0 request:: '/consumers/Q/ids/Q_dev-1398297960885-583b205a,F response:: #7b2276657273696f6e223a312c22737562736372697074696f6e223a7b224b61666b614d6573736167696e675465737431333938323937393538383236223a317d2c227061747465726e223a22737461746963222c2274696d657374616d70223a2231333938323937393630393131227d,s{25769803852,25769803852,1398298076510,1398298076510,0,0,0,91638853217550347,113,0,25769803852} 02:06:00,972 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 10,8 replyHeader:: 10,25769803852,0 request:: '/brokers/ids,F response:: v{'0} 02:06:00,973 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 11,4 replyHeader:: 11,25769803852,0 request:: '/brokers/ids/0,F response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938323937393339303230222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398297939035,1398297939035,0,0,0,91638853217550341,79,0,25769803806} 02:06:00,985 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 12,4 replyHeader:: 12,25769803852,0 request:: '/brokers/topics/KafkaMessagingTest1398297958826,T response:: #7b2276657273696f6e223a312c22706172746974696f6e73223a7b2230223a5b305d7d7d,s{25769803829,25769803829,1398298075162,1398298075162,0,1,0,0,36,1,25769803832} 02:06:00,989 [ead-2] DEBUG ZkUtils$ - Partition map for /brokers/topics/KafkaMessagingTest1398297958826 is Map(0 -> List(0)) 02:06:00,989 [ead-2] INFO ConsumerFetcherManager - [ConsumerFetcherManager-1398297960910] Stopping leader finder thread 02:06:00,989 [ead-2] INFO ConsumerFetcherManager - [ConsumerFetcherManager-1398297960910] Stopping all fetchers 02:06:00,989 [ead-2] INFO ConsumerFetcherManager - [ConsumerFetcherManager-1398297960910] All connections stopped 02:06:00,990 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Cleared all relevant queues for this fetcher 02:06:00,990 [ead-2] DEBUG ConsumerIterator - Clearing the current data chunk for this consumer iterator 02:06:00,990 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Cleared the data chunks in all the consumer message iterators 02:06:00,990 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Committing all offsets after clearing the fetcher queues 02:06:00,990 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Releasing partition ownership 02:06:00,990 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Consumer Q_dev-1398297960885-583b205a rebalancing the following partitions: ArrayBuffer(0) for topic KafkaMessagingTest1398297958826 with consumers: List(Q_dev-1398297960885-583b205a-0) 02:06:00,990 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Q_dev-1398297960885-583b205a-0 attempting to claim partition 0 02:06:00,996 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 13,4 replyHeader:: 13,25769803852,-101 request:: '/consumers/Q/offsets/KafkaMessagingTest1398297958826/0,F response:: 02:06:00,996 [ead-2] DEBUG PartitionTopicInfo - initial consumer offset of KafkaMessagingTest1398297958826:0: fetched offset = -1: consumed offset = -1 is -1 02:06:00,996 [ead-2] DEBUG PartitionTopicInfo - initial fetch offset of KafkaMessagingTest1398297958826:0: fetched offset = -1: consumed offset = -1 is -1 02:06:00,996 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], KafkaMessagingTest1398297958826:0: fetched offset = -1: consumed offset = -1 selected new offset -1 02:06:01,017 [cutor] INFO ZookeeperConsumerConnector - [Q_dev-1398297959762-9699d19f], stopping watcher executor thread for consumer Q_dev-1398297959762-9699d19f 02:06:01,025 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 14,1 replyHeader:: 14,25769803853,0 request:: '/consumers/Q/owners/KafkaMessagingTest1398297958826/0,#515f6465762d313339383239373936303838352d35383362323035612d30,v{s{31,s{'world,'anyone}}},1 response:: '/consumers/Q/owners/KafkaMessagingTest1398297958826/0 02:06:01,025 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Q_dev-1398297960885-583b205a-0 successfully owned partition 0 for topic KafkaMessagingTest1398297958826 02:06:01,025 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Updating the cache 02:06:01,025 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Partitions per topic cache Map(KafkaMessagingTest1398297958826 -> ArrayBuffer(0)) 02:06:01,025 [ead-2] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Consumers per topic cache Map(KafkaMessagingTest1398297958826 -> List(Q_dev-1398297960885-583b205a-0)) 02:06:01,025 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Consumer Q_dev-1398297960885-583b205a selected partitions : KafkaMessagingTest1398297958826:0: fetched offset = -1: consumed offset = -1 02:06:01,026 [ead-2] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], end rebalancing consumer Q_dev-1398297960885-583b205a try #0 02:06:01,026 [hread] INFO ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398297960885-583b205a-leader-finder-thread], Starting 02:06:01,027 [ main] DEBUG KafkaPublisher - sent message to [KafkaMessagingTest1398297958826]: 1222 02:06:01,027 [ main] DEBUG KafkaPublisher - sent message to [KafkaMessagingTest1398297958826]: 23.45 02:06:01,027 [read-] DEBUG ProducerSendThread - Batch full. Sending.. 02:06:01,027 [read-] DEBUG ProducerSendThread - Handling 2 events 02:06:01,027 [read-] DEBUG DefaultEventHandler - Handling 2 events 02:06:01,027 [read-] DEBUG BrokerPartitionInfo - Getting broker partition info for topic KafkaMessagingTest1398297958826 02:06:01,028 [read-] DEBUG BrokerPartitionInfo - Partition [KafkaMessagingTest1398297958826,0] has leader 0 02:06:01,028 [read-] DEBUG DefaultEventHandler - Broker partitions registered for topic: KafkaMessagingTest1398297958826 are 0 02:06:01,028 [read-] DEBUG BrokerPartitionInfo - Getting broker partition info for topic KafkaMessagingTest1398297958826 02:06:01,028 [read-] DEBUG BrokerPartitionInfo - Partition [KafkaMessagingTest1398297958826,0] has leader 0 02:06:01,028 [read-] DEBUG DefaultEventHandler - Broker partitions registered for topic: KafkaMessagingTest1398297958826 are 0 02:06:01,028 [read-] DEBUG DefaultEventHandler - Sending 2 messages with no compression to [KafkaMessagingTest1398297958826,0] 02:06:01,029 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 15,8 replyHeader:: 15,25769803853,0 request:: '/brokers/ids,F response:: v{'0} 02:06:01,029 [read-] DEBUG DefaultEventHandler - Producer sending messages with correlation id 6 for topics [KafkaMessagingTest1398297958826,0] to broker 0 on gk:9092 02:06:01,030 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 16,4 replyHeader:: 16,25769803853,0 request:: '/brokers/ids/0,F response:: #7b226a6d785f706f7274223a2d312c2274696d657374616d70223a2231333938323937393339303230222c22686f7374223a22676b222c2276657273696f6e223a312c22706f7274223a393039327d,s{25769803806,25769803806,1398297939035,1398297939035,0,0,0,91638853217550341,79,0,25769803806} 02:06:01,032 [read-] DEBUG DefaultEventHandler - Producer sent messages with correlation id 6 for topics [KafkaMessagingTest1398297958826,0] to broker 0 on gk:9092 02:06:01,034 [hread] INFO VerifiableProperties - Verifying properties 02:06:01,035 [hread] INFO VerifiableProperties - Property client.id is overridden to Q 02:06:01,035 [hread] INFO VerifiableProperties - Property metadata.broker.list is overridden to gk:9092 02:06:01,035 [hread] INFO VerifiableProperties - Property request.timeout.ms is overridden to 30000 02:06:01,035 [hread] INFO ClientUtils$ - Fetching metadata from broker id:0,host:gk,port:9092 with correlation id 0 for 1 topic(s) Set(KafkaMessagingTest1398297958826) 02:06:01,037 [hread] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 30000 (requested 30000), SO_RCVBUF = 43690 (requested -1), SO_SNDBUF = 102400 (requested 102400). 02:06:01,037 [hread] INFO SyncProducer - Connected to gk:9092 for producing 02:06:01,040 [hread] INFO SyncProducer - Disconnecting from gk:9092 02:06:01,041 [hread] DEBUG ClientUtils$ - Successfully fetched metadata for 1 topic(s) Set(KafkaMessagingTest1398297958826) 02:06:01,041 [hread] DEBUG ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398297960885-583b205a-leader-finder-thread], {TopicMetadata for topic KafkaMessagingTest1398297958826 -> Metadata for partition [KafkaMessagingTest1398297958826,0] is partition 0 leader: 0 (gk:9092) replicas: 0 (gk:9092) isr: 0 (gk:9092) isUnderReplicated: false} 02:06:01,044 [a-0-0] INFO ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398297960885-583b205a-0-0], Starting 02:06:01,045 [hread] DEBUG BlockingChannel - Created socket with SO_TIMEOUT = 30000 (requested 30000), SO_RCVBUF = 65536 (requested 65536), SO_SNDBUF = 8192 (requested -1). 02:06:01,048 [hread] DEBUG PartitionTopicInfo - reset fetch offset of ( KafkaMessagingTest1398297958826:0: fetched offset = 0: consumed offset = -1 ) to 0 02:06:01,048 [hread] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398297958826:0: fetched offset = 0: consumed offset = 0 to 0 02:06:01,048 [hread] INFO ConsumerFetcherManager - [ConsumerFetcherManager-1398297960910] Added fetcher for partitions ArrayBuffer([[KafkaMessagingTest1398297958826,0], initOffset -1 to broker id:0,host:gk,port:9092] ) 02:06:01,052 [a-0-0] DEBUG PartitionTopicInfo - updated fetch offset of (KafkaMessagingTest1398297958826:0: fetched offset = 5: consumed offset = 1) to 5 02:06:01,052 [826-0] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398297958826:0: fetched offset = 5: consumed offset = 1 to 1 02:06:01,053 [826-0] DEBUG KafkaSubscriber - received in [KafkaMessagingTest1398297958826]: create 02:06:01,075 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 17,5 replyHeader:: 17,25769803854,-101 request:: '/consumers/Q/offsets/KafkaMessagingTest1398297958826/0,#31,-1 response:: 02:06:01,100 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 18,1 replyHeader:: 18,25769803855,-101 request:: '/consumers/Q/offsets/KafkaMessagingTest1398297958826,,v{s{31,s{'world,'anyone}}},0 response:: 02:06:01,122 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, 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 02:06:01,143 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 20,1 replyHeader:: 20,25769803857,0 request:: '/consumers/Q/offsets/KafkaMessagingTest1398297958826,,v{s{31,s{'world,'anyone}}},0 response:: '/consumers/Q/offsets/KafkaMessagingTest1398297958826 02:06:01,158 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 21,1 replyHeader:: 21,25769803858,0 request:: '/consumers/Q/offsets/KafkaMessagingTest1398297958826/0,#31,v{s{31,s{'world,'anyone}}},0 response:: '/consumers/Q/offsets/KafkaMessagingTest1398297958826/0 02:06:01,158 [826-0] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Committed offset 1 for topic KafkaMessagingTest1398297958826:0: fetched offset = 5: consumed offset = 1 02:06:01,158 [826-0] DEBUG KafkaSubscriber - commit 02:06:01,158 [826-0] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398297958826:0: fetched offset = 5: consumed offset = 2 to 2 02:06:01,158 [826-0] DEBUG KafkaSubscriber - received in [KafkaMessagingTest1398297958826]: 1 02:06:01,188 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 22,5 replyHeader:: 22,25769803859,0 request:: '/consumers/Q/offsets/KafkaMessagingTest1398297958826/0,#32,-1 response:: s{25769803858,25769803859,1398298076742,1398298076756,1,0,0,0,1,0,25769803858} 02:06:01,189 [826-0] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Committed offset 2 for topic KafkaMessagingTest1398297958826:0: fetched offset = 5: consumed offset = 2 02:06:01,189 [826-0] DEBUG KafkaSubscriber - commit 02:06:01,189 [826-0] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398297958826:0: fetched offset = 5: consumed offset = 3 to 3 02:06:01,189 [826-0] DEBUG KafkaSubscriber - received in [KafkaMessagingTest1398297958826]: 2 02:06:01,217 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 23,5 replyHeader:: 23,25769803860,0 request:: '/consumers/Q/offsets/KafkaMessagingTest1398297958826/0,#33,-1 response:: s{25769803858,25769803860,1398298076742,1398298076787,2,0,0,0,1,0,25769803858} 02:06:01,217 [826-0] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Committed offset 3 for topic KafkaMessagingTest1398297958826:0: fetched offset = 5: consumed offset = 3 02:06:01,217 [826-0] DEBUG KafkaSubscriber - commit 02:06:01,217 [826-0] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398297958826:0: fetched offset = 5: consumed offset = 4 to 4 02:06:01,217 [826-0] DEBUG KafkaSubscriber - received in [KafkaMessagingTest1398297958826]: 1222 StopWatch '': running time (millis) = 191; [send & receive 2 messages] took 191 = 100%02:06:01,218 [ main] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], ZKConsumerConnector shutting down 02:06:01,218 [ main] INFO ConsumerFetcherManager - [ConsumerFetcherManager-1398297960910] Stopping leader finder thread 02:06:01,218 [ main] INFO ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398297960885-583b205a-leader-finder-thread], Shutting down 02:06:01,218 [hread] INFO ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398297960885-583b205a-leader-finder-thread], Stopped 02:06:01,218 [ main] INFO ConsumerFetcherManager$LeaderFinderThread - [Q_dev-1398297960885-583b205a-leader-finder-thread], Shutdown completed 02:06:01,218 [ main] INFO ConsumerFetcherManager - [ConsumerFetcherManager-1398297960910] Stopping all fetchers 02:06:01,218 [ main] INFO ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398297960885-583b205a-0-0], Shutting down 02:06:01,241 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 24,5 replyHeader:: 24,25769803861,0 request:: '/consumers/Q/offsets/KafkaMessagingTest1398297958826/0,#34,-1 response:: s{25769803858,25769803861,1398298076742,1398298076816,3,0,0,0,1,0,25769803858} 02:06:01,241 [826-0] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Committed offset 4 for topic KafkaMessagingTest1398297958826:0: fetched offset = 5: consumed offset = 4 02:06:01,241 [826-0] DEBUG KafkaSubscriber - commit 02:06:01,242 [826-0] DEBUG PartitionTopicInfo - reset consume offset of KafkaMessagingTest1398297958826:0: fetched offset = 5: consumed offset = 5 to 5 02:06:01,242 [826-0] DEBUG KafkaSubscriber - received in [KafkaMessagingTest1398297958826]: 23.45 02:06:01,257 [a-0-0] WARN SimpleConsumer - Reconnect due to socket error: null 02:06:01,257 [a-0-0] DEBUG SimpleConsumer - Disconnecting from gk:9092 02:06:01,257 [a-0-0] INFO ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398297960885-583b205a-0-0], Stopped 02:06:01,257 [ main] INFO ConsumerFetcherThread - [ConsumerFetcherThread-Q_dev-1398297960885-583b205a-0-0], Shutdown completed 02:06:01,257 [ main] INFO ConsumerFetcherManager - [ConsumerFetcherManager-1398297960910] All connections stopped 02:06:01,258 [ main] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Clearing up queue 02:06:01,258 [ main] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Cleared queue and sent shutdown command 02:06:01,258 [ main] DEBUG ZkClient - Closing ZkClient... 02:06:01,258 [44-gk] INFO ZkEventThread - Terminate ZkClient event thread. 02:06:01,258 [ main] DEBUG ZkConnection - Closing ZooKeeper connected to gk 02:06:01,258 [ main] DEBUG ZooKeeper - Closing session: 0x145910d2da8000b 02:06:01,258 [ main] DEBUG ClientCnxn - Closing client for session: 0x145910d2da8000b 02:06:01,259 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 25,5 replyHeader:: 25,25769803862,0 request:: '/consumers/Q/offsets/KafkaMessagingTest1398297958826/0,#35,-1 response:: s{25769803858,25769803862,1398298076742,1398298076840,4,0,0,0,1,0,25769803858} 02:06:01,259 [826-0] DEBUG ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], Committed offset 5 for topic KafkaMessagingTest1398297958826:0: fetched offset = 5: consumed offset = 5 02:06:01,259 [826-0] DEBUG KafkaSubscriber - commit 02:06:01,260 [826-0] DEBUG ConsumerIterator - Received the shutdown command 02:06:01,282 [2181)] DEBUG ClientCnxn - Got notification sessionid:0x145910d2da8000b 02:06:01,282 [2181)] DEBUG ClientCnxn - Got WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/consumers/Q/ids for sessionid 0x145910d2da8000b 02:06:01,283 [hread] DEBUG ZkClient - Received event: WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/consumers/Q/ids 02:06:01,283 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000b, packet:: clientPath:null serverPath:null finished:false header:: 26,-11 replyHeader:: 26,25769803863,0 request:: null response:: null 02:06:01,283 [ main] DEBUG ClientCnxn - Disconnecting client for session: 0x145910d2da8000b 02:06:01,283 [ main] INFO ZooKeeper - Session: 0x145910d2da8000b closed 02:06:01,283 [ main] DEBUG ZkClient - Closing ZkClient...done 02:06:01,283 [hread] DEBUG ZkClient - ignoring event '{NodeChildrenChanged | /consumers/Q/ids}' since shutdown triggered 02:06:01,283 [ main] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], ZKConsumerConnector shut down completed 02:06:01,283 [hread] DEBUG ZkClient - Leaving process event 02:06:01,284 [ main] INFO Producer - Shutting down producer 02:06:01,284 [hread] INFO ClientCnxn - EventThread shut down 02:06:01,284 [ main] INFO ProducerSendThread - Begin shutting down ProducerSendThread 02:06:01,284 [read-] DEBUG ProducerSendThread - Handling 0 events 02:06:01,285 [ main] INFO ProducerSendThread - Shutdown ProducerSendThread complete 02:06:01,285 [ main] INFO ProducerPool - Closing all sync producers 02:06:01,286 [ main] INFO SyncProducer - Disconnecting from gk:9092 02:06:01,286 [ main] DEBUG KafkaMessagingTest - deleting: KafkaMessagingTest1398297958826 02:06:01,287 [ main] DEBUG ZkConnection - Creating new ZookKeeper instance to connect to gk. 02:06:01,287 [51-gk] INFO ZkEventThread - Starting ZkClient event thread. 02:06:01,287 [ main] INFO ZooKeeper - Initiating client connection, connectString=gk sessionTimeout=3000 watcher=org.I0Itec.zkclient.ZkClient@42b113b8 02:06:01,288 [ main] DEBUG ZkClient - Awaiting connection to Zookeeper server 02:06:01,288 [ main] DEBUG ZkClient - Waiting for keeper state SyncConnected 02:06:01,288 [2181)] INFO ClientCnxn - Opening socket connection to server gk/145.76.94.98:2181. Will not attempt to authenticate using SASL (unknown error) 02:06:01,290 [2181)] INFO ClientCnxn - Socket connection established to gk/145.76.94.98:2181, initiating session 02:06:01,290 [2181)] DEBUG ClientCnxn - Session establishment request sent on gk/145.76.94.98:2181 02:06:01,332 [2181)] INFO ClientCnxn - Session establishment complete on server gk/145.76.94.98:2181, sessionid = 0x145910d2da8000c, negotiated timeout = 4000 02:06:01,332 [hread] DEBUG ZkClient - Received event: WatchedEvent state:SyncConnected type:None path:null 02:06:01,333 [hread] INFO ZkClient - zookeeper state changed (SyncConnected) 02:06:01,333 [hread] DEBUG ZkClient - Leaving process event 02:06:01,333 [ main] DEBUG ZkClient - State is SyncConnected 02:06:01,335 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000c, packet:: clientPath:null serverPath:null finished:false header:: 1,8 replyHeader:: 1,25769803864,0 request:: '/brokers/topics,F response:: v{'KafkaMessagingTest1398297958826} 02:06:01,337 [ main] DEBUG Whitelist - KafkaMessagingTest1398297958826 allowed 02:06:01,368 [2181)] DEBUG ClientCnxn - Reading reply sessionid:0x145910d2da8000c, packet:: clientPath:null serverPath:null finished:false header:: 2,1 replyHeader:: 2,25769803865,0 request:: '/admin/delete_topics/KafkaMessagingTest1398297958826,,v{s{31,s{'world,'anyone}}},0 response:: '/admin/delete_topics/KafkaMessagingTest1398297958826 Topic "KafkaMessagingTest1398297958826" queued for deletion.02:06:01,929 [cutor] INFO ZookeeperConsumerConnector - [Q_dev-1398297960885-583b205a], stopping watcher executor thread for consumer Q_dev-1398297960885-583b205a 02:06:03,168 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 495ms 02:06:04,016 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 9ms 02:06:05,349 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 10ms 02:06:06,702 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 29ms 02:06:08,008 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 0ms 02:06:09,341 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 0ms 02:06:10,683 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 9ms 02:06:12,007 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 0ms 02:06:13,341 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 2ms 02:06:14,699 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 26ms 02:06:16,007 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 0ms 02:06:17,340 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 0ms 02:06:18,700 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 27ms 02:06:20,006 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 0ms 02:06:21,339 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 0ms 02:06:22,699 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 27ms 02:06:24,007 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 2ms 02:06:25,338 [2181)] DEBUG ClientCnxn - Got ping response for sessionid: 0x145910d2da8000c after 0ms