[2012-10-11 12:19:59,419] INFO Starting mirror maker (kafka.tools.MirrorMaker$) [2012-10-11 12:19:59,460] INFO Verifying properties (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,461] INFO Property broker.list is overridden to localhost:9094,localhost:9095,localhost:9096 (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,461] INFO Property compression.codec is overridden to 0 (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,461] INFO Property producer.type is overridden to async (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,461] INFO Property queue.enqueueTimeout.ms is overridden to -1 (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,510] INFO Verifying properties (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,511] INFO Property zk.connect is overridden to localhost:2108,localhost:2118 (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,511] INFO Property socket.buffersize is overridden to 1048576 (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,511] INFO Property groupid is overridden to mm_regtest_grp (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,511] INFO Property shallowiterator.enable is overridden to true (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,511] INFO Property zk.connectiontimeout.ms is overridden to 1000000 (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,512] INFO Property fetch.size is overridden to 1048576 (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,512] INFO Property autocommit.interval.ms is overridden to 120000 (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,512] INFO Property autooffset.reset is overridden to smallest (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,512] INFO Property zk.synctime.ms is overridden to 15000 (kafka.utils.VerifiableProperties) [2012-10-11 12:19:59,521] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Connecting to zookeeper instance at localhost:2108,localhost:2118 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:19:59,530] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread) [2012-10-11 12:19:59,535] INFO Client environment:zookeeper.version=3.3.3-1203054, built on 11/17/2011 05:47 GMT (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,535] INFO Client environment:host.name= (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,535] INFO Client environment:java.version=1.6.0_27 (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,535] INFO Client environment:java.vendor=Sun Microsystems Inc. (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,535] INFO Client environment:java.home=/export/apps/jdk/JDK-1_6_0_27/jre (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,535] INFO Client environment:java.class.path=:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../project/boot/scala-2.8.0/lib/scala-compiler.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../project/boot/scala-2.8.0/lib/scala-library.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/target/scala_2.8.0/kafka-0.8.0.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib/metrics-annotation-3.0.0-10ccc80c.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib/metrics-core-3.0.0-10ccc80c.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib/zkclient-20120522.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../perf/target/scala_2.8.0/kafka-perf-0.8.0.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib_managed/scala_2.8.0/compile/jopt-simple-3.2.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib_managed/scala_2.8.0/compile/log4j-1.2.15.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib_managed/scala_2.8.0/compile/slf4j-api-1.7.1.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib_managed/scala_2.8.0/compile/slf4j-simple-1.7.1.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib_managed/scala_2.8.0/compile/snappy-java-1.0.4.1.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib_managed/scala_2.8.0/compile/zookeeper-3.3.4.jar (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,535] INFO Client environment:java.library.path=/export/apps/jdk/JDK-1_6_0_27/jre/lib/amd64/server:/export/apps/jdk/JDK-1_6_0_27/jre/lib/amd64:/export/apps/jdk/JDK-1_6_0_27/jre/../lib/amd64:/local/instantclient_10_2:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,535] INFO Client environment:java.io.tmpdir=/tmp (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,535] INFO Client environment:java.compiler= (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,535] INFO Client environment:os.name=Linux (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,536] INFO Client environment:os.arch=amd64 (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,536] INFO Client environment:os.version=2.6.32-131.4.1.el6.x86_64 (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,536] INFO Client environment:user.name=jfung (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,536] INFO Client environment:user.home=/home/jfung (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,536] INFO Client environment:user.dir=/home/jfung (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,536] INFO Initiating client connection, connectString=localhost:2108,localhost:2118 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@7ab7b3f9 (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,551] INFO Opening socket connection to server localhost/127.0.0.1:2118 (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:19:59,556] INFO Socket connection established to localhost/127.0.0.1:2118, initiating session (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:19:59,580] INFO Session establishment complete on server localhost/127.0.0.1:2118, sessionid = 0x23a5143a21a0001, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:19:59,582] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient) [2012-10-11 12:19:59,590] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c-leader-finder-thread], Starting (kafka.consumer.ConsumerFetcherManager$$anon$1) [2012-10-11 12:19:59,590] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], starting auto committer every 120000 ms (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:19:59,629] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], begin registering consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c in ZK (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:19:59,689] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], end registering consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c in ZK (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:19:59,694] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], starting watcher executor thread for consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:19:59,723] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], begin rebalancing consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c try #0 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:19:59,737] INFO Constructing topic count for mm_regtest_grp_jfung-ld-1349983199520-e644b02c from *1*.* using \*(\p{Digit}+)\*(.*) as pattern. (kafka.consumer.TopicCount$) [2012-10-11 12:19:59,741] INFO Constructing topic count for mm_regtest_grp_jfung-ld-1349983199520-e644b02c from *1*.* using \*(\p{Digit}+)\*(.*) as pattern. (kafka.consumer.TopicCount$) [2012-10-11 12:19:59,785] INFO Fetching metadata for topic Set() (kafka.utils.Utils$) [2012-10-11 12:19:59,787] INFO Connected to 127.0.0.1:9091 for producing (kafka.producer.SyncProducer) [2012-10-11 12:19:59,842] INFO Disconnecting from 127.0.0.1:9091 (kafka.producer.SyncProducer) [2012-10-11 12:19:59,850] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Cleared all relevant queues for this fetcher (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:19:59,851] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Cleared the data chunks in all the consumer message iterators (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:19:59,852] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Committing all offsets after clearing the fetcher queues (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:19:59,852] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Releasing partition ownership (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:19:59,855] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Updating the cache (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:19:59,857] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c selected partitions : (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:19:59,859] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], end rebalancing consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c try #0 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:19:59,859] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Creating topic event watcher for whitelist .* (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:19:59,860] INFO Initiating client connection, connectString=localhost:2108,localhost:2118 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@343aff84 (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:19:59,860] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread) [2012-10-11 12:19:59,861] INFO Opening socket connection to server localhost/127.0.0.1:2118 (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:19:59,862] INFO Socket connection established to localhost/127.0.0.1:2118, initiating session (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:19:59,868] INFO Session establishment complete on server localhost/127.0.0.1:2118, sessionid = 0x23a5143a21a0002, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:19:59,868] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient) [2012-10-11 12:19:59,875] INFO Fetching metadata for topic Set() (kafka.utils.Utils$) [2012-10-11 12:19:59,876] INFO Connected to 127.0.0.1:9091 for producing (kafka.producer.SyncProducer) [2012-10-11 12:19:59,878] INFO Disconnecting from 127.0.0.1:9091 (kafka.producer.SyncProducer) [2012-10-11 12:20:00,006] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Topics to consume = List() (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:11,011] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Topic event: added topics = List(test_1) (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:11,011] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Topics to consume = List(test_1) (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:11,027] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], begin rebalancing consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c try #0 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:11,031] INFO Constructing topic count for mm_regtest_grp_jfung-ld-1349983199520-e644b02c from *1*.* using \*(\p{Digit}+)\*(.*) as pattern. (kafka.consumer.TopicCount$) [2012-10-11 12:20:11,033] INFO Constructing topic count for mm_regtest_grp_jfung-ld-1349983199520-e644b02c from *1*.* using \*(\p{Digit}+)\*(.*) as pattern. (kafka.consumer.TopicCount$) [2012-10-11 12:20:11,038] INFO Fetching metadata for topic Set(test_1) (kafka.utils.Utils$) [2012-10-11 12:20:11,038] INFO Connected to 127.0.0.1:9091 for producing (kafka.producer.SyncProducer) [2012-10-11 12:20:11,122] INFO Disconnecting from 127.0.0.1:9091 (kafka.producer.SyncProducer) [2012-10-11 12:20:11,123] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Cleared all relevant queues for this fetcher (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:11,124] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:11,124] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Cleared the data chunks in all the consumer message iterators (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:11,124] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Committing all offsets after clearing the fetcher queues (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:11,124] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Releasing partition ownership (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:11,125] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c rebalancing the following partitions: ListBuffer(0) for topic test_1 with consumers: List(mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0) (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:11,127] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:11,128] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], exception during rebalance (kafka.consumer.ZookeeperConsumerConnector) kafka.common.NoBrokersForPartitionException: No leader available for partition 0 on topic test_1 at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$addPartitionTopicInfo(ZookeeperConsumerConnector.scala:599) at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11$$anonfun$apply$13.apply(ZookeeperConsumerConnector.scala:474) at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11$$anonfun$apply$13.apply(ZookeeperConsumerConnector.scala:471) at scala.collection.immutable.Range$ByOne$class.foreach(Range.scala:285) at scala.collection.immutable.Range$$anon$2.foreach(Range.scala:265) at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11.apply(ZookeeperConsumerConnector.scala:471) at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11.apply(ZookeeperConsumerConnector.scala:458) at scala.collection.mutable.HashSet.foreach(HashSet.scala:61) at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2.apply(ZookeeperConsumerConnector.scala:458) at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2.apply(ZookeeperConsumerConnector.scala:445) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:80) at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:80) at scala.collection.Iterator$class.foreach(Iterator.scala:631) at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:161) at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:194) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:39) at scala.collection.mutable.HashMap.foreach(HashMap.scala:80) at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:445) at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:388) at scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282) at scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265) at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:383) at kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:713) at kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.handleTopicEvent(ZookeeperConsumerConnector.scala:783) at kafka.consumer.ZookeeperTopicEventWatcher$ZkTopicEventListener.liftedTree1$1(ZookeeperTopicEventWatcher.scala:74) at kafka.consumer.ZookeeperTopicEventWatcher$ZkTopicEventListener.handleChildChange(ZookeeperTopicEventWatcher.scala:69) at org.I0Itec.zkclient.ZkClient$7.run(ZkClient.java:568) at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71) [2012-10-11 12:20:11,130] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], end rebalancing consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c try #0 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:11,130] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Rebalancing attempt failed. Clearing the cache before the next rebalancing operation is triggered (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:11,130] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Cleared all relevant queues for this fetcher (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:11,131] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:11,131] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Cleared the data chunks in all the consumer message iterators (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:11,131] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Committing all offsets after clearing the fetcher queues (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,131] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], begin rebalancing consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c try #1 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,136] INFO Constructing topic count for mm_regtest_grp_jfung-ld-1349983199520-e644b02c from *1*.* using \*(\p{Digit}+)\*(.*) as pattern. (kafka.consumer.TopicCount$) [2012-10-11 12:20:26,139] INFO Constructing topic count for mm_regtest_grp_jfung-ld-1349983199520-e644b02c from *1*.* using \*(\p{Digit}+)\*(.*) as pattern. (kafka.consumer.TopicCount$) [2012-10-11 12:20:26,144] INFO Fetching metadata for topic Set(test_1) (kafka.utils.Utils$) [2012-10-11 12:20:26,144] INFO Connected to 127.0.0.1:9091 for producing (kafka.producer.SyncProducer) [2012-10-11 12:20:26,168] INFO Disconnecting from 127.0.0.1:9091 (kafka.producer.SyncProducer) [2012-10-11 12:20:26,169] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Cleared all relevant queues for this fetcher (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,169] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,169] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Cleared the data chunks in all the consumer message iterators (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,169] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Committing all offsets after clearing the fetcher queues (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,170] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Releasing partition ownership (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,170] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c rebalancing the following partitions: ListBuffer(0) for topic test_1 with consumers: List(mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0) (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,170] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,243] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0 successfully owned partition 0 for topic test_1 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,243] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Updating the cache (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,244] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c selected partitions : test_1:0: fetched offset = 0: consumed offset = 0 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,244] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], end rebalancing consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c try #1 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,245] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], begin rebalancing consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c try #0 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,248] INFO Fetching metadata for topic Set(test_1) (kafka.utils.Utils$) [2012-10-11 12:20:26,249] INFO Constructing topic count for mm_regtest_grp_jfung-ld-1349983199520-e644b02c from *1*.* using \*(\p{Digit}+)\*(.*) as pattern. (kafka.consumer.TopicCount$) [2012-10-11 12:20:26,296] INFO Connected to 127.0.0.1:9091 for producing (kafka.producer.SyncProducer) [2012-10-11 12:20:26,298] INFO Constructing topic count for mm_regtest_grp_jfung-ld-1349983199520-e644b02c from *1*.* using \*(\p{Digit}+)\*(.*) as pattern. (kafka.consumer.TopicCount$) [2012-10-11 12:20:26,301] INFO Fetching metadata for topic Set(test_1) (kafka.utils.Utils$) [2012-10-11 12:20:26,302] INFO Connected to 127.0.0.1:9091 for producing (kafka.producer.SyncProducer) [2012-10-11 12:20:26,315] INFO Disconnecting from 127.0.0.1:9091 (kafka.producer.SyncProducer) [2012-10-11 12:20:26,325] INFO Disconnecting from 127.0.0.1:9091 (kafka.producer.SyncProducer) [2012-10-11 12:20:26,345] INFO [ConsumerFetcherThread-mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0-1], Starting (kafka.consumer.ConsumerFetcherThread) [2012-10-11 12:20:26,345] INFO [ConsumerFetcherManager-1349983199587], adding fetcher on topic test_1, partion 0, initOffset 0 to broker 1 with fetcherId 0 (kafka.consumer.ConsumerFetcherManager) [2012-10-11 12:20:26,346] INFO [ConsumerFetcherThread-mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0-1], Shutting down (kafka.consumer.ConsumerFetcherThread) [2012-10-11 12:20:26,365] INFO [ConsumerFetcherThread-mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0-1], Stopped (kafka.consumer.ConsumerFetcherThread) [2012-10-11 12:20:26,365] INFO [ConsumerFetcherThread-mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0-1], Shutdown completed (kafka.consumer.ConsumerFetcherThread) [2012-10-11 12:20:26,365] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Cleared all relevant queues for this fetcher (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,366] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,366] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Cleared the data chunks in all the consumer message iterators (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,366] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Committing all offsets after clearing the fetcher queues (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,407] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Releasing partition ownership (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,427] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c rebalancing the following partitions: ListBuffer(0) for topic test_1 with consumers: List(mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0) (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,427] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,434] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0 successfully owned partition 0 for topic test_1 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,434] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Updating the cache (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,435] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], Consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c selected partitions : test_1:0: fetched offset = 0: consumed offset = 0 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,435] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], end rebalancing consumer mm_regtest_grp_jfung-ld-1349983199520-e644b02c try #0 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:26,550] INFO Fetching metadata for topic Set(test_1) (kafka.utils.Utils$) [2012-10-11 12:20:26,550] INFO Connected to 127.0.0.1:9091 for producing (kafka.producer.SyncProducer) [2012-10-11 12:20:26,571] INFO Disconnecting from 127.0.0.1:9091 (kafka.producer.SyncProducer) [2012-10-11 12:20:26,572] INFO [ConsumerFetcherManager-1349983199587], adding fetcher on topic test_1, partion 0, initOffset 0 to broker 1 with fetcherId 0 (kafka.consumer.ConsumerFetcherManager) [2012-10-11 12:20:26,572] INFO [ConsumerFetcherThread-mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0-1], Starting (kafka.consumer.ConsumerFetcherThread) [2012-10-11 12:20:26,609] TRACE Setting test_1 consumed offset to 1 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,617] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3968775010, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,618] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,618] TRACE Setting test_1 consumed offset to 2 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,619] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2074178430, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,619] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,619] TRACE Setting test_1 consumed offset to 3 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,620] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1663889063, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,620] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,620] TRACE Setting test_1 consumed offset to 4 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,621] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2803454828, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,621] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,621] TRACE Setting test_1 consumed offset to 5 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,622] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 683347625, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,622] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,622] TRACE Setting test_1 consumed offset to 6 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,623] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2105181845, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,623] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,623] TRACE Setting test_1 consumed offset to 7 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,624] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 778107714, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,624] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,624] TRACE Setting test_1 consumed offset to 8 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,625] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2713888391, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,625] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,625] TRACE Setting test_1 consumed offset to 9 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,626] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3931457161, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,626] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,626] TRACE Setting test_1 consumed offset to 10 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,627] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1710693196, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,627] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,627] TRACE Setting test_1 consumed offset to 11 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,628] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1981192360, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,628] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,628] TRACE Setting test_1 consumed offset to 12 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,629] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2863577274, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,629] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,629] TRACE Setting test_1 consumed offset to 13 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,629] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 621602175, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,629] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,629] TRACE Setting test_1 consumed offset to 14 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,630] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3778631860, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,630] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,630] TRACE Setting test_1 consumed offset to 15 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,630] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1855653233, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,631] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,631] TRACE Setting test_1 consumed offset to 16 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,631] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2893368657, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,631] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,631] TRACE Setting test_1 consumed offset to 17 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,632] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 601297044, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,632] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,632] TRACE Setting test_1 consumed offset to 18 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,632] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1892511043, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,632] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,633] TRACE Setting test_1 consumed offset to 19 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,633] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3890392415, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,633] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,633] TRACE Setting test_1 consumed offset to 20 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,633] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1749086362, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,634] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,634] TRACE Setting test_1 consumed offset to 21 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,634] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3161883840, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,634] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,634] TRACE Setting test_1 consumed offset to 22 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,635] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 869587205, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,643] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,643] TRACE Setting test_1 consumed offset to 23 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,644] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1624155346, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,644] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,644] TRACE Setting test_1 consumed offset to 24 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,645] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2017671435, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,645] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,645] TRACE Setting test_1 consumed offset to 25 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,646] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4158743758, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,646] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,646] TRACE Setting test_1 consumed offset to 26 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,647] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1712673081, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,647] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,647] TRACE Setting test_1 consumed offset to 27 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,648] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3131928875, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,648] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,648] TRACE Setting test_1 consumed offset to 28 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,649] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 890186990, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,649] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,649] TRACE Setting test_1 consumed offset to 29 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,650] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2123943136, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,650] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,650] TRACE Setting test_1 consumed offset to 30 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,650] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4047147301, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,650] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,650] TRACE Setting test_1 consumed offset to 31 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,651] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1836666628, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,651] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,651] TRACE Setting test_1 consumed offset to 32 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,651] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2982244118, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,652] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,652] TRACE Setting test_1 consumed offset to 33 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,652] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1046688467, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,652] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,652] TRACE Setting test_1 consumed offset to 34 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,653] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1978979037, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,653] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,653] TRACE Setting test_1 consumed offset to 35 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,653] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4199976728, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,654] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,654] TRACE Setting test_1 consumed offset to 36 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,654] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1805826799, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,654] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,654] TRACE Setting test_1 consumed offset to 37 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,655] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3071974141, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,655] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,655] TRACE Setting test_1 consumed offset to 38 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,655] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 951633720, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,655] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,656] TRACE Setting test_1 consumed offset to 39 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,656] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1932470070, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,656] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,656] TRACE Setting test_1 consumed offset to 40 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,656] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4237130483, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,657] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,657] TRACE Setting test_1 consumed offset to 41 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,657] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1300159526, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,657] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,657] TRACE Setting test_1 consumed offset to 42 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,658] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2445737012, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,658] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,658] TRACE Setting test_1 consumed offset to 43 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,658] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 509911537, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,659] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,659] TRACE Setting test_1 consumed offset to 44 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,659] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3662748730, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,659] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,659] TRACE Setting test_1 consumed offset to 45 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,660] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1442005503, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,660] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,660] TRACE Setting test_1 consumed offset to 46 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,660] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1269115341, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,660] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,661] TRACE Setting test_1 consumed offset to 47 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,661] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2535262687, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,661] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,661] TRACE Setting test_1 consumed offset to 48 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,661] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 415192090, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,662] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,662] TRACE Setting test_1 consumed offset to 49 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,662] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1395176468, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,662] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,662] TRACE Setting test_1 consumed offset to 50 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,663] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3700091345, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,663] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,663] TRACE Setting test_1 consumed offset to 51 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,663] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1283429243, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,663] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,664] TRACE Setting test_1 consumed offset to 52 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,664] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2429006697, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,664] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,664] TRACE Setting test_1 consumed offset to 53 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,665] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 526773932, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,665] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,665] TRACE Setting test_1 consumed offset to 54 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,665] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1425149602, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,665] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,665] TRACE Setting test_1 consumed offset to 55 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,666] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3679474535, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,666] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,666] TRACE Setting test_1 consumed offset to 56 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,666] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1252288144, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,667] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,667] TRACE Setting test_1 consumed offset to 57 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,667] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2518435458, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,667] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,667] TRACE Setting test_1 consumed offset to 58 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,668] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1378483017, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,668] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,668] TRACE Setting test_1 consumed offset to 59 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,668] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 431889223, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,668] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,669] TRACE Setting test_1 consumed offset to 60 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,669] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3716916876, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,669] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,669] TRACE Setting test_1 consumed offset to 61 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,697] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1103657133, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,697] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,697] TRACE Setting test_1 consumed offset to 62 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,697] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2641385663, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,698] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,698] TRACE Setting test_1 consumed offset to 63 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,698] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1497752948, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,698] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,698] TRACE Setting test_1 consumed offset to 64 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,699] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 315753850, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,699] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,699] TRACE Setting test_1 consumed offset to 65 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,699] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3605510321, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,699] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,700] TRACE Setting test_1 consumed offset to 66 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,700] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1604194463, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,700] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,700] TRACE Setting test_1 consumed offset to 67 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,701] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2611719508, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,701] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,701] TRACE Setting test_1 consumed offset to 68 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,701] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 336195729, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,701] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,701] TRACE Setting test_1 consumed offset to 69 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,702] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3493612890, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,702] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,702] TRACE Setting test_1 consumed offset to 70 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,702] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1192463686, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,703] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,703] TRACE Setting test_1 consumed offset to 71 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,703] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1335744782, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,703] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,703] TRACE Setting test_1 consumed offset to 72 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,704] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2343068869, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,704] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,704] TRACE Setting test_1 consumed offset to 73 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,704] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 67778816, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,704] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,705] TRACE Setting test_1 consumed offset to 74 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,705] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3225388235, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,705] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,705] TRACE Setting test_1 consumed offset to 75 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,706] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1460683991, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,706] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,706] TRACE Setting test_1 consumed offset to 76 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,706] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1229335781, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,706] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,707] TRACE Setting test_1 consumed offset to 77 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,707] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 47303915, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,707] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,707] TRACE Setting test_1 consumed offset to 78 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,708] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2373161262, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,708] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,708] TRACE Setting test_1 consumed offset to 79 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,708] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3336859936, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,709] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,709] TRACE Setting test_1 consumed offset to 80 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,709] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1372303676, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,709] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,710] TRACE Setting test_1 consumed offset to 81 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,710] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1110061784, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,710] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,710] TRACE Setting test_1 consumed offset to 82 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,711] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 163435222, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,711] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,711] TRACE Setting test_1 consumed offset to 83 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,711] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3448270621, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,711] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,712] TRACE Setting test_1 consumed offset to 84 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,712] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2250215187, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,712] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,712] TRACE Setting test_1 consumed offset to 85 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,713] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1520938753, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,713] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,713] TRACE Setting test_1 consumed offset to 86 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,713] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3411254006, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,713] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,714] TRACE Setting test_1 consumed offset to 87 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,714] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1156695859, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,714] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,714] TRACE Setting test_1 consumed offset to 88 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,714] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 258352957, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,715] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,715] TRACE Setting test_1 consumed offset to 89 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,715] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2160360184, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,715] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,715] TRACE Setting test_1 consumed offset to 90 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,716] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1551653610, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,716] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,716] TRACE Setting test_1 consumed offset to 91 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,716] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3985636415, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,716] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,716] TRACE Setting test_1 consumed offset to 92 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,717] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1647157754, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,717] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,717] TRACE Setting test_1 consumed offset to 93 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,717] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 700072436, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,717] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,718] TRACE Setting test_1 consumed offset to 94 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,718] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2786597937, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,718] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:26,718] TRACE Setting test_1 consumed offset to 95 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:26,718] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2057321507, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:26,719] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:27,086] TRACE Setting test_1 consumed offset to 96 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:27,087] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3948153300, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:27,087] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:27,087] TRACE Setting test_1 consumed offset to 97 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:27,088] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1693864977, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:27,088] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:27,088] TRACE Setting test_1 consumed offset to 98 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:27,088] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 794932255, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:27,089] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:27,089] TRACE Setting test_1 consumed offset to 99 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:27,089] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2697193946, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:27,089] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:27,089] TRACE Setting test_1 consumed offset to 100 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:27,090] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2088487368, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:27,090] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:29,513] INFO Fetching metadata for topic Set(test_1) (kafka.utils.Utils$) [2012-10-11 12:20:29,514] INFO Connected to localhost:9094 for producing (kafka.producer.SyncProducer) [2012-10-11 12:20:29,574] INFO Disconnecting from localhost:9094 (kafka.producer.SyncProducer) [2012-10-11 12:20:29,594] INFO Connected to 127.0.0.1:9094 for producing (kafka.producer.SyncProducer) [2012-10-11 12:20:29,599] TRACE Setting test_1 consumed offset to 101 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:29,599] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3611588867, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:29,600] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:20:29,600] TRACE Setting test_1 consumed offset to 102 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:29,600] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2631112973, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:29,600] TRACE Remaining queue size: 9998 (kafka.producer.Producer) [2012-10-11 12:20:29,600] TRACE Setting test_1 consumed offset to 103 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:29,601] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1491477702, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:29,601] TRACE Remaining queue size: 9997 (kafka.producer.Producer) [2012-10-11 12:20:29,601] TRACE Setting test_1 consumed offset to 104 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:29,602] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 201087249, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:29,602] TRACE Remaining queue size: 9996 (kafka.producer.Producer) [2012-10-11 12:20:29,602] TRACE Setting test_1 consumed offset to 105 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:29,602] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 326223048, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:29,602] TRACE Remaining queue size: 9995 (kafka.producer.Producer) [2012-10-11 12:20:30,103] TRACE Setting test_1 consumed offset to 106 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:30,103] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1581109549, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:30,104] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:30,104] TRACE Setting test_1 consumed offset to 107 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:30,104] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2584243430, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:30,104] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:30,105] TRACE Setting test_1 consumed offset to 108 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:30,105] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3516894440, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:30,105] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:30,109] TRACE Setting test_1 consumed offset to 109 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:30,110] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 220703994, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:30,110] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:30,110] TRACE Setting test_1 consumed offset to 110 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:30,111] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 363475235, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:30,111] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:30,607] TRACE Setting test_1 consumed offset to 111 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:30,608] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2439279323, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:30,608] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:30,610] TRACE Setting test_1 consumed offset to 112 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:30,610] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3673395925, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:30,611] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:30,611] TRACE Setting test_1 consumed offset to 113 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:30,619] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1431424784, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:30,620] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:30,621] TRACE Setting test_1 consumed offset to 114 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:30,622] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 105624263, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:30,622] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:30,622] TRACE Setting test_1 consumed offset to 115 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:30,623] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 516304670, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:30,623] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:31,111] TRACE Setting test_1 consumed offset to 116 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:31,111] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2545911600, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:31,112] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:31,112] TRACE Setting test_1 consumed offset to 117 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:31,112] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1401567995, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:31,112] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:31,158] TRACE Setting test_1 consumed offset to 118 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:31,158] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3693635390, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:31,158] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:31,159] TRACE Setting test_1 consumed offset to 119 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:31,159] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 404609781, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:31,159] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:31,159] TRACE Setting test_1 consumed offset to 120 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:31,160] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 9455404, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:31,160] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:31,701] TRACE Setting test_1 consumed offset to 121 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:31,702] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1133114218, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:31,702] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:31,702] TRACE Setting test_1 consumed offset to 122 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:31,702] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2277265057, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:31,702] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:31,703] TRACE Setting test_1 consumed offset to 123 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:31,703] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 136188772, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:31,703] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:31,703] TRACE Setting test_1 consumed offset to 124 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:31,704] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3425414831, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:31,704] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:31,704] TRACE Setting test_1 consumed offset to 125 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:31,704] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 278105789, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:31,705] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:32,205] TRACE Setting test_1 consumed offset to 126 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:32,206] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2171059018, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:32,206] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:32,206] TRACE Setting test_1 consumed offset to 127 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:32,206] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1163003521, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:32,206] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:32,207] TRACE Setting test_1 consumed offset to 128 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:32,207] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3404749636, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:32,207] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:32,211] TRACE Setting test_1 consumed offset to 129 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:32,211] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 373848918, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:32,211] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:32,211] TRACE Setting test_1 consumed offset to 130 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:32,212] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 247850639, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:32,212] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:32,708] TRACE Setting test_1 consumed offset to 131 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:32,709] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1312692412, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:32,709] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:32,709] TRACE Setting test_1 consumed offset to 132 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:32,709] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2316019063, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:32,709] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:32,714] TRACE Setting test_1 consumed offset to 133 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:32,715] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3248244089, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:32,715] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:32,715] TRACE Setting test_1 consumed offset to 134 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:32,715] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 95025330, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:32,716] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:32,716] TRACE Setting test_1 consumed offset to 135 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:32,716] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 488924523, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:32,716] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:32,720] TRACE Setting test_1 consumed offset to 136 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:32,721] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2362462364, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:32,721] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:20:32,721] TRACE Setting test_1 consumed offset to 137 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:32,722] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1223028055, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:32,722] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:33,218] TRACE Setting test_1 consumed offset to 138 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:33,218] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3343364242, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:33,218] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:33,219] TRACE Setting test_1 consumed offset to 139 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:33,219] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 469733504, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:33,219] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:33,219] TRACE Setting test_1 consumed offset to 140 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:33,220] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 57806169, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:33,220] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:33,809] TRACE Setting test_1 consumed offset to 141 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:33,810] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1849265054, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:33,810] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:33,810] TRACE Setting test_1 consumed offset to 142 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:33,810] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2852927061, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:33,810] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:33,811] TRACE Setting test_1 consumed offset to 143 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:33,811] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3785086555, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:33,811] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:20:33,811] TRACE Setting test_1 consumed offset to 144 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:33,812] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1025766985, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:33,812] TRACE Remaining queue size: 9998 (kafka.producer.Producer) [2012-10-11 12:20:33,812] TRACE Setting test_1 consumed offset to 145 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:33,812] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 632187792, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:33,812] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:34,313] TRACE Setting test_1 consumed offset to 146 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:34,314] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2899821502, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:34,314] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:34,314] TRACE Setting test_1 consumed offset to 147 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:34,314] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1759673973, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:34,314] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:34,314] TRACE Setting test_1 consumed offset to 148 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:34,315] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1006109602, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:34,315] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:34,315] TRACE Setting test_1 consumed offset to 149 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:34,315] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 594910843, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:34,316] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:34,318] TRACE Setting test_1 consumed offset to 150 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:34,318] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3879740336, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:34,318] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:34,819] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], ZKConsumerConnector shutting down (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:34,819] INFO Shutting down topic event watcher. (kafka.consumer.ZookeeperTopicEventWatcher) [2012-10-11 12:20:34,819] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread) [2012-10-11 12:20:34,823] TRACE Setting test_1 consumed offset to 151 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:34,823] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1865991363, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:34,823] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:34,823] TRACE Setting test_1 consumed offset to 152 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:34,824] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2869786888, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:34,824] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:34,824] TRACE Setting test_1 consumed offset to 153 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:34,825] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 615457997, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:34,825] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:34,825] TRACE Setting test_1 consumed offset to 154 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:34,825] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1008908564, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:34,825] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:34,826] TRACE Setting test_1 consumed offset to 155 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:34,826] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3768228102, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:34,826] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:34,839] INFO Session: 0x23a5143a21a0002 closed (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:34,839] INFO EventThread shut down (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:20:34,872] INFO Forcing shutdown of Kafka scheduler (kafka.utils.KafkaScheduler) [2012-10-11 12:20:34,873] INFO [ConsumerFetcherManager-1349983199587], shutting down (kafka.consumer.ConsumerFetcherManager) [2012-10-11 12:20:34,873] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c-leader-finder-thread], Shutting down (kafka.consumer.ConsumerFetcherManager$$anon$1) [2012-10-11 12:20:34,873] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c-leader-finder-thread], Stopped (kafka.consumer.ConsumerFetcherManager$$anon$1) [2012-10-11 12:20:34,873] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c-leader-finder-thread], Shutdown completed (kafka.consumer.ConsumerFetcherManager$$anon$1) [2012-10-11 12:20:34,874] INFO [ConsumerFetcherThread-mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0-1], Shutting down (kafka.consumer.ConsumerFetcherThread) [2012-10-11 12:20:34,928] INFO Reconnect due to socket error: (kafka.consumer.SimpleConsumer) java.nio.channels.ClosedByInterruptException at java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:184) at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:270) at sun.nio.ch.SocketAdaptor$SocketInputStream.read(SocketAdaptor.java:195) at sun.nio.ch.ChannelInputStream.read(ChannelInputStream.java:86) at java.nio.channels.Channels$ReadableByteChannelImpl.read(Channels.java:221) at kafka.utils.Utils$.read(Utils.scala:455) at kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54) at kafka.network.Receive$class.readCompletely(Transmission.scala:56) at kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29) at kafka.network.BlockingChannel.receive(BlockingChannel.scala:92) at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:69) at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:67) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:103) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:103) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:103) at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:102) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:82) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:50) [2012-10-11 12:20:34,929] INFO [ConsumerFetcherThread-mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0-1], Stopped (kafka.consumer.ConsumerFetcherThread) [2012-10-11 12:20:34,929] INFO [ConsumerFetcherThread-mm_regtest_grp_jfung-ld-1349983199520-e644b02c-0-1], Shutdown completed (kafka.consumer.ConsumerFetcherThread) [2012-10-11 12:20:34,930] INFO [ConsumerFetcherManager-1349983199587], shutdown completed (kafka.consumer.ConsumerFetcherManager) [2012-10-11 12:20:34,931] DEBUG Received the shutdown command (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:34,932] INFO Stopped thread mirrormaker-0. (kafka.tools.MirrorMaker$MirrorMakerThread) [2012-10-11 12:20:35,117] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread) [2012-10-11 12:20:35,145] INFO Session: 0x23a5143a21a0001 closed (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,145] INFO EventThread shut down (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:20:35,145] INFO [mm_regtest_grp_jfung-ld-1349983199520-e644b02c], ZKConsumerConnector shut down completed (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:35,146] INFO Shutting down producer (kafka.producer.Producer) [2012-10-11 12:20:35,147] INFO Beging shutting down ProducerSendThread (kafka.producer.async.ProducerSendThread) [2012-10-11 12:20:35,148] INFO Shutdown ProducerSendThread complete (kafka.producer.async.ProducerSendThread) [2012-10-11 12:20:35,148] INFO Closing all sync producers (kafka.producer.ProducerPool) [2012-10-11 12:20:35,151] INFO Disconnecting from 127.0.0.1:9094 (kafka.producer.SyncProducer) [2012-10-11 12:20:35,796] INFO Starting mirror maker (kafka.tools.MirrorMaker$) [2012-10-11 12:20:35,837] INFO Verifying properties (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,838] INFO Property broker.list is overridden to localhost:9094,localhost:9095,localhost:9096 (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,838] INFO Property compression.codec is overridden to 0 (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,838] INFO Property producer.type is overridden to async (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,838] INFO Property queue.enqueueTimeout.ms is overridden to -1 (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,887] INFO Verifying properties (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,890] INFO Property zk.connect is overridden to localhost:2108,localhost:2118 (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,890] INFO Property socket.buffersize is overridden to 1048576 (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,890] INFO Property groupid is overridden to mm_regtest_grp (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,891] INFO Property shallowiterator.enable is overridden to true (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,891] INFO Property zk.connectiontimeout.ms is overridden to 1000000 (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,891] INFO Property fetch.size is overridden to 1048576 (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,891] INFO Property autocommit.interval.ms is overridden to 120000 (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,892] INFO Property autooffset.reset is overridden to smallest (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,892] INFO Property zk.synctime.ms is overridden to 15000 (kafka.utils.VerifiableProperties) [2012-10-11 12:20:35,901] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], Connecting to zookeeper instance at localhost:2108,localhost:2118 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:35,910] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread) [2012-10-11 12:20:35,916] INFO Client environment:zookeeper.version=3.3.3-1203054, built on 11/17/2011 05:47 GMT (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,916] INFO Client environment:host.name= (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,916] INFO Client environment:java.version=1.6.0_27 (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,916] INFO Client environment:java.vendor=Sun Microsystems Inc. (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,916] INFO Client environment:java.home=/export/apps/jdk/JDK-1_6_0_27/jre (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,916] INFO Client environment:java.class.path=:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../project/boot/scala-2.8.0/lib/scala-compiler.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../project/boot/scala-2.8.0/lib/scala-library.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/target/scala_2.8.0/kafka-0.8.0.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib/metrics-annotation-3.0.0-10ccc80c.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib/metrics-core-3.0.0-10ccc80c.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib/zkclient-20120522.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../perf/target/scala_2.8.0/kafka-perf-0.8.0.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib_managed/scala_2.8.0/compile/jopt-simple-3.2.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib_managed/scala_2.8.0/compile/log4j-1.2.15.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib_managed/scala_2.8.0/compile/slf4j-api-1.7.1.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib_managed/scala_2.8.0/compile/slf4j-simple-1.7.1.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib_managed/scala_2.8.0/compile/snappy-java-1.0.4.1.jar:/home/jfung/workspace_kafka/kafka_r1397194_557_sanity/bin/../core/lib_managed/scala_2.8.0/compile/zookeeper-3.3.4.jar (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,916] INFO Client environment:java.library.path=/export/apps/jdk/JDK-1_6_0_27/jre/lib/amd64/server:/export/apps/jdk/JDK-1_6_0_27/jre/lib/amd64:/export/apps/jdk/JDK-1_6_0_27/jre/../lib/amd64:/local/instantclient_10_2:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,916] INFO Client environment:java.io.tmpdir=/tmp (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,916] INFO Client environment:java.compiler= (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,916] INFO Client environment:os.name=Linux (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,916] INFO Client environment:os.arch=amd64 (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,916] INFO Client environment:os.version=2.6.32-131.4.1.el6.x86_64 (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,916] INFO Client environment:user.name=jfung (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,916] INFO Client environment:user.home=/home/jfung (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,916] INFO Client environment:user.dir=/home/jfung (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,917] INFO Initiating client connection, connectString=localhost:2108,localhost:2118 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@7ab7b3f9 (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:35,931] INFO Opening socket connection to server localhost/127.0.0.1:2118 (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:20:35,935] INFO Socket connection established to localhost/127.0.0.1:2118, initiating session (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:20:35,950] INFO Session establishment complete on server localhost/127.0.0.1:2118, sessionid = 0x23a5143a21a0004, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:20:35,951] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient) [2012-10-11 12:20:35,958] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de-leader-finder-thread], Starting (kafka.consumer.ConsumerFetcherManager$$anon$1) [2012-10-11 12:20:35,958] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], starting auto committer every 120000 ms (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:35,985] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], begin registering consumer mm_regtest_grp_jfung-ld-1349983235900-ac06a1de in ZK (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,030] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], end registering consumer mm_regtest_grp_jfung-ld-1349983235900-ac06a1de in ZK (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,035] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], starting watcher executor thread for consumer mm_regtest_grp_jfung-ld-1349983235900-ac06a1de (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,075] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], begin rebalancing consumer mm_regtest_grp_jfung-ld-1349983235900-ac06a1de try #0 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,088] INFO Constructing topic count for mm_regtest_grp_jfung-ld-1349983235900-ac06a1de from *1*.* using \*(\p{Digit}+)\*(.*) as pattern. (kafka.consumer.TopicCount$) [2012-10-11 12:20:36,091] INFO Constructing topic count for mm_regtest_grp_jfung-ld-1349983235900-ac06a1de from *1*.* using \*(\p{Digit}+)\*(.*) as pattern. (kafka.consumer.TopicCount$) [2012-10-11 12:20:36,129] INFO Fetching metadata for topic Set(test_1) (kafka.utils.Utils$) [2012-10-11 12:20:36,131] INFO Connected to 127.0.0.1:9091 for producing (kafka.producer.SyncProducer) [2012-10-11 12:20:36,155] INFO Disconnecting from 127.0.0.1:9091 (kafka.producer.SyncProducer) [2012-10-11 12:20:36,163] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], Cleared all relevant queues for this fetcher (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,164] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,164] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], Cleared the data chunks in all the consumer message iterators (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,165] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], Committing all offsets after clearing the fetcher queues (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,165] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], Releasing partition ownership (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,167] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], Consumer mm_regtest_grp_jfung-ld-1349983235900-ac06a1de rebalancing the following partitions: ListBuffer(0) for topic test_1 with consumers: List(mm_regtest_grp_jfung-ld-1349983235900-ac06a1de-0) (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,169] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], mm_regtest_grp_jfung-ld-1349983235900-ac06a1de-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,179] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], mm_regtest_grp_jfung-ld-1349983235900-ac06a1de-0 successfully owned partition 0 for topic test_1 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,180] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], Updating the cache (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,184] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], Consumer mm_regtest_grp_jfung-ld-1349983235900-ac06a1de selected partitions : test_1:0: fetched offset = 155: consumed offset = 155 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,187] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], end rebalancing consumer mm_regtest_grp_jfung-ld-1349983235900-ac06a1de try #0 (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,188] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], Creating topic event watcher for whitelist .* (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,189] INFO Initiating client connection, connectString=localhost:2108,localhost:2118 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@6f7918f0 (org.apache.zookeeper.ZooKeeper) [2012-10-11 12:20:36,190] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread) [2012-10-11 12:20:36,191] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2108 (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:20:36,191] INFO Socket connection established to localhost/0:0:0:0:0:0:0:1:2108, initiating session (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:20:36,191] INFO Fetching metadata for topic Set(test_1) (kafka.utils.Utils$) [2012-10-11 12:20:36,192] INFO Connected to 127.0.0.1:9091 for producing (kafka.producer.SyncProducer) [2012-10-11 12:20:36,199] INFO Session establishment complete on server localhost/0:0:0:0:0:0:0:1:2108, sessionid = 0x13a5143a21b0002, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:20:36,199] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient) [2012-10-11 12:20:36,206] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de], Topics to consume = List(test_1) (kafka.consumer.ZookeeperConsumerConnector) [2012-10-11 12:20:36,209] INFO Disconnecting from 127.0.0.1:9091 (kafka.producer.SyncProducer) [2012-10-11 12:20:36,220] INFO [ConsumerFetcherThread-mm_regtest_grp_jfung-ld-1349983235900-ac06a1de-0-1], Starting (kafka.consumer.ConsumerFetcherThread) [2012-10-11 12:20:36,220] INFO [ConsumerFetcherManager-1349983235956], adding fetcher on topic test_1, partion 0, initOffset 155 to broker 1 with fetcherId 0 (kafka.consumer.ConsumerFetcherManager) [2012-10-11 12:20:36,265] TRACE Setting test_1 consumed offset to 156 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,271] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2916519139, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,272] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,272] TRACE Setting test_1 consumed offset to 157 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,272] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1776496936, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,272] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,273] TRACE Setting test_1 consumed offset to 158 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,273] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 578081062, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,273] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,273] TRACE Setting test_1 consumed offset to 159 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,274] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3863047405, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,274] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,274] TRACE Setting test_1 consumed offset to 160 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,274] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 989416703, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,274] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,275] TRACE Setting test_1 consumed offset to 161 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,275] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1653550869, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,275] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,275] TRACE Setting test_1 consumed offset to 162 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,276] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3979178704, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,276] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,276] TRACE Setting test_1 consumed offset to 163 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,276] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2797245150, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,276] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,277] TRACE Setting test_1 consumed offset to 164 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,277] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 689491739, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,277] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,277] TRACE Setting test_1 consumed offset to 165 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,278] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 831869634, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,278] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,405] TRACE Setting test_1 consumed offset to 166 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,405] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2690737973, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,406] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,406] TRACE Setting test_1 consumed offset to 167 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,407] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1683282686, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,407] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,407] TRACE Setting test_1 consumed offset to 168 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,408] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3958802235, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,408] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,410] TRACE Setting test_1 consumed offset to 169 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,410] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 801323760, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,411] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,411] TRACE Setting test_1 consumed offset to 170 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,411] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 927901481, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,411] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,913] TRACE Setting test_1 consumed offset to 171 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,914] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4227157674, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,914] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,914] TRACE Setting test_1 consumed offset to 172 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,915] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1951863663, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,915] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,915] TRACE Setting test_1 consumed offset to 173 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,916] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2959257252, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,916] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,916] TRACE Setting test_1 consumed offset to 174 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,917] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1069609825, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,917] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:36,917] TRACE Setting test_1 consumed offset to 175 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:36,918] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 659386040, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:36,918] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:37,417] TRACE Setting test_1 consumed offset to 176 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:37,418] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1921836676, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:37,418] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:37,418] TRACE Setting test_1 consumed offset to 177 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:37,419] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3065600847, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:37,446] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:37,446] TRACE Setting test_1 consumed offset to 178 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:37,446] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 563518291, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:37,447] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:37,463] TRACE Setting test_1 consumed offset to 179 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:37,463] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4247698241, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:37,464] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:37,464] TRACE Setting test_1 consumed offset to 180 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:37,464] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 958072458, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:37,464] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:37,973] TRACE Setting test_1 consumed offset to 181 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:37,973] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3184870770, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:37,973] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:20:37,974] TRACE Setting test_1 consumed offset to 182 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:37,974] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 721061230, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:37,974] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:37,975] TRACE Setting test_1 consumed offset to 183 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:37,975] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2044786873, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:37,975] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:37,976] TRACE Setting test_1 consumed offset to 184 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:37,976] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4131562876, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:37,976] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:37,977] TRACE Setting test_1 consumed offset to 185 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:37,977] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 846665911, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:37,977] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:38,476] TRACE Setting test_1 consumed offset to 186 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:38,476] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 740388997, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:38,477] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:38,477] TRACE Setting test_1 consumed offset to 187 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:38,477] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2134576466, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:38,478] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:38,478] TRACE Setting test_1 consumed offset to 188 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:38,478] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4036579479, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:38,478] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:38,481] TRACE Setting test_1 consumed offset to 189 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:38,482] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 883748188, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:38,482] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:38,482] TRACE Setting test_1 consumed offset to 190 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:38,483] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3138302105, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:38,483] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:38,985] TRACE Setting test_1 consumed offset to 191 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:38,986] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3594860126, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:38,986] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:38,986] TRACE Setting test_1 consumed offset to 192 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:38,987] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 184358476, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:38,987] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:38,987] TRACE Setting test_1 consumed offset to 193 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:38,988] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1508338587, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:38,988] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:38,988] TRACE Setting test_1 consumed offset to 194 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:38,989] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2647840336, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:38,989] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:38,989] TRACE Setting test_1 consumed offset to 195 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:38,990] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 309365653, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:38,990] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:39,488] TRACE Setting test_1 consumed offset to 196 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:39,489] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 203875239, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:39,489] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:39,489] TRACE Setting test_1 consumed offset to 197 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:39,490] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3500065717, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:39,490] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:39,490] TRACE Setting test_1 consumed offset to 198 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:39,491] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 346783358, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:39,491] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:39,493] TRACE Setting test_1 consumed offset to 199 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:39,493] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1597808240, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:39,493] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:39,494] TRACE Setting test_1 consumed offset to 200 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:39,494] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2601067451, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:39,494] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:40,883] INFO Fetching metadata for topic Set(test_1) (kafka.utils.Utils$) [2012-10-11 12:20:40,883] INFO Connected to localhost:9094 for producing (kafka.producer.SyncProducer) [2012-10-11 12:20:40,910] INFO Disconnecting from localhost:9094 (kafka.producer.SyncProducer) [2012-10-11 12:20:40,929] INFO Connected to 127.0.0.1:9094 for producing (kafka.producer.SyncProducer) [2012-10-11 12:20:42,001] TRACE Setting test_1 consumed offset to 201 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:42,002] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1201866674, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:42,002] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:42,002] TRACE Setting test_1 consumed offset to 202 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:42,003] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 204793788, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:42,003] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:42,003] TRACE Setting test_1 consumed offset to 203 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:42,003] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2207693433, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:42,003] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:42,003] TRACE Setting test_1 consumed offset to 204 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:42,004] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3355531895, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:42,004] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:42,004] TRACE Setting test_1 consumed offset to 205 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:42,004] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2602248096, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:42,005] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:42,505] TRACE Setting test_1 consumed offset to 206 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:42,506] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 183439959, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:42,506] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:20:42,506] TRACE Setting test_1 consumed offset to 207 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:42,507] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2236436370, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:42,507] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:42,507] TRACE Setting test_1 consumed offset to 208 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:42,507] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1098445401, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:42,508] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:42,511] TRACE Setting test_1 consumed offset to 209 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:42,512] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2646659659, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:42,512] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:42,512] TRACE Setting test_1 consumed offset to 210 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:42,513] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3470438300, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:42,513] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:43,008] TRACE Setting test_1 consumed offset to 211 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:43,008] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2384548271, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:43,009] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:20:43,009] TRACE Setting test_1 consumed offset to 212 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:43,009] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 25365610, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:43,010] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:43,010] TRACE Setting test_1 consumed offset to 213 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:43,010] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1242885220, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:43,011] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:43,014] TRACE Setting test_1 consumed offset to 214 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:43,014] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3317084577, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:43,014] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:43,015] TRACE Setting test_1 consumed offset to 215 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:43,015] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2527906934, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:43,015] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:43,511] TRACE Setting test_1 consumed offset to 216 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:43,511] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 123271553, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:43,511] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:43,512] TRACE Setting test_1 consumed offset to 217 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:43,512] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1288640911, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:43,519] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:43,519] TRACE Setting test_1 consumed offset to 218 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:43,520] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2298127428, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:43,520] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:43,553] TRACE Setting test_1 consumed offset to 219 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:43,554] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2423732637, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:43,554] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:43,554] TRACE Setting test_1 consumed offset to 220 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:43,555] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3278718026, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:43,555] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:44,084] TRACE Setting test_1 consumed offset to 221 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:44,085] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 391852048, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:44,085] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:44,086] TRACE Setting test_1 consumed offset to 222 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:44,086] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1556926494, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:44,086] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:44,087] TRACE Setting test_1 consumed offset to 223 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:44,087] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2566483413, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:44,087] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:44,087] TRACE Setting test_1 consumed offset to 224 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:44,088] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3547237851, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:44,088] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:44,088] TRACE Setting test_1 consumed offset to 225 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:44,089] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2155147276, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:44,089] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:44,588] TRACE Setting test_1 consumed offset to 226 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:44,588] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 293651963, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:44,589] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:20:44,589] TRACE Setting test_1 consumed offset to 227 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:44,589] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1511466485, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:44,590] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:44,590] TRACE Setting test_1 consumed offset to 228 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:44,590] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2653067326, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:44,590] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:44,593] TRACE Setting test_1 consumed offset to 229 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:44,594] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2259617255, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:44,594] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:44,594] TRACE Setting test_1 consumed offset to 230 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:44,594] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3585439792, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:44,595] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:45,091] TRACE Setting test_1 consumed offset to 231 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:45,092] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1367030728, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:45,092] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:45,092] TRACE Setting test_1 consumed offset to 232 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:45,093] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 451730374, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:45,093] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:45,097] TRACE Setting test_1 consumed offset to 233 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:45,098] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2504951299, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:45,098] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:45,098] TRACE Setting test_1 consumed offset to 234 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:45,099] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3738789389, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:45,099] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:45,099] TRACE Setting test_1 consumed offset to 235 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:45,099] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2378374106, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:45,100] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:45,599] TRACE Setting test_1 consumed offset to 236 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:45,600] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1470156323, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:45,600] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:45,600] TRACE Setting test_1 consumed offset to 237 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:45,601] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 473378349, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:45,601] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:20:45,601] TRACE Setting test_1 consumed offset to 238 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:45,602] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2476045288, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:45,602] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:45,602] TRACE Setting test_1 consumed offset to 239 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:45,602] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3624047590, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:45,603] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:45,603] TRACE Setting test_1 consumed offset to 240 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:45,603] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2333666865, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:45,604] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:46,154] TRACE Setting test_1 consumed offset to 241 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:46,155] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1903995114, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:46,155] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:46,155] TRACE Setting test_1 consumed offset to 242 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:46,156] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 988498148, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:46,156] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:46,156] TRACE Setting test_1 consumed offset to 243 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:46,156] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3041465633, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:46,157] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:46,157] TRACE Setting test_1 consumed offset to 244 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:46,157] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4276024623, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:46,158] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:46,158] TRACE Setting test_1 consumed offset to 245 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:46,158] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2915338488, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:46,158] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:46,657] TRACE Setting test_1 consumed offset to 246 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:46,657] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1009827087, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:46,657] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:46,658] TRACE Setting test_1 consumed offset to 247 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:46,658] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2870967571, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:46,658] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:46,658] TRACE Setting test_1 consumed offset to 248 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:46,659] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4161077444, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:46,659] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:46,663] TRACE Setting test_1 consumed offset to 249 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:46,663] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3012747466, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:46,663] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:46,664] TRACE Setting test_1 consumed offset to 250 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:46,664] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2007457025, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:46,664] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:47,160] TRACE Setting test_1 consumed offset to 251 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:47,161] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1005193145, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:47,161] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:47,161] TRACE Setting test_1 consumed offset to 252 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:47,161] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2898642853, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:47,162] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:47,162] TRACE Setting test_1 consumed offset to 253 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:47,162] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4292852338, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:47,162] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:20:47,166] TRACE Setting test_1 consumed offset to 254 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:47,167] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3024640636, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:47,167] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:47,167] TRACE Setting test_1 consumed offset to 255 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:47,168] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1887299511, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:47,168] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:47,688] TRACE Setting test_1 consumed offset to 256 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:47,688] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2854105678, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:47,688] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:47,688] TRACE Setting test_1 consumed offset to 257 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:47,689] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1026683474, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:47,689] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:47,689] TRACE Setting test_1 consumed offset to 258 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:47,689] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4177809305, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:47,690] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:47,690] TRACE Setting test_1 consumed offset to 259 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:47,690] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2996023191, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:47,690] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:47,690] TRACE Setting test_1 consumed offset to 260 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:47,691] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1990595164, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:47,714] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:48,228] TRACE Setting test_1 consumed offset to 261 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:48,229] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 912125039, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:48,229] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:48,229] TRACE Setting test_1 consumed offset to 262 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:48,229] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3120542122, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:48,229] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:48,230] TRACE Setting test_1 consumed offset to 263 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:48,230] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2110393441, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:48,230] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:48,230] TRACE Setting test_1 consumed offset to 264 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:48,230] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2708614259, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:48,230] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:48,234] TRACE Setting test_1 consumed offset to 265 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:48,234] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4066922916, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:48,234] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:48,732] TRACE Setting test_1 consumed offset to 266 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:48,733] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3206825025, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:48,733] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:48,733] TRACE Setting test_1 consumed offset to 267 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:48,733] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2812926360, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:48,733] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:48,734] TRACE Setting test_1 consumed offset to 268 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:48,734] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 814094724, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:48,734] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:48,734] TRACE Setting test_1 consumed offset to 269 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:48,735] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2064775562, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:48,735] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:48,737] TRACE Setting test_1 consumed offset to 270 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:48,738] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4105413711, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:48,738] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:49,240] TRACE Setting test_1 consumed offset to 271 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:49,240] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3081375753, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:49,240] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:49,240] TRACE Setting test_1 consumed offset to 272 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:49,241] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1796354075, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:49,241] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:49,241] TRACE Setting test_1 consumed offset to 273 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:49,242] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2938605008, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:49,242] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:49,242] TRACE Setting test_1 consumed offset to 274 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:49,243] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 545640469, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:49,243] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:49,243] TRACE Setting test_1 consumed offset to 275 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:49,243] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3836767710, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:49,244] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:49,743] TRACE Setting test_1 consumed offset to 276 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:49,743] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 643704318, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:49,743] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:49,744] TRACE Setting test_1 consumed offset to 277 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:49,744] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2977031650, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:49,744] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:49,744] TRACE Setting test_1 consumed offset to 278 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:49,777] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1841939952, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:49,777] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:49,794] TRACE Setting test_1 consumed offset to 279 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:49,795] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2851895355, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:49,795] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:49,795] TRACE Setting test_1 consumed offset to 280 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:49,795] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3798702133, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:49,795] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:50,308] TRACE Setting test_1 consumed offset to 281 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:50,308] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 758266819, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:50,308] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:20:50,308] TRACE Setting test_1 consumed offset to 282 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:50,309] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3122527199, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:50,309] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:50,309] TRACE Setting test_1 consumed offset to 283 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:50,310] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1722145741, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:50,310] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:50,310] TRACE Setting test_1 consumed offset to 284 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:50,310] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2727372294, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:50,310] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:50,311] TRACE Setting test_1 consumed offset to 285 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:50,311] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3909584392, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:50,311] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:50,810] TRACE Setting test_1 consumed offset to 286 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:50,811] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1618882086, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:50,811] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:50,811] TRACE Setting test_1 consumed offset to 287 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:50,811] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 736742952, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:50,812] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:50,812] TRACE Setting test_1 consumed offset to 288 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:50,812] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4024202211, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:50,812] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:50,815] TRACE Setting test_1 consumed offset to 289 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:50,816] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3167096372, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:50,816] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:50,816] TRACE Setting test_1 consumed offset to 290 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:50,816] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2756416493, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:50,816] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:51,313] TRACE Setting test_1 consumed offset to 291 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:51,314] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1185040623, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:51,314] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:51,314] TRACE Setting test_1 consumed offset to 292 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:51,314] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 221620449, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:51,314] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:51,314] TRACE Setting test_1 consumed offset to 293 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:51,315] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3372225834, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:51,315] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:51,318] TRACE Setting test_1 consumed offset to 294 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:51,319] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2585422077, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:51,319] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:51,319] TRACE Setting test_1 consumed offset to 295 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:51,319] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2190996772, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:51,319] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:51,817] TRACE Setting test_1 consumed offset to 296 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:51,817] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 200170762, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:51,817] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:51,817] TRACE Setting test_1 consumed offset to 297 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:51,818] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1081720068, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:51,818] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:51,818] TRACE Setting test_1 consumed offset to 298 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:51,818] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3487293633, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:51,819] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:20:51,821] TRACE Setting test_1 consumed offset to 299 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:51,822] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2629934358, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:51,822] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:51,822] TRACE Setting test_1 consumed offset to 300 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:51,823] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2219573455, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:51,823] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:54,331] TRACE Setting test_1 consumed offset to 301 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:54,331] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3947236815, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:54,332] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:54,332] TRACE Setting test_1 consumed offset to 302 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:54,332] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4090204182, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:54,332] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:54,333] TRACE Setting test_1 consumed offset to 303 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:54,333] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3093065752, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:54,333] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:54,333] TRACE Setting test_1 consumed offset to 304 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:54,334] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2087308755, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:54,334] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:54,334] TRACE Setting test_1 consumed offset to 305 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:54,334] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 939404765, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:54,334] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:54,834] TRACE Setting test_1 consumed offset to 306 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:54,835] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3196552691, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:54,835] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:54,835] TRACE Setting test_1 consumed offset to 307 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:54,836] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4111492605, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:54,836] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:54,836] TRACE Setting test_1 consumed offset to 308 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:54,836] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 824563766, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:54,836] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:54,840] TRACE Setting test_1 consumed offset to 309 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:54,879] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3986552868, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:54,879] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:54,879] TRACE Setting test_1 consumed offset to 310 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:54,879] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2058500152, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:54,880] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:55,338] TRACE Setting test_1 consumed offset to 311 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:55,338] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4269571008, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:55,338] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:55,339] TRACE Setting test_1 consumed offset to 312 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:55,339] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 977913355, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:55,339] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:55,339] TRACE Setting test_1 consumed offset to 313 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:55,340] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3052116942, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:55,340] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:55,343] TRACE Setting test_1 consumed offset to 314 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:55,343] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1910384133, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:55,343] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:55,343] TRACE Setting test_1 consumed offset to 315 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:55,344] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3874612761, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:55,344] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:55,844] TRACE Setting test_1 consumed offset to 316 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:55,845] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1016214496, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:55,845] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:20:55,845] TRACE Setting test_1 consumed offset to 317 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:55,845] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4171730475, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:55,846] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:55,846] TRACE Setting test_1 consumed offset to 318 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:55,846] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3006295589, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:55,846] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:55,846] TRACE Setting test_1 consumed offset to 319 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:55,847] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3760854002, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:55,847] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:55,847] TRACE Setting test_1 consumed offset to 320 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:55,848] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1996870638, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:55,848] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:56,378] TRACE Setting test_1 consumed offset to 321 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:56,379] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 747764337, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:56,379] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:56,379] TRACE Setting test_1 consumed offset to 322 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:56,379] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3903080378, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:56,380] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:56,380] TRACE Setting test_1 consumed offset to 323 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:56,380] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4029274723, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:56,380] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:56,384] TRACE Setting test_1 consumed offset to 324 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:56,384] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2738071476, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:56,384] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:56,385] TRACE Setting test_1 consumed offset to 325 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:56,385] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1728453247, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:56,385] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:56,882] TRACE Setting test_1 consumed offset to 326 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:56,882] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4001346129, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:56,882] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:20:56,882] TRACE Setting test_1 consumed offset to 327 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:56,883] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4143067016, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:56,883] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:56,883] TRACE Setting test_1 consumed offset to 328 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:56,883] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 709496730, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:56,889] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:56,891] TRACE Setting test_1 consumed offset to 329 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:56,891] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2783466079, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:56,891] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:56,892] TRACE Setting test_1 consumed offset to 330 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:56,892] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1641934740, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:56,892] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:57,393] TRACE Setting test_1 consumed offset to 331 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:57,394] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4255003061, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:57,394] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:20:57,394] TRACE Setting test_1 consumed offset to 332 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:57,395] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 556143015, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:57,395] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:57,395] TRACE Setting test_1 consumed offset to 333 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:57,395] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3843271788, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:57,395] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:57,396] TRACE Setting test_1 consumed offset to 334 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:57,396] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2927905890, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:57,396] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:57,396] TRACE Setting test_1 consumed offset to 335 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:57,397] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1790046633, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:57,397] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:57,897] TRACE Setting test_1 consumed offset to 336 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:57,897] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4215653470, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:57,897] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:57,897] TRACE Setting test_1 consumed offset to 337 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:57,898] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3821558151, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:57,898] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:57,898] TRACE Setting test_1 consumed offset to 338 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:57,898] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2824845705, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:57,899] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:57,899] TRACE Setting test_1 consumed offset to 339 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:57,899] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1818887234, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:57,899] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:57,903] TRACE Setting test_1 consumed offset to 340 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:57,904] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 670950476, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:57,904] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:58,452] TRACE Setting test_1 consumed offset to 341 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:58,453] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3306438478, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:58,453] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:58,453] TRACE Setting test_1 consumed offset to 342 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:58,453] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3717833367, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:58,453] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:58,454] TRACE Setting test_1 consumed offset to 343 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:58,454] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2391007040, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:58,454] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:58,454] TRACE Setting test_1 consumed offset to 344 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:58,455] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1253466763, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:58,455] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:58,455] TRACE Setting test_1 consumed offset to 345 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:58,455] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 18973317, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:58,456] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:58,954] TRACE Setting test_1 consumed offset to 346 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:58,955] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3678558076, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:58,955] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:58,955] TRACE Setting test_1 consumed offset to 347 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:58,955] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2287479467, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:58,956] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:58,956] TRACE Setting test_1 consumed offset to 348 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:58,956] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3285174949, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:58,956] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:58,957] TRACE Setting test_1 consumed offset to 349 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:58,957] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 133855086, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:58,957] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:58,961] TRACE Setting test_1 consumed offset to 350 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:58,961] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1282250592, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:58,961] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:59,457] TRACE Setting test_1 consumed offset to 351 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:59,458] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2407698461, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:59,458] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:59,462] TRACE Setting test_1 consumed offset to 352 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:59,463] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3701009866, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:59,463] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:59,463] TRACE Setting test_1 consumed offset to 353 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:59,463] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3289739283, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:59,464] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:59,464] TRACE Setting test_1 consumed offset to 354 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:59,464] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2149848, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:59,464] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:59,465] TRACE Setting test_1 consumed offset to 355 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:59,465] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1270296022, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:59,465] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:59,965] TRACE Setting test_1 consumed offset to 356 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:59,966] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2304337398, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:59,966] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:59,966] TRACE Setting test_1 consumed offset to 357 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:59,966] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3268314616, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:59,967] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:59,967] TRACE Setting test_1 consumed offset to 358 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:59,967] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 117127219, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:59,967] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:59,968] TRACE Setting test_1 consumed offset to 359 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:59,968] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3661830177, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:59,968] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:20:59,972] TRACE Setting test_1 consumed offset to 360 (kafka.consumer.ConsumerIterator) [2012-10-11 12:20:59,972] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1298978877, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:20:59,972] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:00,488] TRACE Setting test_1 consumed offset to 361 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:00,489] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2184543179, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:00,489] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:00,489] TRACE Setting test_1 consumed offset to 362 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:00,490] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3382877125, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:00,490] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:00,490] TRACE Setting test_1 consumed offset to 363 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:00,490] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3509519900, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:00,490] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:00,491] TRACE Setting test_1 consumed offset to 364 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:00,491] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 228009486, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:00,491] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:00,491] TRACE Setting test_1 consumed offset to 365 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:00,492] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1174455808, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:00,492] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:00,991] TRACE Setting test_1 consumed offset to 366 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:00,992] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2230226464, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:00,992] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:00,992] TRACE Setting test_1 consumed offset to 367 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:00,992] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3480841774, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:00,993] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:00,993] TRACE Setting test_1 consumed offset to 368 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:00,993] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3623154679, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:00,993] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:00,996] TRACE Setting test_1 consumed offset to 369 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:00,997] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 189584357, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:00,997] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:00,997] TRACE Setting test_1 consumed offset to 370 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:00,997] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1088107499, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:00,997] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:01,498] TRACE Setting test_1 consumed offset to 371 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:01,499] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3749357503, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:01,499] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:01,499] TRACE Setting test_1 consumed offset to 372 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:01,500] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2498578353, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:01,500] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:01,500] TRACE Setting test_1 consumed offset to 373 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:01,500] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3354868326, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:01,500] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:01,501] TRACE Setting test_1 consumed offset to 374 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:01,501] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 458168948, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:01,501] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:01,501] TRACE Setting test_1 consumed offset to 375 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:01,502] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1356397178, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:01,502] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:02,001] TRACE Setting test_1 consumed offset to 376 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:02,002] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2453058138, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:02,002] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:02,002] TRACE Setting test_1 consumed offset to 377 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:02,003] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3651228244, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:02,003] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:02,003] TRACE Setting test_1 consumed offset to 378 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:02,003] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1443041169, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:02,003] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:02,008] TRACE Setting test_1 consumed offset to 379 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:02,008] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3240939405, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:02,008] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:02,009] TRACE Setting test_1 consumed offset to 380 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:02,009] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 496299935, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:02,009] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:02,520] TRACE Setting test_1 consumed offset to 381 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:02,520] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3536669801, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:02,520] TRACE Remaining queue size: 9999 (kafka.producer.Producer) [2012-10-11 12:21:02,521] TRACE Setting test_1 consumed offset to 382 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:02,521] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2572856423, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:02,521] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:02,521] TRACE Setting test_1 consumed offset to 383 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:02,522] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1567560108, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:02,522] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:02,522] TRACE Setting test_1 consumed offset to 384 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:02,522] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3393245616, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:02,523] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:02,523] TRACE Setting test_1 consumed offset to 385 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:02,523] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 385413538, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:02,523] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:03,022] TRACE Setting test_1 consumed offset to 386 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:03,023] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2676054412, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:03,023] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:03,023] TRACE Setting test_1 consumed offset to 387 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:03,024] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 270730313, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:03,024] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:03,024] TRACE Setting test_1 consumed offset to 388 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:03,024] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3558259074, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:03,025] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:03,027] TRACE Setting test_1 consumed offset to 389 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:03,028] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 1538581575, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:03,028] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:03,028] TRACE Setting test_1 consumed offset to 390 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:03,028] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3432719451, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:03,029] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:03,532] TRACE Setting test_1 consumed offset to 391 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:03,532] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 922706560, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:03,532] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:03,533] TRACE Setting test_1 consumed offset to 392 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:03,533] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3109896005, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:03,533] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:03,533] TRACE Setting test_1 consumed offset to 393 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:03,534] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4073381707, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:03,534] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:03,534] TRACE Setting test_1 consumed offset to 394 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:03,535] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2104001166, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:03,535] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:03,535] TRACE Setting test_1 consumed offset to 395 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:03,535] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3930538642, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:03,535] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:04,035] TRACE Setting test_1 consumed offset to 396 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:04,035] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3213281966, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:04,035] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:04,035] TRACE Setting test_1 consumed offset to 397 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:04,036] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 3969693561, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:04,036] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:04,036] TRACE Setting test_1 consumed offset to 398 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:04,037] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 807704427, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:04,037] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:04,037] TRACE Setting test_1 consumed offset to 399 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:04,037] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 4094765728, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:04,037] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:21:04,039] TRACE Setting test_1 consumed offset to 400 (kafka.consumer.ConsumerIterator) [2012-10-11 12:21:04,039] TRACE Added to send queue an event: ProducerData(test_1,null,List(Message(magic = 2, attributes = 0, crc = 2075359077, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=500 cap=500]))) (kafka.producer.Producer) [2012-10-11 12:21:04,039] TRACE Remaining queue size: 10000 (kafka.producer.Producer) [2012-10-11 12:22:23,772] INFO Reconnect due to socket error: (kafka.consumer.SimpleConsumer) java.io.EOFException: Received -1 when reading from channel, socket has likely been closed. at kafka.utils.Utils$.read(Utils.scala:456) at kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54) at kafka.network.Receive$class.readCompletely(Transmission.scala:56) at kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29) at kafka.network.BlockingChannel.receive(BlockingChannel.scala:92) at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:69) at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:67) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:103) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:103) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:103) at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:102) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:82) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:50) [2012-10-11 12:22:23,776] INFO Fetching metadata for topic Set(test_1) (kafka.utils.Utils$) [2012-10-11 12:22:23,776] INFO Connected to 127.0.0.1:9093 for producing (kafka.producer.SyncProducer) [2012-10-11 12:22:23,812] INFO Disconnecting from 127.0.0.1:9093 (kafka.producer.SyncProducer) [2012-10-11 12:22:23,814] INFO [ConsumerFetcherManager-1349983235956], adding fetcher on topic test_1, partion 0, initOffset 400 to broker 3 with fetcherId 0 (kafka.consumer.ConsumerFetcherManager) [2012-10-11 12:22:23,814] INFO [ConsumerFetcherThread-mm_regtest_grp_jfung-ld-1349983235900-ac06a1de-0-3], Starting (kafka.consumer.ConsumerFetcherThread) [2012-10-11 12:22:25,458] INFO Reconnect due to socket error: (kafka.consumer.SimpleConsumer) java.io.EOFException: Received -1 when reading from channel, socket has likely been closed. at kafka.utils.Utils$.read(Utils.scala:456) at kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54) at kafka.network.Receive$class.readCompletely(Transmission.scala:56) at kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29) at kafka.network.BlockingChannel.receive(BlockingChannel.scala:92) at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:69) at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:67) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:103) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:103) at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:103) at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:102) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:82) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:50) [2012-10-11 12:22:25,461] ERROR [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de-leader-finder-thread], Error due to (kafka.consumer.ConsumerFetcherManager$$anon$1) kafka.common.KafkaException: fetching topic metadata for topics [Set(test_1)] from broker [ArrayBuffer()] failed at kafka.utils.Utils$.getTopicMetadata(Utils.scala:704) at kafka.consumer.ConsumerFetcherManager$$anon$1.doWork(ConsumerFetcherManager.scala:55) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:50) [2012-10-11 12:22:25,462] INFO [mm_regtest_grp_jfung-ld-1349983235900-ac06a1de-leader-finder-thread], Stopped (kafka.consumer.ConsumerFetcherManager$$anon$1) [2012-10-11 12:22:27,547] WARN Session 0x23a5143a21a0004 for server localhost/127.0.0.1:2118, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) java.io.IOException: Connection reset by peer at sun.nio.ch.FileDispatcher.read0(Native Method) at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:21) at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:198) at sun.nio.ch.IOUtil.read(IOUtil.java:166) at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:243) at org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:859) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1157) [2012-10-11 12:22:27,549] INFO Unable to read additional data from server sessionid 0x13a5143a21b0002, likely server has closed socket, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:22:27,648] INFO zookeeper state changed (Disconnected) (org.I0Itec.zkclient.ZkClient) [2012-10-11 12:22:27,649] INFO zookeeper state changed (Disconnected) (org.I0Itec.zkclient.ZkClient) [2012-10-11 12:22:27,666] INFO Opening socket connection to server localhost/127.0.0.1:2118 (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:22:27,667] WARN Session 0x13a5143a21b0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:567) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1146) [2012-10-11 12:22:28,433] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2118 (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:22:28,433] WARN Session 0x23a5143a21a0004 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:567) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1146) [2012-10-11 12:22:28,463] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2118 (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:22:28,464] WARN Session 0x13a5143a21b0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:567) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1146) [2012-10-11 12:22:29,257] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2108 (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:22:29,258] WARN Session 0x23a5143a21a0004 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:567) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1146) [2012-10-11 12:22:29,286] INFO Opening socket connection to server localhost/127.0.0.1:2108 (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:22:29,287] WARN Session 0x13a5143a21b0002 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:567) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1146) [2012-10-11 12:22:29,663] INFO Opening socket connection to server localhost/127.0.0.1:2108 (org.apache.zookeeper.ClientCnxn) [2012-10-11 12:22:29,664] WARN Session 0x23a5143a21a0004 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:567) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1146)