[2013-11-24 21:14:16,638] INFO Verifying properties (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property socket.send.buffer.bytes is overridden to 1048576 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property socket.request.max.bytes is overridden to 104857600 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property log.dir is overridden to \data\kafka\kafka-logs (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property log.cleanup.interval.mins is overridden to 1 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property log.retention.hours is overridden to 24 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property num.io.threads is overridden to 2 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property broker.id is overridden to 0 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] WARN Property kafka.csv.metrics.reporter.enabled is not valid (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property port is overridden to 9092 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property log.flush.interval.messages is overridden to 10000 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] WARN Property kafka.metrics.reporters is not valid (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] WARN Property kafka.csv.metrics.dir is not valid (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property auto.create.topics.enable is overridden to false (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property log.flush.interval.ms is overridden to 1000 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] WARN Property kafka.metrics.polling.interval.secs is not valid (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property num.network.threads is overridden to 2 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property socket.receive.buffer.bytes is overridden to 1048576 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property log.segment.bytes is overridden to 536870912 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property num.partitions is overridden to 1 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property zookeeper.connection.timeout.ms is overridden to 1000000 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,669] INFO Property zookeeper.connect is overridden to 10.65.127.85:2181,10.65.127.86:2181,10.65.127.87:2181 (kafka.utils.VerifiableProperties) [2013-11-24 21:14:16,716] INFO [Kafka Server 0], Starting (kafka.server.KafkaServer) [2013-11-24 21:14:16,747] INFO [Log Manager on Broker 0] Log directory 'D:\data\kafka\kafka-logs' not found, creating it. (kafka.log.LogManager) [2013-11-24 21:14:16,747] INFO [Log Manager on Broker 0] Starting log cleaner every 60000 ms (kafka.log.LogManager) [2013-11-24 21:14:16,763] INFO [Log Manager on Broker 0] Starting log flusher every 3000 ms with the following overrides Map() (kafka.log.LogManager) [2013-11-24 21:14:16,810] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.Acceptor) [2013-11-24 21:14:16,810] INFO [Socket Server on Broker 0], Started (kafka.network.SocketServer) [2013-11-24 21:14:16,825] INFO connecting to ZK: 10.65.127.85:2181,10.65.127.86:2181,10.65.127.87:2181 (kafka.server.KafkaZooKeeper) [2013-11-24 21:14:25,935] INFO Registered broker 0 at path /brokers/ids/0 with address KAFKASERVER914:9092. (kafka.utils.ZkUtils$) [2013-11-24 21:14:25,935] INFO [Kafka Server 0], Connecting to ZK: 10.65.127.85:2181,10.65.127.86:2181,10.65.127.87:2181 (kafka.server.KafkaServer) [2013-11-24 21:14:26,076] INFO Will not load MX4J, mx4j-tools.jar is not in the classpath (kafka.utils.Mx4jLoader$) [2013-11-24 21:14:26,092] INFO conflict in /controller data: { "brokerid":0, "timestamp":"1385356466076", "version":1 } stored data: { "brokerid":3, "timestamp":"1384497263161", "version":1 } (kafka.utils.ZkUtils$) [2013-11-24 21:14:26,123] INFO [Replica Manager on Broker 0]: Handling LeaderAndIsr request Name:LeaderAndIsrRequest;Version:0;Controller:3;ControllerEpoch:1;CorrelationId:33;ClientId:id_3-host_null-port_9092;PartitionState:(testlogs,2) -> (LeaderAndIsrInfo:(Leader:1,ISR:1,LeaderEpoch:3,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1),(testlogs,1) -> (LeaderAndIsrInfo:(Leader:3,ISR:3,LeaderEpoch:1,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:3,0);Leaders:id:3,host:KAFKASERVER311,port:9092,id:1,host:KAFKASERVER114,port:9092 (kafka.server.ReplicaManager) [2013-11-24 21:14:26,201] INFO [Kafka Log on Broker 0], Completed load of log testlogs-2 with log end offset 0 (kafka.log.Log) [2013-11-24 21:14:26,201] INFO [Log Manager on Broker 0] Created log for partition [testlogs,2] in D:\data\kafka\kafka-logs. (kafka.log.LogManager) [2013-11-24 21:14:26,201] WARN No highwatermark file is found. Returning 0 as the highwatermark for partition [testlogs,2] (kafka.server.HighwaterMarkCheckpoint) [2013-11-24 21:14:26,201] INFO [ReplicaFetcherManager on broker 0] Removing fetcher for partition [testlogs,2] (kafka.server.ReplicaFetcherManager) [2013-11-24 21:14:26,201] INFO [Kafka Log on Broker 0], Truncated log segment D:\data\kafka\kafka-logs\testlogs-2\00000000000000000000.log to target offset 0 (kafka.log.Log) [2013-11-24 21:14:26,232] INFO [ReplicaFetcherThread-0-1], Starting (kafka.server.ReplicaFetcherThread) [2013-11-24 21:14:26,232] INFO [ReplicaFetcherManager on broker 0] Adding fetcher for partition [testlogs,2], initOffset 0 to broker 1 with fetcherId 0 (kafka.server.ReplicaFetcherManager) [2013-11-24 21:14:26,232] INFO [Kafka Log on Broker 0], Completed load of log testlogs-1 with log end offset 0 (kafka.log.Log) [2013-11-24 21:14:26,232] INFO [Log Manager on Broker 0] Created log for partition [testlogs,1] in D:\data\kafka\kafka-logs. (kafka.log.LogManager) [2013-11-24 21:14:26,232] WARN No highwatermark file is found. Returning 0 as the highwatermark for partition [testlogs,1] (kafka.server.HighwaterMarkCheckpoint) [2013-11-24 21:14:26,232] INFO [ReplicaFetcherManager on broker 0] Removing fetcher for partition [testlogs,1] (kafka.server.ReplicaFetcherManager) [2013-11-24 21:14:26,232] INFO [Kafka Log on Broker 0], Truncated log segment D:\data\kafka\kafka-logs\testlogs-1\00000000000000000000.log to target offset 0 (kafka.log.Log) [2013-11-24 21:14:26,232] INFO [ReplicaFetcherManager on broker 0] Adding fetcher for partition [testlogs,1], initOffset 0 to broker 3 with fetcherId 0 (kafka.server.ReplicaFetcherManager) [2013-11-24 21:14:26,232] INFO [ReplicaFetcherThread-0-3], Starting (kafka.server.ReplicaFetcherThread) [2013-11-24 21:14:26,232] INFO [Replica Manager on Broker 0]: Handled leader and isr request Name:LeaderAndIsrRequest;Version:0;Controller:3;ControllerEpoch:1;CorrelationId:33;ClientId:id_3-host_null-port_9092;PartitionState:(testlogs,2) -> (LeaderAndIsrInfo:(Leader:1,ISR:1,LeaderEpoch:3,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1),(testlogs,1) -> (LeaderAndIsrInfo:(Leader:3,ISR:3,LeaderEpoch:1,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:3,0);Leaders:id:3,host:KAFKASERVER311,port:9092,id:1,host:KAFKASERVER114,port:9092 (kafka.server.ReplicaManager) [2013-11-24 21:14:26,279] INFO [Kafka Server 0], Started (kafka.server.KafkaServer) [2013-11-24 21:14:26,451] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:26,451] INFO [Kafka Log on Broker 0], Deleting log segment 0 from testlogs-1 (kafka.log.Log) [2013-11-24 21:14:26,467] INFO Deleting index D:\data\kafka\kafka-logs\testlogs-1\00000000000000000000.index (kafka.log.OffsetIndex) [2013-11-24 21:14:26,467] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) kafka.common.KafkaStorageException: Deleting log segment 0 failed. at kafka.log.Log$$anonfun$deleteSegments$1.apply(Log.scala:613) at kafka.log.Log$$anonfun$deleteSegments$1.apply(Log.scala:608) at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34) at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:33) at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:26,685] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:26,685] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:26,764] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:26,764] INFO [Kafka Log on Broker 0], Deleting log segment 0 from testlogs-2 (kafka.log.Log) [2013-11-24 21:14:26,764] INFO Deleting index D:\data\kafka\kafka-logs\testlogs-2\00000000000000000000.index (kafka.log.OffsetIndex) [2013-11-24 21:14:26,764] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) kafka.common.KafkaStorageException: Deleting log segment 0 failed. at kafka.log.Log$$anonfun$deleteSegments$1.apply(Log.scala:613) at kafka.log.Log$$anonfun$deleteSegments$1.apply(Log.scala:608) at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34) at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:33) at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:26,951] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:26,951] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:27,154] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:27,154] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:27,185] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:27,185] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:27,451] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:27,451] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:27,654] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:27,654] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:27,889] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:27,889] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:27,889] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:27,889] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:27,951] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:27,951] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:27,951] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:27,951] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:28,436] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:28,436] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:28,451] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:28,451] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:28,936] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:28,936] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:28,967] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:28,967] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:29,451] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:29,451] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:29,467] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:29,467] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:29,529] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:29,529] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:29,951] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:29,951] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:30,045] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:30,045] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:30,467] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:30,467] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:30,545] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:30,545] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:30,967] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:30,967] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:31,061] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:31,061] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:31,483] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:31,483] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:31,561] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:31,561] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:31,983] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:31,983] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:32,061] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:32,061] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:32,123] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:32,123] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:32,326] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:32,326] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:32,342] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:32,342] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:32,826] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:32,826] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:32,826] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:32,826] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:32,951] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:32,951] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:33,217] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:33,217] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:33,217] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:33,217] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:33,451] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:33,451] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:33,733] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:33,733] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:33,889] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:33,889] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:33,905] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:33,905] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:34,014] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:34,014] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:34,123] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:34,123] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:34,155] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:34,155] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:34,623] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:34,623] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:34,655] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:34,655] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:35,139] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:35,139] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:35,155] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:35,155] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:35,639] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:35,639] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:35,670] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:35,670] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:36,124] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:36,124] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:36,124] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:36,124] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:36,155] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:36,155] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:36,530] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:36,530] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:36,639] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:36,639] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:36,952] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:36,952] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:36,952] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:36,952] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:37,046] INFO Closing socket connection to /10.65.127.83. (kafka.network.Processor) [2013-11-24 21:14:37,389] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-1' to 1195016 (kafka.log.Log) [2013-11-24 21:14:37,389] WARN [ReplicaFetcherThread-0-3], Error getting offset for partition [testlogs,1] to broker 3 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:109) at kafka.utils.Utils$.inLock(Utils.scala:565) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:108) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:86) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) [2013-11-24 21:14:37,467] INFO [Kafka Log on Broker 0], Truncate and start log 'testlogs-2' to 1195480 (kafka.log.Log) [2013-11-24 21:14:37,467] WARN [ReplicaFetcherThread-0-1], Error getting offset for partition [testlogs,2] to broker 1 (kafka.server.ReplicaFetcherThread) java.lang.NullPointerException at kafka.log.Log.deleteSegments(Log.scala:608) at kafka.log.Log.truncateAndStartWithNewOffset(Log.scala:667) at kafka.server.ReplicaFetcherThread.handleOffsetOutOfRange(ReplicaFetcherThread.scala:97) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:142) at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:109) at scala.collection.immutable.Map$Map1.foreach(Map.scala:119)