[2017-04-24 22:46:57,863] INFO Truncating log __consumer_offsets-13 to offset 15. (kafka.log.Log)
[2017-04-24 22:46:57,864] WARN [ReplicaFetcherThread-0-72], Error in fetch kafka.server.ReplicaFetcherThread$FetchRequest@30d0ab2c (kafk
a.server.ReplicaFetcherThread)
java.io.IOException: Connection to 72 was disconnected before the response was read
        at kafka.utils.NetworkClientBlockingOps$.$anonfun$blockingSendAndReceive$3(NetworkClientBlockingOps.scala:114)
        at kafka.utils.NetworkClientBlockingOps$.$anonfun$blockingSendAndReceive$3$adapted(NetworkClientBlockingOps.scala:112)
        at scala.Option.foreach(Option.scala:257)
        at kafka.utils.NetworkClientBlockingOps$.$anonfun$blockingSendAndReceive$1(NetworkClientBlockingOps.scala:112)
        at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:136)
        at kafka.utils.NetworkClientBlockingOps$.pollContinuously$extension(NetworkClientBlockingOps.scala:142)
        at kafka.utils.NetworkClientBlockingOps$.blockingSendAndReceive$extension(NetworkClientBlockingOps.scala:108)
        at kafka.server.ReplicaFetcherThread.sendRequest(ReplicaFetcherThread.scala:249)
        at kafka.server.ReplicaFetcherThread.fetch(ReplicaFetcherThread.scala:234)
        at kafka.server.ReplicaFetcherThread.fetch(ReplicaFetcherThread.scala:42)
        at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:118)
        at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:103)
        at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
[2017-04-24 22:46:57,866] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([__consumer_offsets-13, initOffset 15 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:57,872] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions IL2S-1 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:57,872] INFO Truncating log IL2S-1 to offset 2831945670. (kafka.log.Log)
[2017-04-24 22:46:57,939] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([IL2S-1, initOffset 2831945670 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,094] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-49 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,094] INFO Truncating log __consumer_offsets-49 to offset 0. (kafka.log.Log)
[2017-04-24 22:46:58,097] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([__consumer_offsets-49, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,100] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-28 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,101] INFO Truncating log __consumer_offsets-28 to offset 0. (kafka.log.Log)
[2017-04-24 22:46:58,103] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([__consumer_offsets-28, initOffset	0 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,106] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-4 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,107] INFO Truncating log __consumer_offsets-4 to offset 0. (kafka.log.Log)
[2017-04-24 22:46:58,109] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([__consumer_offsets-4, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,111] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-37 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,112] INFO Truncating log __consumer_offsets-37 to offset 0. (kafka.log.Log)
[2017-04-24 22:46:58,114] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([__consumer_offsets-37, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,117] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-31 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,117] INFO Truncating log __consumer_offsets-31 to offset 0. (kafka.log.Log)
[2017-04-24 22:46:58,119] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([__consumer_offsets-31, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,122] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-34 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,122] INFO Truncating log __consumer_offsets-34 to offset 0. (kafka.log.Log)
[2017-04-24 22:46:58,124] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([__consumer_offsets-34, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,127] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-46 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,127] INFO Truncating log __consumer_offsets-46 to offset 0. (kafka.log.Log)
[2017-04-24 22:46:58,130] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([__consumer_offsets-46, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,132] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-25 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,133] INFO Truncating log __consumer_offsets-25 to offset 0. (kafka.log.Log)
[2017-04-24 22:46:58,135] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([__consumer_offsets-25, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,138] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-43 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,138] INFO Truncating log __consumer_offsets-43 to offset 0. (kafka.log.Log)
[2017-04-24 22:46:58,141] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([__consumer_offsets-43, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,143] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-7 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,143] INFO Truncating log __consumer_offsets-7 to offset 0. (kafka.log.Log)
[2017-04-24 22:46:58,146] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([__consumer_offsets-7, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,148] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions test-0 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,149] INFO Truncating log test-0 to offset 5. (kafka.log.Log)
[2017-04-24 22:46:58,151] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([test-0, initOffset 5 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,153] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-1 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,153] INFO Truncating log __consumer_offsets-1 to offset 0. (kafka.log.Log)
[2017-04-24 22:46:58,155] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([__consumer_offsets-1, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,158] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-16 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,158] INFO Truncating log __consumer_offsets-16 to offset 0. (kafka.log.Log)
[2017-04-24 22:46:58,160] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([__consumer_offsets-16, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,163] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-30 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,163] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-30 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,391] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-30 in 228 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,393] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-39 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,394] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-39 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,396] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-39 in 2 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,402] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-18 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,402] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-18 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,404] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-0 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,404] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-18 in 2 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,404] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-0 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,410] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-24 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,411] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-0 in 4 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,411] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-24 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,412] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions IL2S-0 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,413] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-24 in 2 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,415] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-33 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,415] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-33 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,416] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-33 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,417] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions test-2 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,418] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-3 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,419] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-3 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,420] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-3 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,420] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-21 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,421] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-21 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,422] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-21 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,422] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions SEGMENT-0 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,424] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-12 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,425] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-12 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,426] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-15 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,427] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-12 in 2 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,427] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-15 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,428] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-15 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,429] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-48 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,430] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-48 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,431] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-48 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,431] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-6 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,431] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-6 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,432] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-6 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,432] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-42 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,433] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-42 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,434] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-42 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,435] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-27 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,435] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-27 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,437] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-27 in 2 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,437] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-45 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,437] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-45 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,439] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-45 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,439] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions DSLAM-1 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,440] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-36 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,441] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-36 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,442] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-9 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,442] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-36 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,442] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-9 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,444] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-9 in 2 millisecon[2017-04-24 22:46:58,434] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-42 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,435] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-27 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,435] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-27 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,437] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-27 in 2 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,437] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-45 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,437] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-45 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,439] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-45 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,439] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions DSLAM-1 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,440] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-36 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,441] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-36 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,442] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-9 (kafka.server.ReplicaFetcherManager)
[2017-04-24 22:46:58,442] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-36 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,442] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-9 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:46:58,444] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-9 in 2 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:51:10,914] INFO [Group Metadata Manager on Broker 73]: Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 22:53:01,450] INFO Rolled new log segment for 'SEGMENT-1' in 1 ms. (kafka.log.Log)
[2017-04-24 22:53:03,954] INFO Rolled new log segment for 'SEGMENT-0' in 1 ms. (kafka.log.Log)
[2017-04-24 22:53:06,609] INFO Rolled new log segment for 'SEGMENT-2' in 1 ms. (kafka.log.Log)
[2017-04-24 23:01:10,914] INFO [Group Metadata Manager on Broker 73]: Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.Gr
oupMetadataManager)
[2017-04-24 23:02:37,903] INFO Rolled new log segment for 'DSLAM-1' in 1 ms. (kafka.log.Log)
[2017-04-24 23:11:10,914] INFO [Group Metadata Manager on Broker 73]: Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.Gr
oupMetadataManager)
[2017-04-24 23:15:51,781] INFO Rolled new log segment for 'DSLAM-0' in 1 ms. (kafka.log.Log)
[2017-04-24 23:16:08,137] INFO Rolled new log segment for 'DSLAM-2' in 1 ms. (kafka.log.Log)
[2017-04-24 23:16:40,636] INFO Scheduling log segment 2350710897 for log IL2S-0 for deletion. (kafka.log.Log)
[2017-04-24 23:17:40,637] INFO Deleting segment 2350710897 from log IL2S-0. (kafka.log.Log)
[2017-04-24 23:17:40,646] INFO Deleting index /npm/application/Telemetry/kafka_2.12-0.10.2.0/logs/IL2S-0/00000000002350710897.index.dele
ted (kafka.log.OffsetIndex)
[2017-04-24 23:17:40,648] INFO Deleting index /npm/application/Telemetry/kafka_2.12-0.10.2.0/logs/IL2S-0/00000000002350710897.timeindex.
deleted (kafka.log.TimeIndex)
[2017-04-24 23:21:10,914] INFO [Group Metadata Manager on Broker 73]: Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.Gr
oupMetadataManager)
[2017-04-24 23:26:40,636] INFO Scheduling log segment 2591917648 for log DSLAM-1 for deletion. (kafka.log.Log)
[2017-04-24 23:26:40,637] INFO Scheduling log segment 2592043489 for log DSLAM-0 for deletion. (kafka.log.Log)
[2017-04-24 23:26:40,638] INFO Scheduling log segment 2592030929 for log DSLAM-2 for deletion. (kafka.log.Log)
[2017-04-24 23:27:40,637] INFO Deleting segment 2591917648 from log DSLAM-1. (kafka.log.Log)
[2017-04-24 23:27:40,638] INFO Deleting segment 2592043489 from log DSLAM-0. (kafka.log.Log)
[2017-04-24 23:27:40,638] INFO Deleting segment 2592030929 from log DSLAM-2. (kafka.log.Log)
[2017-04-24 23:27:40,652] INFO Deleting index /npm/application/Telemetry/kafka_2.12-0.10.2.0/logs/DSLAM-2/00000000002592030929.index.del
eted (kafka.log.OffsetIndex)
[2017-04-24 23:27:40,652] INFO Deleting index /npm/application/Telemetry/kafka_2.12-0.10.2.0/logs/DSLAM-1/00000000002591917648.index.del
eted (kafka.log.OffsetIndex)
[2017-04-24 23:27:40,652] INFO Deleting index /npm/application/Telemetry/kafka_2.12-0.10.2.0/logs/DSLAM-0/00000000002592043489.index.del
eted (kafka.log.OffsetIndex)
[2017-04-24 23:27:40,654] INFO Deleting index /npm/application/Telemetry/kafka_2.12-0.10.2.0/logs/DSLAM-2/00000000002592030929.timeindex
.deleted (kafka.log.TimeIndex)
[2017-04-24 23:27:40,654] INFO Deleting index /npm/application/Telemetry/kafka_2.12-0.10.2.0/logs/DSLAM-0/00000000002592043489.timeindex
.deleted (kafka.log.TimeIndex)
[2017-04-24 23:27:40,654] INFO Deleting index /npm/application/Telemetry/kafka_2.12-0.10.2.0/logs/DSLAM-1/00000000002591917648.timeindex
.deleted (kafka.log.TimeIndex)
[2017-04-24 23:31:10,914] INFO [Group Metadata Manager on Broker 73]: Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:41:10,914] INFO [Group Metadata Manager on Broker 73]: Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:14,007] INFO Creating /controller (is it secure? false) (kafka.utils.ZKCheckedEphemeral)
[2017-04-24 23:45:14,010] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral)
[2017-04-24 23:45:14,010] INFO 73 successfully elected as leader (kafka.server.ZookeeperLeaderElector)
[2017-04-24 23:45:14,433] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions IL2S-2,__consumer_offsets-8,__consumer_offsets-38,test-1,__consumer_offsets-2,__consumer_offsets-14,SEGMENT-2,__consumer_offsets-20,__consumer_offsets-44,__consumer_offsets-26,__consumer_offsets-32 (kafka.server.ReplicaFetcherManager)
[2017-04-24 23:45:14,435] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-11,__consumer_offsets-41,__consumer_offsets-17,__consumer_offsets-23,DSLAM-0,__consumer_offsets-47,__consumer_offsets-29,__consumer_offsets-5,__consumer_offsets-35 (kafka.server.ReplicaFetcherManager)
[2017-04-24 23:45:14,435] INFO Truncating log DSLAM-0 to offset 3107428388. (kafka.log.Log)
[2017-04-24 23:45:14,439] INFO Truncating log __consumer_offsets-35 to offset 0. (kafka.log.Log)
[2017-04-24 23:45:14,439] INFO Truncating log __consumer_offsets-41 to offset 684. (kafka.log.Log)
[2017-04-24 23:45:14,439] INFO Truncating log __consumer_offsets-23 to offset 9. (kafka.log.Log)
[2017-04-24 23:45:14,439] INFO Truncating log __consumer_offsets-47 to offset 0. (kafka.log.Log)
[2017-04-24 23:45:14,439] INFO Truncating log __consumer_offsets-17 to offset 11. (kafka.log.Log)
[2017-04-24 23:45:14,439] INFO Truncating log __consumer_offsets-11 to offset 0. (kafka.log.Log)
[2017-04-24 23:45:14,439] INFO Truncating log __consumer_offsets-5 to offset 0. (kafka.log.Log)
[2017-04-24 23:45:14,439] INFO Truncating log __consumer_offsets-29 to offset 0. (kafka.log.Log)
[2017-04-24 23:45:14,442] INFO [ReplicaFetcherManager on broker 73] Added fetcher for partitions List([DSLAM-0, initOffset 3107428388 to broker BrokerEndPoint(74,10.52.208.74,9092)] , [__consumer_offsets-35, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] , [__consumer_offsets-41, initOffset 684 to broker BrokerEndPoint(74,10.52.208.74,9092)] , [__consumer_offsets-23, initOffset 9 to broker BrokerEndPoint(74,10.52.208.74,9092)] , [__consumer_offsets-47, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] , [__consumer_offsets-17, initOffset 11 to broker BrokerEndPoint(74,10.52.208.74,9092)] , [__consumer_offsets-11, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] , [__consumer_offsets-5, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] , [__consumer_offsets-29, initOffset 0 to broker BrokerEndPoint(74,10.52.208.74,9092)] ) (kafka.server.ReplicaFetcherManager)
[2017-04-24 23:45:14,442] INFO New leader is 73 (kafka.server.ZookeeperLeaderElector$LeaderChangeListener)
[2017-04-24 23:45:14,443] INFO [ReplicaFetcherThread-0-72], Shutting down (kafka.server.ReplicaFetcherThread)
[2017-04-24 23:45:20,763] INFO Partition [__consumer_offsets,9] on broker 73: Shrinking ISR for partition [__consumer_offsets,9] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:20,767] INFO Partition [__consumer_offsets,42] on broker 73: Shrinking ISR for partition [__consumer_offsets,42] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:20,769] INFO Partition [__consumer_offsets,21] on broker 73: Shrinking ISR for partition [__consumer_offsets,21] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:20,771] INFO Partition [DSLAM,1] on broker 73: Shrinking ISR for partition [DSLAM,1] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,001] INFO Partition [__consumer_offsets,30] on broker 73: Shrinking ISR for partition [__consumer_offsets,30] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,005] INFO Partition [__consumer_offsets,45] on broker 73: Shrinking ISR for partition [__consumer_offsets,45] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,007] INFO Partition [SEGMENT,0] on broker 73: Shrinking ISR for partition [SEGMENT,0] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,009] INFO Partition [__consumer_offsets,12] on broker 73: Shrinking ISR for partition [__consumer_offsets,12] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,010] INFO Partition [IL2S,0] on broker 73: Shrinking ISR for partition [IL2S,0] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,012] INFO Partition [test,2] on broker 73: Shrinking ISR for partition [test,2] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,014] INFO Partition [__consumer_offsets,24] on broker 73: Shrinking ISR for partition [__consumer_offsets,24] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,016] INFO Partition [__consumer_offsets,0] on broker 73: Shrinking ISR for partition [__consumer_offsets,0] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,018] INFO Partition [__consumer_offsets,33] on broker 73: Shrinking ISR for partition [__consumer_offsets,33] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,020] INFO Partition [__consumer_offsets,15] on broker 73: Shrinking ISR for partition [__consumer_offsets,15] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,022] INFO Partition [__consumer_offsets,48] on broker 73: Shrinking ISR for partition [__consumer_offsets,48] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,023] INFO Partition [__consumer_offsets,3] on broker 73: Shrinking ISR for partition [__consumer_offsets,3] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,026] INFO Partition [__consumer_offsets,36] on broker 73: Shrinking ISR for partition [__consumer_offsets,36] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,028] INFO Partition [__consumer_offsets,18] on broker 73: Shrinking ISR for partition [__consumer_offsets,18] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,030] INFO Partition [__consumer_offsets,27] on broker 73: Shrinking ISR for partition [__consumer_offsets,27] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,032] INFO Partition [__consumer_offsets,39] on broker 73: Shrinking ISR for partition [__consumer_offsets,39] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:21,033] INFO Partition [__consumer_offsets,6] on broker 73: Shrinking ISR for partition [__consumer_offsets,6] from 72,73,74 to 73,74 (kafka.cluster.Partition)
[2017-04-24 23:45:38,443] INFO [ReplicaFetcherThread-0-72], Stopped  (kafka.server.ReplicaFetcherThread)
[2017-04-24 23:45:38,443] INFO [ReplicaFetcherThread-0-72], Shutdown completed (kafka.server.ReplicaFetcherThread)
[2017-04-24 23:45:38,447] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,666] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-44 in 219 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,666] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-2 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,668] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-2 in 2 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,668] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-8 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,669] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-8 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,669] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-14 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,670] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-14 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,670] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-20 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,673] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-20 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,673] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-26 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,674] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-26 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,674] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-32 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,676] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-32 in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,676] INFO [Group Metadata Manager on Broker 73]: Loading offsets and group metadata from __consumer_offsets-38 (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:45:38,678] INFO [Group Metadata Manager on Broker 73]: Finished loading offsets from __consumer_offsets-38 in 2 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-04-24 23:46:05,140] INFO Partition [__consumer_offsets,8] on broker 73: Expanding ISR for partition __consumer_offsets-8 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:05,143] INFO Partition [__consumer_offsets,38] on broker 73: Expanding ISR for partition __consumer_offsets-38 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:05,145] INFO Partition [__consumer_offsets,2] on broker 73: Expanding ISR for partition __consumer_offsets-2 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:05,147] INFO Partition [__consumer_offsets,14] on broker 73: Expanding ISR for partition __consumer_offsets-14 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:05,149] INFO Partition [__consumer_offsets,20] on broker 73: Expanding ISR for partition __consumer_offsets-20 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:05,151] INFO Partition [__consumer_offsets,44] on broker 73: Expanding ISR for partition __consumer_offsets-44 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:05,156] INFO Partition [__consumer_offsets,26] on broker 73: Expanding ISR for partition __consumer_offsets-26 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:05,159] INFO Partition [__consumer_offsets,32] on broker 73: Expanding ISR for partition __consumer_offsets-32 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:05,161] INFO Partition [test,1] on broker 73: Expanding ISR for partition test-1 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:05,163] INFO Partition [SEGMENT,2] on broker 73: Expanding ISR for partition SEGMENT-2 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,009] INFO Partition [IL2S,2] on broker 73: Expanding ISR for partition IL2S-2 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,161] INFO Partition [test,2] on broker 73: Expanding ISR for partition test-2 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,164] INFO Partition [__consumer_offsets,39] on broker 73: Expanding ISR for partition __consumer_offsets-39 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,165] INFO Partition [__consumer_offsets,6] on broker 73: Expanding ISR for partition __consumer_offsets-6 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,167] INFO Partition [__consumer_offsets,21] on broker 73: Expanding ISR for partition __consumer_offsets-21 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,169] INFO Partition [__consumer_offsets,3] on broker 73: Expanding ISR for partition __consumer_offsets-3 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,171] INFO Partition [__consumer_offsets,36] on broker 73: Expanding ISR for partition __consumer_offsets-36 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,173] INFO Partition [__consumer_offsets,18] on broker 73: Expanding ISR for partition __consumer_offsets-18 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,174] INFO Partition [__consumer_offsets,48] on broker 73: Expanding ISR for partition __consumer_offsets-48 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,176] INFO Partition [__consumer_offsets,0] on broker 73: Expanding ISR for partition __consumer_offsets-0 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,178] INFO Partition [__consumer_offsets,30] on broker 73: Expanding ISR for partition __consumer_offsets-30 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,180] INFO Partition [__consumer_offsets,33] on broker 73: Expanding ISR for partition __consumer_offsets-33 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,257] INFO Partition [__consumer_offsets,15] on broker 73: Expanding ISR for partition __consumer_offsets-15 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,260] INFO Partition [__consumer_offsets,45] on broker 73: Expanding ISR for partition __consumer_offsets-45 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,262] INFO Partition [SEGMENT,0] on broker 73: Expanding ISR for partition SEGMENT-0 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,263] INFO Partition [__consumer_offsets,27] on broker 73: Expanding ISR for partition __consumer_offsets-27 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,265] INFO Partition [__consumer_offsets,12] on broker 73: Expanding ISR for partition __consumer_offsets-12 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,267] INFO Partition [__consumer_offsets,9] on broker 73: Expanding ISR for partition __consumer_offsets-9 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,269] INFO Partition [__consumer_offsets,42] on broker 73: Expanding ISR for partition __consumer_offsets-42 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,270] INFO Partition [__consumer_offsets,24] on broker 73: Expanding ISR for partition __consumer_offsets-24 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:06,776] INFO Partition [DSLAM,1] on broker 73: Expanding ISR for partition DSLAM-1 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:46:17,793] INFO Partition [IL2S,0] on broker 73: Expanding ISR for partition IL2S-0 from 73,74 to 73,74,72 (kafka.cluster.Partition)
[2017-04-24 23:49:26,383] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions __consumer_offsets-22,__consumer_offsets-4,__consumer_offsets-46,__consumer_offsets-16,__consumer_offsets-28,DSLAM-2,__consumer_offsets-34,__consumer_offsets-10,__consumer_offsets-40 (kafka.server.ReplicaFetcherManager)
[2017-04-24 23:49:26,390] INFO [ReplicaFetcherManager on broker 73] Removed fetcher for partitions SEGMENT-1,__consumer_offsets-17,__consumer_offsets-43,__consumer_offsets-25,__consumer_offsets-47,__consumer_offsets-29,__consumer_offsets-37,__consumer_offsets-7,__consumer_offsets-11,__consumer_offsets-41,test-0,__consumer_offsets-23,DSLAM-0,__consumer_offsets-19,__consumer_offsets-49,__consumer_offsets-1,__consumer_offsets-31,IL2S-1,__consumer_offsets-5,__consumer_offsets-35,__consumer_offsets-13 (kafka.server.ReplicaFetcherManager)
[2017-04-24 23:49:26,390] INFO Truncating log IL2S-1 to offset 2847388757. (kafka.log.Log)
[2017-04-24 23:49:26,592] INFO Truncating log __consumer_offsets-7 to offset 0. (kafka.log.Log)
[2017-04-24 23:49:26,592] INFO Truncating log DSLAM-0 to offset 3107894030. (kafka.log.Log)
[2017-04-24 23:49:26,639] INFO Truncating log __consumer_offsets-25 to offset 0. (kafka.log.Log)
[2017-04-24 23:49:26,639] INFO Truncating log __consumer_offsets-35 to offset 0. (kafka.log.Log)
[2017-04-24 23:49:26,639] INFO Truncating log __consumer_offsets-41 to offset 684. (kafka.log.Log)
[2017-04-24 23:49:26,640] INFO Truncating log __consumer_offsets-23 to offset 9. (kafka.log.Log)
[2017-04-24 23:49:26,640] INFO Truncating log __consumer_offsets-49 to offset 0. (kafka.log.Log)
[2017-04-24 23:49:26,640] INFO Truncating log __consumer_offsets-47 to offset 0. (kafka.log.Log)
[2017-04-24 23:49:26,640] INFO Truncating log test-0 to offset 5. (kafka.log.Log)
[2017-04-24 23:49:26,640] INFO Truncating log __consumer_offsets-31 to offset 0. (kafka.log.Log)
[2017-04-24 23:49:26,640] INFO Truncating log __consumer_offsets-37 to offset 0. (kafka.log.Log)
[2017-04-24 23:49:26,640] INFO Truncating log __consumer_offsets-17 to offset 11. (kafka.log.Log)
[2017-04-24 23:49:26,640] INFO Truncating log __consumer_offsets-19 to offset 2. (kafka.log.Log)
[2017-04-24 23:49:26,640] INFO Truncating log __consumer_offsets-11 to offset 0. (kafka.log.Log)
[2017-04-24 23:49:26,640] INFO Truncating log __consumer_offsets-13 to offset 15. (kafka.log.Log)
[2017-04-24 23:49:26,640] INFO Truncating log __consumer_offsets-43 to offset 0. (kafka.log.Log)
[2017-04-24 23:49:26,640] INFO Truncating log __consumer_offsets-1 to offset 0. (kafka.log.Log)
[2017-04-24 23:49:26,640] INFO Truncating log __consumer_offsets-5 to offset 0. (kafka.log.Log)
[2017-04-24 23:49:26,640] INFO Truncating log __consumer_offsets-29 to offset 0. (kafka.log.Log)