[2013-01-11 09:38:15,198] INFO Starting mirror maker (kafka.tools.MirrorMaker$)
[2013-01-11 09:38:15,260] INFO Verifying properties (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,261] INFO Property broker.list is overridden to 10.0.0.2:9092 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,261] INFO Property queue.size is overridden to 100000 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,261] INFO Property producer.type is overridden to async (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,262] INFO Property batch.size is overridden to 20000 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,262] INFO Property queue.enqueueTimeout.ms is overridden to -1 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,335] INFO Verifying properties (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,335] INFO Property zk.connect is overridden to 10.0.0.1:2181 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,335] INFO Property socket.buffersize is overridden to 26214400 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,335] INFO Property consumer.timeout.ms is overridden to -1 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,335] INFO Property groupid is overridden to KafkaMirror (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,336] INFO Property queuedchunks.max is overridden to 10000 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,336] INFO Property shallowiterator.enable is overridden to true (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,336] INFO Property zk.connectiontimeout.ms is overridden to 1000000 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,336] INFO Property fetch.size is overridden to 25485760 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,336] INFO Property max.fetch.wait.ms is overridden to 1000 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,337] INFO Property min.fetch.bytes is overridden to 1000 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,337] INFO Property refresh.leader.backoff.ms is overridden to 600000 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:15,346] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Connecting to zookeeper instance at 10.0.0.1:2181 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:15,356] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)
[2013-01-11 09:38:15,364] INFO Client environment:zookeeper.version=3.3.3-1203054, built on 11/17/2011 05:47 GMT (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,364] INFO Client environment:host.name=mirror-01 (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,364] INFO Client environment:java.version=1.6.0_31 (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,364] INFO Client environment:java.vendor=Sun Microsystems Inc. (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,365] INFO Client environment:java.home=/usr/java/jdk1.6.0_31/jre (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,365] INFO Client environment:java.class.path=:/opt/kafka-0.8/bin/../project/boot/scala-2.8.0/lib/scala-compiler.jar:/opt/kafka-0.8/bin/../project/boot/scala-2.8.0/lib/scala-library.jar:/opt/kafka-0.8/bin/../core/target/scala_2.8.0/core-kafka_2.8.0-0.8.0-SNAPSHOT.jar:/opt/kafka-0.8/bin/../core/target/scala_2.8.0/core-kafka_2.8.0-0.8.0-SNAPSHOT-test.jar:/opt/kafka-0.8/bin/../core/lib/metrics-annotation-3.0.0-c0c8be71.jar:/opt/kafka-0.8/bin/../core/lib/metrics-core-3.0.0-c0c8be71.jar:/opt/kafka-0.8/bin/../core/lib/zkclient-20120522.jar:/opt/kafka-0.8/bin/../perf/target/scala_2.8.0/kafka-perf-0.8.0-SNAPSHOT.jar:/opt/kafka-0.8/bin/../core/lib_managed/scala_2.8.0/compile/jopt-simple-3.2.jar:/opt/kafka-0.8/bin/../core/lib_managed/scala_2.8.0/compile/log4j-1.2.15.jar:/opt/kafka-0.8/bin/../core/lib_managed/scala_2.8.0/compile/slf4j-api-1.7.2.jar:/opt/kafka-0.8/bin/../core/lib_managed/scala_2.8.0/compile/slf4j-simple-1.7.2.jar:/opt/kafka-0.8/bin/../core/lib_managed/scala_2.8.0/compile/snappy-java-1.0.4.1.jar:/opt/kafka-0.8/bin/../core/lib_managed/scala_2.8.0/compile/zookeeper-3.3.4.jar (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,365] INFO Client environment:java.library.path=/usr/java/jdk1.6.0_31/jre/lib/amd64/server:/usr/java/jdk1.6.0_31/jre/lib/amd64:/usr/java/jdk1.6.0_31/jre/../lib/amd64:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,365] INFO Client environment:java.io.tmpdir=/tmp (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,365] INFO Client environment:java.compiler=<NA> (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,365] INFO Client environment:os.name=Linux (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,365] INFO Client environment:os.arch=amd64 (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,365] INFO Client environment:os.version=2.6.18-274.12.1.el5.centos.plus (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,365] INFO Client environment:user.name=m.brugidou (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,365] INFO Client environment:user.home=/home/m.brugidou (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,365] INFO Client environment:user.dir=/home/m.brugidou (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,366] INFO Initiating client connection, connectString=10.0.0.1:2181 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@565bb966 (org.apache.zookeeper.ZooKeeper)
[2013-01-11 09:38:15,383] INFO Opening socket connection to server /10.0.0.1:2181 (org.apache.zookeeper.ClientCnxn)
[2013-01-11 09:38:15,533] INFO Socket connection established to broker-01/10.0.0.1:2181, initiating session (org.apache.zookeeper.ClientCnxn)
[2013-01-11 09:38:15,682] INFO Session establishment complete on server broker-01/10.0.0.1:2181, sessionid = 0x13c012a599601a6, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn)
[2013-01-11 09:38:15,684] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient)
[2013-01-11 09:38:15,689] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15-leader-finder-thread], Starting  (kafka.consumer.ConsumerFetcherManager$$anon$1)
[2013-01-11 09:38:15,690] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], starting auto committer every 60000 ms (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:15,867] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], begin registering consumer KafkaMirror_mirror-01-1357893495345-fac86b15 in ZK (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:16,018] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], end registering consumer KafkaMirror_mirror-01-1357893495345-fac86b15 in ZK (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:16,021] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], starting watcher executor thread for consumer KafkaMirror_mirror-01-1357893495345-fac86b15 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:23,443] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], begin rebalancing consumer KafkaMirror_mirror-01-1357893495345-fac86b15 try #0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:23,885] INFO Constructing topic count for KafkaMirror_mirror-01-1357893495345-fac86b15 from !1!xdummyx using !(\p{Digit}+)!(.*) as pattern. (kafka.consumer.TopicCount$)
[2013-01-11 09:38:24,320] INFO Constructing topic count for KafkaMirror_mirror-01-1357893495345-fac86b15 from !1!xdummyx using !(\p{Digit}+)!(.*) as pattern. (kafka.consumer.TopicCount$)
[2013-01-11 09:38:24,769] INFO Verifying properties (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:24,769] INFO Property broker.list is overridden to broker-01:9092 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:24,770] INFO Property clientid is overridden to KafkaMirror (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:24,793] INFO Fetching metadata for topic Set(topic-1, topic-8, topic-24, topic-9, topic-20, topic-9al, topic-16, topic-22, topic-15, topic-5, topic-17, dummy, topic-18, topic-3, topic-7, topic-23, topic-14, topic-92, topic-6, topic-25, topic-21, topic-2, topic-3, topic-19) (kafka.client.ClientUtils$)
[2013-01-11 09:38:24,938] INFO Connected to broker-01:9092 for producing (kafka.producer.SyncProducer)
[2013-01-11 09:38:25,214] INFO Disconnecting from broker-01:9092 (kafka.producer.SyncProducer)
[2013-01-11 09:38:25,224] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared all relevant queues for this fetcher (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:25,225] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,225] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,225] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,225] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,225] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,226] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,226] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,226] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,226] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,226] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,226] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,226] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,226] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,226] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,227] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,227] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,227] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,227] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,227] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,227] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,227] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,227] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,227] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,227] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:25,228] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared the data chunks in all the consumer message iterators (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:25,228] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Committing all offsets after clearing the fetcher queues (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:25,229] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Releasing partition ownership (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:25,231] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0) for topic topic-1 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:25,233] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:25,382] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0) for topic topic-8 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:25,382] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:25,527] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0, 1, 2, 3) for topic topic-24 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:25,527] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:25,671] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 1 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:25,816] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 2 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:25,960] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 3 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:26,105] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0) for topic topic-9 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:26,105] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:26,107] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], exception during rebalance  (kafka.consumer.ZookeeperConsumerConnector)
kafka.common.NoBrokersForPartitionException: No leader available for partition 0 on topic topic-9
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$addPartitionTopicInfo(ZookeeperConsumerConnector.scala:584)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11$$anonfun$apply$13.apply(ZookeeperConsumerConnector.scala:459)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11$$anonfun$apply$13.apply(ZookeeperConsumerConnector.scala:456)
	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:456)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11.apply(ZookeeperConsumerConnector.scala:443)
	at scala.collection.mutable.HashSet.foreach(HashSet.scala:61)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2.apply(ZookeeperConsumerConnector.scala:443)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2.apply(ZookeeperConsumerConnector.scala:430)
	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:430)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:373)
	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:368)
	at kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:697)
	at kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.<init>(ZookeeperConsumerConnector.scala:732)
	at kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:141)
	at kafka.tools.MirrorMaker$$anonfun$4.apply(MirrorMaker.scala:116)
	at kafka.tools.MirrorMaker$$anonfun$4.apply(MirrorMaker.scala:116)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
	at scala.collection.immutable.List.foreach(List.scala:45)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
	at scala.collection.immutable.List.map(List.scala:45)
	at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:116)
	at kafka.tools.MirrorMaker.main(MirrorMaker.scala)
[2013-01-11 09:38:26,109] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], end rebalancing consumer KafkaMirror_mirror-01-1357893495345-fac86b15 try #0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:26,109] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Rebalancing attempt failed. Clearing the cache before the next rebalancing operation is triggered (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:26,110] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared all relevant queues for this fetcher (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:26,110] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,110] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,110] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,110] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,110] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,111] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,111] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,111] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,111] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,111] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,111] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,111] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,111] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,111] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,111] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,112] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,112] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,112] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,112] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,112] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,112] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,112] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,112] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,112] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:26,113] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared the data chunks in all the consumer message iterators (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:26,113] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Committing all offsets after clearing the fetcher queues (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:28,115] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], begin rebalancing consumer KafkaMirror_mirror-01-1357893495345-fac86b15 try #1 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:28,548] INFO Constructing topic count for KafkaMirror_mirror-01-1357893495345-fac86b15 from !1!xdummyx using !(\p{Digit}+)!(.*) as pattern. (kafka.consumer.TopicCount$)
[2013-01-11 09:38:28,983] INFO Constructing topic count for KafkaMirror_mirror-01-1357893495345-fac86b15 from !1!xdummyx using !(\p{Digit}+)!(.*) as pattern. (kafka.consumer.TopicCount$)
[2013-01-11 09:38:29,419] INFO Verifying properties (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:29,419] INFO Property broker.list is overridden to broker-01:9092 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:29,419] INFO Property clientid is overridden to KafkaMirror (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:29,420] INFO Fetching metadata for topic Set(topic-1, topic-8, topic-24, topic-9, topic-20, topic-9al, topic-16, topic-22, topic-15, topic-5, topic-17, dummy, topic-18, topic-3, topic-7, topic-23, topic-14, topic-92, topic-6, topic-25, topic-21, topic-2, topic-3, topic-19) (kafka.client.ClientUtils$)
[2013-01-11 09:38:29,564] INFO Connected to broker-01:9092 for producing (kafka.producer.SyncProducer)
[2013-01-11 09:38:29,809] INFO Disconnecting from broker-01:9092 (kafka.producer.SyncProducer)
[2013-01-11 09:38:29,811] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared all relevant queues for this fetcher (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:29,811] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,811] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,811] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,811] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,811] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,811] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,811] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,811] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,811] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,812] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,812] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,812] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,812] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,812] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,812] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,812] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,812] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,812] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,813] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,813] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,813] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,813] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,813] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,813] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:29,813] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared the data chunks in all the consumer message iterators (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:29,813] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Committing all offsets after clearing the fetcher queues (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:29,813] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Releasing partition ownership (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:29,814] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0) for topic topic-1 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:29,814] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:29,958] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0) for topic topic-8 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:29,958] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:30,103] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0, 1, 2, 3) for topic topic-24 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:30,103] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:30,248] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 1 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:30,392] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 2 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:30,537] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 3 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:30,682] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0) for topic topic-9 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:30,682] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:30,682] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], exception during rebalance  (kafka.consumer.ZookeeperConsumerConnector)
kafka.common.NoBrokersForPartitionException: No leader available for partition 0 on topic topic-9
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$addPartitionTopicInfo(ZookeeperConsumerConnector.scala:584)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11$$anonfun$apply$13.apply(ZookeeperConsumerConnector.scala:459)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11$$anonfun$apply$13.apply(ZookeeperConsumerConnector.scala:456)
	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:456)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11.apply(ZookeeperConsumerConnector.scala:443)
	at scala.collection.mutable.HashSet.foreach(HashSet.scala:61)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2.apply(ZookeeperConsumerConnector.scala:443)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2.apply(ZookeeperConsumerConnector.scala:430)
	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:430)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:373)
	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:368)
	at kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:697)
	at kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.<init>(ZookeeperConsumerConnector.scala:732)
	at kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:141)
	at kafka.tools.MirrorMaker$$anonfun$4.apply(MirrorMaker.scala:116)
	at kafka.tools.MirrorMaker$$anonfun$4.apply(MirrorMaker.scala:116)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
	at scala.collection.immutable.List.foreach(List.scala:45)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
	at scala.collection.immutable.List.map(List.scala:45)
	at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:116)
	at kafka.tools.MirrorMaker.main(MirrorMaker.scala)
[2013-01-11 09:38:30,683] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], end rebalancing consumer KafkaMirror_mirror-01-1357893495345-fac86b15 try #1 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:30,684] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Rebalancing attempt failed. Clearing the cache before the next rebalancing operation is triggered (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:30,684] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared all relevant queues for this fetcher (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:30,684] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,684] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,684] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,684] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,684] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,685] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,685] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,685] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,685] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,685] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,685] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,685] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,685] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,686] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,686] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,686] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,686] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,686] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,686] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,686] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,686] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,686] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,687] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,687] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:30,687] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared the data chunks in all the consumer message iterators (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:30,687] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Committing all offsets after clearing the fetcher queues (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:32,689] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], begin rebalancing consumer KafkaMirror_mirror-01-1357893495345-fac86b15 try #2 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:33,122] INFO Constructing topic count for KafkaMirror_mirror-01-1357893495345-fac86b15 from !1!xdummyx using !(\p{Digit}+)!(.*) as pattern. (kafka.consumer.TopicCount$)
[2013-01-11 09:38:33,557] INFO Constructing topic count for KafkaMirror_mirror-01-1357893495345-fac86b15 from !1!xdummyx using !(\p{Digit}+)!(.*) as pattern. (kafka.consumer.TopicCount$)
[2013-01-11 09:38:33,992] INFO Verifying properties (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:33,992] INFO Property broker.list is overridden to broker-01:9092 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:33,993] INFO Property clientid is overridden to KafkaMirror (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:33,993] INFO Fetching metadata for topic Set(topic-1, topic-8, topic-24, topic-9, topic-20, topic-9al, topic-16, topic-22, topic-15, topic-5, topic-17, dummy, topic-18, topic-3, topic-7, topic-23, topic-14, topic-92, topic-6, topic-25, topic-21, topic-2, topic-3, topic-19) (kafka.client.ClientUtils$)
[2013-01-11 09:38:34,138] INFO Connected to broker-01:9092 for producing (kafka.producer.SyncProducer)
[2013-01-11 09:38:34,403] INFO Disconnecting from broker-01:9092 (kafka.producer.SyncProducer)
[2013-01-11 09:38:34,404] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared all relevant queues for this fetcher (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:34,404] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,404] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,404] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,405] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,405] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,405] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,405] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,405] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,405] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,405] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,405] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,405] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,405] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,406] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,406] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,406] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,406] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,406] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,406] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,406] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,406] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,406] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,406] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,407] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:34,407] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared the data chunks in all the consumer message iterators (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:34,407] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Committing all offsets after clearing the fetcher queues (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:34,407] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Releasing partition ownership (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:34,407] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0) for topic topic-1 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:34,407] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:34,552] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0) for topic topic-8 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:34,552] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:34,697] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0, 1, 2, 3) for topic topic-24 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:34,697] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:34,841] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 1 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:34,986] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 2 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:35,131] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 3 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:35,276] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0) for topic topic-9 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:35,276] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:35,276] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], exception during rebalance  (kafka.consumer.ZookeeperConsumerConnector)
kafka.common.NoBrokersForPartitionException: No leader available for partition 0 on topic topic-9
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$addPartitionTopicInfo(ZookeeperConsumerConnector.scala:584)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11$$anonfun$apply$13.apply(ZookeeperConsumerConnector.scala:459)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11$$anonfun$apply$13.apply(ZookeeperConsumerConnector.scala:456)
	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:456)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11.apply(ZookeeperConsumerConnector.scala:443)
	at scala.collection.mutable.HashSet.foreach(HashSet.scala:61)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2.apply(ZookeeperConsumerConnector.scala:443)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2.apply(ZookeeperConsumerConnector.scala:430)
	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:430)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:373)
	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:368)
	at kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:697)
	at kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.<init>(ZookeeperConsumerConnector.scala:732)
	at kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:141)
	at kafka.tools.MirrorMaker$$anonfun$4.apply(MirrorMaker.scala:116)
	at kafka.tools.MirrorMaker$$anonfun$4.apply(MirrorMaker.scala:116)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
	at scala.collection.immutable.List.foreach(List.scala:45)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
	at scala.collection.immutable.List.map(List.scala:45)
	at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:116)
	at kafka.tools.MirrorMaker.main(MirrorMaker.scala)
[2013-01-11 09:38:35,277] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], end rebalancing consumer KafkaMirror_mirror-01-1357893495345-fac86b15 try #2 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:35,277] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Rebalancing attempt failed. Clearing the cache before the next rebalancing operation is triggered (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:35,277] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared all relevant queues for this fetcher (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:35,277] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,277] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,277] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,278] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,278] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,278] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,278] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,278] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,278] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,278] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,278] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,278] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,278] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,279] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,279] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,279] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,279] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,279] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,279] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,279] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,279] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,279] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,280] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,280] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:35,280] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared the data chunks in all the consumer message iterators (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:35,280] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Committing all offsets after clearing the fetcher queues (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:37,282] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], begin rebalancing consumer KafkaMirror_mirror-01-1357893495345-fac86b15 try #3 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:37,716] INFO Constructing topic count for KafkaMirror_mirror-01-1357893495345-fac86b15 from !1!xdummyx using !(\p{Digit}+)!(.*) as pattern. (kafka.consumer.TopicCount$)
[2013-01-11 09:38:38,151] INFO Constructing topic count for KafkaMirror_mirror-01-1357893495345-fac86b15 from !1!xdummyx using !(\p{Digit}+)!(.*) as pattern. (kafka.consumer.TopicCount$)
[2013-01-11 09:38:38,587] INFO Verifying properties (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:38,587] INFO Property broker.list is overridden to broker-01:9092 (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:38,587] INFO Property clientid is overridden to KafkaMirror (kafka.utils.VerifiableProperties)
[2013-01-11 09:38:38,587] INFO Fetching metadata for topic Set(topic-1, topic-8, topic-24, topic-9, topic-20, topic-9al, topic-16, topic-22, topic-15, topic-5, topic-17, dummy, topic-18, topic-3, topic-7, topic-23, topic-14, topic-92, topic-6, topic-25, topic-21, topic-2, topic-3, topic-19) (kafka.client.ClientUtils$)
[2013-01-11 09:38:38,731] INFO Connected to broker-01:9092 for producing (kafka.producer.SyncProducer)
[2013-01-11 09:38:38,986] INFO Disconnecting from broker-01:9092 (kafka.producer.SyncProducer)
[2013-01-11 09:38:38,987] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared all relevant queues for this fetcher (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:38,987] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,987] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,987] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,988] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,988] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,988] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,988] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,988] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,988] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,988] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,988] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,989] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,989] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,989] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,989] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,989] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,989] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,989] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,989] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,990] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,990] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,990] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,990] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,990] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:38,990] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared the data chunks in all the consumer message iterators (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:38,990] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Committing all offsets after clearing the fetcher queues (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:38,990] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Releasing partition ownership (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:38,991] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0) for topic topic-1 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:38,991] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:39,135] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0) for topic topic-8 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:39,136] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:39,280] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0, 1, 2, 3) for topic topic-24 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:39,280] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:39,425] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 1 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:39,570] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 2 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:39,715] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 3 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:39,859] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Consumer KafkaMirror_mirror-01-1357893495345-fac86b15 rebalancing the following partitions: ArrayBuffer(0) for topic topic-9 with consumers: List(KafkaMirror_mirror-01-1357893495345-fac86b15-0) (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:39,859] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], KafkaMirror_mirror-01-1357893495345-fac86b15-0 attempting to claim partition 0 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:39,860] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], exception during rebalance  (kafka.consumer.ZookeeperConsumerConnector)
kafka.common.NoBrokersForPartitionException: No leader available for partition 0 on topic topic-9
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$addPartitionTopicInfo(ZookeeperConsumerConnector.scala:584)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11$$anonfun$apply$13.apply(ZookeeperConsumerConnector.scala:459)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11$$anonfun$apply$13.apply(ZookeeperConsumerConnector.scala:456)
	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:456)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2$$anonfun$apply$11.apply(ZookeeperConsumerConnector.scala:443)
	at scala.collection.mutable.HashSet.foreach(HashSet.scala:61)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2.apply(ZookeeperConsumerConnector.scala:443)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance$2.apply(ZookeeperConsumerConnector.scala:430)
	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:430)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:373)
	at scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:285)
	at scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265)
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:368)
	at kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:697)
	at kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.<init>(ZookeeperConsumerConnector.scala:732)
	at kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:141)
	at kafka.tools.MirrorMaker$$anonfun$4.apply(MirrorMaker.scala:116)
	at kafka.tools.MirrorMaker$$anonfun$4.apply(MirrorMaker.scala:116)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
	at scala.collection.immutable.List.foreach(List.scala:45)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
	at scala.collection.immutable.List.map(List.scala:45)
	at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:116)
	at kafka.tools.MirrorMaker.main(MirrorMaker.scala)
[2013-01-11 09:38:39,860] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], end rebalancing consumer KafkaMirror_mirror-01-1357893495345-fac86b15 try #3 (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:39,860] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Rebalancing attempt failed. Clearing the cache before the next rebalancing operation is triggered (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:39,861] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared all relevant queues for this fetcher (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:39,861] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,861] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,861] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,861] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,861] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,861] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,862] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,862] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,862] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,862] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,862] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,862] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,862] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,863] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,863] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,863] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,863] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,863] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,863] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,863] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,863] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,864] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,864] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,864] INFO Clearing the current data chunk for this consumer iterator (kafka.consumer.ConsumerIterator)
[2013-01-11 09:38:39,864] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Cleared the data chunks in all the consumer message iterators (kafka.consumer.ZookeeperConsumerConnector)
[2013-01-11 09:38:39,864] INFO [KafkaMirror_mirror-01-1357893495345-fac86b15], Committing all offsets after clearing the fetcher queues (kafka.consumer.ZookeeperConsumerConnector)
Exception in thread "main" kafka.common.ConsumerRebalanceFailedException: KafkaMirror_mirror-01-1357893495345-fac86b15 can't rebalance after 4 retries
	at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:396)
	at kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:697)
	at kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.<init>(ZookeeperConsumerConnector.scala:732)
	at kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:141)
	at kafka.tools.MirrorMaker$$anonfun$4.apply(MirrorMaker.scala:116)
	at kafka.tools.MirrorMaker$$anonfun$4.apply(MirrorMaker.scala:116)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
	at scala.collection.immutable.List.foreach(List.scala:45)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
	at scala.collection.immutable.List.map(List.scala:45)
	at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:116)
	at kafka.tools.MirrorMaker.main(MirrorMaker.scala)