[2017-11-02 23:55:31,860] INFO Partition [fcustomer_demographics,3] on broker 2: Expanding ISR for partition [fcustomer_demographics,3] from 2,1 to 2,1,0 (kafka.cluster.Partition)
[2017-11-02 23:55:31,865] INFO Partition [fcustomer_demographics,18] on broker 2: Expanding ISR for partition [fcustomer_demographics,18] from 2,1 to 2,1,0 (kafka.cluster.Partition)
[2017-11-02 23:55:31,869] INFO Partition [fcustomer_demographics,9] on broker 2: Expanding ISR for partition [fcustomer_demographics,9] from 2,1 to 2,1,0 (kafka.cluster.Partition)
[2017-11-02 23:55:31,874] INFO Partition [catalog_returns,4] on broker 2: Expanding ISR for partition [catalog_returns,4] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:31,878] INFO Partition [catalog_returns,10] on broker 2: Expanding ISR for partition [catalog_returns,10] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:31,883] INFO Partition [catalog_returns,13] on broker 2: Expanding ISR for partition [catalog_returns,13] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:31,888] INFO Partition [catalog_returns,19] on broker 2: Expanding ISR for partition [catalog_returns,19] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:31,892] INFO Partition [catalog_returns,1] on broker 2: Expanding ISR for partition [catalog_returns,1] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:31,896] INFO Partition [catalog_returns,7] on broker 2: Expanding ISR for partition [catalog_returns,7] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:31,901] INFO Partition [catalog_returns,16] on broker 2: Expanding ISR for partition [catalog_returns,16] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:31,905] INFO Partition [fcatalog_returns,19] on broker 2: Expanding ISR for partition [fcatalog_returns,19] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:32,589] INFO Rolled new log segment for 'store_returns-17' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:33,080] INFO Rolled new log segment for 'inventory-17' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:33,282] INFO Rolled new log segment for 'store_sales-8' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:33,378] INFO Rolled new log segment for 'store_sales-3' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:33,659] INFO Partition [web_returns,17] on broker 2: Expanding ISR for partition [web_returns,17] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:33,661] INFO Partition [web_returns,5] on broker 2: Expanding ISR for partition [web_returns,5] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:33,662] INFO Partition [web_returns,14] on broker 2: Expanding ISR for partition [web_returns,14] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:33,663] INFO Partition [web_returns,2] on broker 2: Expanding ISR for partition [web_returns,2] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:33,664] INFO Partition [web_returns,8] on broker 2: Expanding ISR for partition [web_returns,8] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:33,665] INFO Partition [fcustomer,12] on broker 2: Expanding ISR for partition [fcustomer,12] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:33,666] INFO Partition [fcustomer,18] on broker 2: Expanding ISR for partition [fcustomer,18] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:33,667] INFO Partition [fcustomer,0] on broker 2: Expanding ISR for partition [fcustomer,0] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:33,667] INFO Partition [fcustomer,9] on broker 2: Expanding ISR for partition [fcustomer,9] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:33,668] INFO Partition [fcustomer,15] on broker 2: Expanding ISR for partition [fcustomer,15] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:33,668] INFO Partition [fcustomer,6] on broker 2: Expanding ISR for partition [fcustomer,6] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:33,669] INFO Partition [fcustomer,3] on broker 2: Expanding ISR for partition [fcustomer,3] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:33,992] INFO Rolled new log segment for 'fweb_sales-12' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:34,151] INFO Rolled new log segment for 'store_sales-17' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:34,476] INFO Rolled new log segment for 'store_sales-1' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:34,697] INFO Rolled new log segment for 'store_sales-2' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:34,708] INFO Rolled new log segment for 'fstore_sales-7' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:34,778] INFO Rolled new log segment for 'store_sales-5' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:34,785] INFO Rolled new log segment for 'store_sales-13' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:34,799] INFO Rolled new log segment for 'store_sales-19' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:34,882] INFO Rolled new log segment for 'store_sales-7' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:35,041] INFO Rolled new log segment for 'store_sales-11' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:35,200] INFO Rolled new log segment for 'fstore_sales-13' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:35,201] INFO Partition [web_returns,11] on broker 2: Expanding ISR for partition [web_returns,11] from 2 to 2,0 (kafka.cluster.Partition)
[2017-11-02 23:55:35,483] INFO Rolled new log segment for 'fweb_sales-6' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:36,071] INFO Partition [fcustomer,12] on broker 2: Expanding ISR for partition [fcustomer,12] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:36,072] INFO Partition [fcustomer,18] on broker 2: Expanding ISR for partition [fcustomer,18] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:36,073] INFO Partition [fcustomer,0] on broker 2: Expanding ISR for partition [fcustomer,0] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:36,074] INFO Partition [fcustomer,9] on broker 2: Expanding ISR for partition [fcustomer,9] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:36,075] INFO Partition [fcustomer,15] on broker 2: Expanding ISR for partition [fcustomer,15] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:36,076] INFO Partition [fcustomer,6] on broker 2: Expanding ISR for partition [fcustomer,6] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:36,077] INFO Partition [fcustomer,3] on broker 2: Expanding ISR for partition [fcustomer,3] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:36,077] INFO Partition [web_returns,17] on broker 2: Expanding ISR for partition [web_returns,17] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:36,078] INFO Partition [web_returns,5] on broker 2: Expanding ISR for partition [web_returns,5] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:36,078] INFO Partition [web_returns,14] on broker 2: Expanding ISR for partition [web_returns,14] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:36,079] INFO Partition [web_returns,2] on broker 2: Expanding ISR for partition [web_returns,2] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:36,079] INFO Partition [web_returns,11] on broker 2: Expanding ISR for partition [web_returns,11] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:36,080] INFO Partition [web_returns,8] on broker 2: Expanding ISR for partition [web_returns,8] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:37,105] INFO Rolled new log segment for 'web_sales-14' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:37,521] INFO Rolled new log segment for 'web_sales-13' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:37,637] INFO Rolled new log segment for 'fstore_sales-17' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:37,649] INFO Rolled new log segment for 'web_sales-8' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:37,761] INFO Rolled new log segment for 'fstore_sales-11' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:37,999] INFO Rolled new log segment for 'fstore_sales-5' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:38,282] INFO Rolled new log segment for 'fstore_sales-1' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:38,725] INFO Rolled new log segment for 'fweb_sales-18' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:38,879] INFO Rolled new log segment for 'fstore_sales-19' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:38,884] INFO Rolled new log segment for 'fweb_sales-3' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:38,915] INFO Rolled new log segment for 'store_sales-9' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:39,490] INFO Rolled new log segment for 'store_sales-14' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:39,767] INFO Rolled new log segment for 'fweb_sales-0' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:41,264] INFO Rolled new log segment for 'web_sales-2' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:41,420] INFO Rolled new log segment for 'fcatalog_returns-8' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:42,996] INFO Rolled new log segment for 'fweb_sales-10' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:44,950] INFO Rolled new log segment for 'fstore_sales-3' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:44,954] INFO Rolled new log segment for 'store_sales-12' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:44,957] INFO Rolled new log segment for 'fstore_sales-2' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:44,969] INFO Rolled new log segment for 'store_sales-18' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:44,974] INFO Rolled new log segment for 'store_sales-0' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:44,984] INFO Rolled new log segment for 'store_sales-16' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:44,987] INFO Rolled new log segment for 'store_sales-6' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:45,001] INFO Rolled new log segment for 'fstore_sales-15' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:45,016] INFO Rolled new log segment for 'store_sales-4' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:45,024] INFO Rolled new log segment for 'store_sales-10' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:45,042] INFO Rolled new log segment for 'fstore_sales-9' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:45,045] INFO Rolled new log segment for 'fstore_sales-8' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:45,057] INFO Rolled new log segment for 'fstore_sales-14' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:45,239] WARN [ReplicaFetcherThread-0-0], Replica 2 for partition fstore_sales-3 reset its fetch offset from 2893348917 to current leader 0's start offset 2894582364 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,316] INFO Scheduling log segment 2892104557 for log fstore_sales-3 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,316] INFO Scheduling log segment 2892352281 for log fstore_sales-3 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,316] INFO Scheduling log segment 2892600276 for log fstore_sales-3 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,316] INFO Scheduling log segment 2892848213 for log fstore_sales-3 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,316] INFO Scheduling log segment 2893095867 for log fstore_sales-3 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,317] INFO Scheduling log segment 2893343716 for log fstore_sales-3 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,318] ERROR [ReplicaFetcherThread-0-0], Current offset 2893348917 for partition [fstore_sales,3] out of range; reset offset to 2894582364 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,345] WARN [ReplicaFetcherThread-0-0], Replica 2 for partition store_sales-12 reset its fetch offset from 2747582888 to current leader 0's start offset 2748517025 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,345] INFO Scheduling log segment 2746406147 for log store_sales-12 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,345] INFO Scheduling log segment 2746640176 for log store_sales-12 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,346] INFO Scheduling log segment 2746874440 for log store_sales-12 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,346] INFO Scheduling log segment 2747109021 for log store_sales-12 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,346] INFO Scheduling log segment 2747343482 for log store_sales-12 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,346] INFO Scheduling log segment 2747577967 for log store_sales-12 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,347] ERROR [ReplicaFetcherThread-0-0], Current offset 2747582888 for partition [store_sales,12] out of range; reset offset to 2748517025 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,348] WARN [ReplicaFetcherThread-0-0], Replica 2 for partition fstore_sales-2 reset its fetch offset from 2872302703 to current leader 0's start offset 2873536157 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,349] INFO Scheduling log segment 2871058368 for log fstore_sales-2 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,349] INFO Scheduling log segment 2871306071 for log fstore_sales-2 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,349] INFO Scheduling log segment 2871554074 for log fstore_sales-2 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,349] INFO Scheduling log segment 2871802014 for log fstore_sales-2 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,349] INFO Scheduling log segment 2872049686 for log fstore_sales-2 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,349] INFO Scheduling log segment 2872297502 for log fstore_sales-2 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,350] ERROR [ReplicaFetcherThread-0-0], Current offset 2872302703 for partition [fstore_sales,2] out of range; reset offset to 2873536157 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,385] WARN [ReplicaFetcherThread-0-0], Replica 2 for partition store_sales-18 reset its fetch offset from 2747590559 to current leader 0's start offset 2748524715 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,385] INFO Scheduling log segment 2746413854 for log store_sales-18 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,385] INFO Scheduling log segment 2746647867 for log store_sales-18 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,385] INFO Scheduling log segment 2746882095 for log store_sales-18 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,385] INFO Scheduling log segment 2747116670 for log store_sales-18 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,385] INFO Scheduling log segment 2747351133 for log store_sales-18 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,386] INFO Scheduling log segment 2747585638 for log store_sales-18 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,387] ERROR [ReplicaFetcherThread-0-0], Current offset 2747590559 for partition [store_sales,18] out of range; reset offset to 2748524715 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,391] WARN [ReplicaFetcherThread-0-0], Replica 2 for partition store_sales-0 reset its fetch offset from 2747601864 to current leader 0's start offset 2748536002 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,391] INFO Scheduling log segment 2746425123 for log store_sales-0 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,391] INFO Scheduling log segment 2746659199 for log store_sales-0 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,391] INFO Scheduling log segment 2746893451 for log store_sales-0 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,392] INFO Scheduling log segment 2747127998 for log store_sales-0 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,392] INFO Scheduling log segment 2747362439 for log store_sales-0 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,392] INFO Scheduling log segment 2747596942 for log store_sales-0 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,393] ERROR [ReplicaFetcherThread-0-0], Current offset 2747601864 for partition [store_sales,0] out of range; reset offset to 2748536002 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,399] WARN [ReplicaFetcherThread-0-0], Replica 2 for partition store_sales-16 reset its fetch offset from 2771949493 to current leader 0's start offset 2772883632 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,399] INFO Scheduling log segment 2770772703 for log store_sales-16 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,400] INFO Scheduling log segment 2771006766 for log store_sales-16 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,400] INFO Scheduling log segment 2771241010 for log store_sales-16 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,400] INFO Scheduling log segment 2771475595 for log store_sales-16 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,400] INFO Scheduling log segment 2771710076 for log store_sales-16 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,400] INFO Scheduling log segment 2771944573 for log store_sales-16 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,401] ERROR [ReplicaFetcherThread-0-0], Current offset 2771949493 for partition [store_sales,16] out of range; reset offset to 2772883632 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,402] WARN [ReplicaFetcherThread-0-0], Replica 2 for partition store_sales-6 reset its fetch offset from 2747358408 to current leader 0's start offset 2748292473 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,402] INFO Scheduling log segment 2746181777 for log store_sales-6 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,402] INFO Scheduling log segment 2746415816 for log store_sales-6 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,402] INFO Scheduling log segment 2746650037 for log store_sales-6 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,402] INFO Scheduling log segment 2746884591 for log store_sales-6 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,402] INFO Scheduling log segment 2747119039 for log store_sales-6 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,402] INFO Scheduling log segment 2747353488 for log store_sales-6 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,404] ERROR [ReplicaFetcherThread-0-0], Current offset 2747358408 for partition [store_sales,6] out of range; reset offset to 2748292473 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,416] WARN [ReplicaFetcherThread-0-0], Replica 2 for partition fstore_sales-15 reset its fetch offset from 2893347940 to current leader 0's start offset 2894581338 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,416] INFO Scheduling log segment 2892103641 for log fstore_sales-15 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,416] INFO Scheduling log segment 2892351341 for log fstore_sales-15 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,416] INFO Scheduling log segment 2892599335 for log fstore_sales-15 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,416] INFO Scheduling log segment 2892847232 for log fstore_sales-15 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,416] INFO Scheduling log segment 2893094905 for log fstore_sales-15 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,416] INFO Scheduling log segment 2893342738 for log fstore_sales-15 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,418] ERROR [ReplicaFetcherThread-0-0], Current offset 2893347940 for partition [fstore_sales,15] out of range; reset offset to 2894581338 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,430] WARN [ReplicaFetcherThread-0-0], Replica 2 for partition store_sales-4 reset its fetch offset from 2771944153 to current leader 0's start offset 2772878259 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,430] INFO Scheduling log segment 2770767399 for log store_sales-4 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,430] INFO Scheduling log segment 2771001461 for log store_sales-4 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,430] INFO Scheduling log segment 2771235732 for log store_sales-4 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,430] INFO Scheduling log segment 2771470309 for log store_sales-4 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,430] INFO Scheduling log segment 2771704770 for log store_sales-4 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,430] INFO Scheduling log segment 2771939233 for log store_sales-4 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,432] ERROR [ReplicaFetcherThread-0-0], Current offset 2771944153 for partition [store_sales,4] out of range; reset offset to 2772878259 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,439] WARN [ReplicaFetcherThread-0-0], Replica 2 for partition store_sales-10 reset its fetch offset from 2762094098 to current leader 0's start offset 2763028167 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,439] INFO Scheduling log segment 2760917481 for log store_sales-10 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,439] INFO Scheduling log segment 2761151510 for log store_sales-10 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,439] INFO Scheduling log segment 2761385716 for log store_sales-10 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,439] INFO Scheduling log segment 2761620235 for log store_sales-10 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,439] INFO Scheduling log segment 2761854702 for log store_sales-10 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,439] INFO Scheduling log segment 2762089177 for log store_sales-10 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,440] ERROR [ReplicaFetcherThread-0-0], Current offset 2762094098 for partition [store_sales,10] out of range; reset offset to 2763028167 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,455] WARN [ReplicaFetcherThread-0-0], Replica 2 for partition fstore_sales-9 reset its fetch offset from 2893351132 to current leader 0's start offset 2894584597 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,455] INFO Scheduling log segment 2892106816 for log fstore_sales-9 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,456] INFO Scheduling log segment 2892354547 for log fstore_sales-9 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,456] INFO Scheduling log segment 2892602543 for log fstore_sales-9 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,456] INFO Scheduling log segment 2892850449 for log fstore_sales-9 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,456] INFO Scheduling log segment 2893098101 for log fstore_sales-9 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,456] INFO Scheduling log segment 2893345931 for log fstore_sales-9 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,457] ERROR [ReplicaFetcherThread-0-0], Current offset 2893351132 for partition [fstore_sales,9] out of range; reset offset to 2894584597 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,459] WARN [ReplicaFetcherThread-0-0], Replica 2 for partition fstore_sales-8 reset its fetch offset from 2872290413 to current leader 0's start offset 2873523770 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,459] INFO Scheduling log segment 2871046126 for log fstore_sales-8 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,459] INFO Scheduling log segment 2871293869 for log fstore_sales-8 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,459] INFO Scheduling log segment 2871541910 for log fstore_sales-8 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,459] INFO Scheduling log segment 2871789806 for log fstore_sales-8 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,459] INFO Scheduling log segment 2872037418 for log fstore_sales-8 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,459] INFO Scheduling log segment 2872285212 for log fstore_sales-8 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,461] ERROR [ReplicaFetcherThread-0-0], Current offset 2872290413 for partition [fstore_sales,8] out of range; reset offset to 2873523770 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,470] WARN [ReplicaFetcherThread-0-0], Replica 2 for partition fstore_sales-14 reset its fetch offset from 2872303305 to current leader 0's start offset 2873536649 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,470] INFO Scheduling log segment 2871059010 for log fstore_sales-14 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,470] INFO Scheduling log segment 2871306657 for log fstore_sales-14 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,470] INFO Scheduling log segment 2871554624 for log fstore_sales-14 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,470] INFO Scheduling log segment 2871802549 for log fstore_sales-14 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,470] INFO Scheduling log segment 2872050243 for log fstore_sales-14 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,470] INFO Scheduling log segment 2872298104 for log fstore_sales-14 for deletion. (kafka.log.Log)
[2017-11-02 23:55:45,472] ERROR [ReplicaFetcherThread-0-0], Current offset 2872303305 for partition [fstore_sales,14] out of range; reset offset to 2873536649 (kafka.server.ReplicaFetcherThread)
[2017-11-02 23:55:45,533] INFO Partition [catalog_returns,10] on broker 2: Expanding ISR for partition [catalog_returns,10] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:45,534] INFO Partition [catalog_returns,13] on broker 2: Expanding ISR for partition [catalog_returns,13] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:45,535] INFO Partition [catalog_returns,19] on broker 2: Expanding ISR for partition [catalog_returns,19] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:45,537] INFO Partition [catalog_returns,16] on broker 2: Expanding ISR for partition [catalog_returns,16] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:46,233] INFO Rolled new log segment for 'fweb_returns-3' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:46,817] INFO Rolled new log segment for 'fcatalog_returns-5' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:47,405] INFO Partition [catalog_returns,4] on broker 2: Expanding ISR for partition [catalog_returns,4] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:47,407] INFO Partition [catalog_returns,1] on broker 2: Expanding ISR for partition [catalog_returns,1] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:47,408] INFO Partition [catalog_returns,7] on broker 2: Expanding ISR for partition [catalog_returns,7] from 2,0 to 2,0,1 (kafka.cluster.Partition)
[2017-11-02 23:55:47,822] INFO Rolled new log segment for 'catalog_sales-1' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:47,869] INFO Rolled new log segment for 'fweb_sales-8' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:47,894] INFO Rolled new log segment for 'catalog_sales-9' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:48,116] INFO Partition [fcatalog_returns,1] on broker 2: Shrinking ISR for partition [fcatalog_returns,1] from 2,0 to 2 (kafka.cluster.Partition)
[2017-11-02 23:55:48,117] INFO Partition [fcatalog_returns,16] on broker 2: Shrinking ISR for partition [fcatalog_returns,16] from 2,0 to 2 (kafka.cluster.Partition)
[2017-11-02 23:55:48,118] INFO Partition [fcatalog_returns,10] on broker 2: Shrinking ISR for partition [fcatalog_returns,10] from 2,0 to 2 (kafka.cluster.Partition)
[2017-11-02 23:55:48,119] INFO Partition [fcatalog_returns,19] on broker 2: Shrinking ISR for partition [fcatalog_returns,19] from 2,0 to 2 (kafka.cluster.Partition)
[2017-11-02 23:55:48,120] INFO Partition [fcatalog_returns,4] on broker 2: Shrinking ISR for partition [fcatalog_returns,4] from 2,0 to 2 (kafka.cluster.Partition)
[2017-11-02 23:55:48,121] INFO Partition [fcatalog_returns,7] on broker 2: Shrinking ISR for partition [fcatalog_returns,7] from 2,0 to 2 (kafka.cluster.Partition)
[2017-11-02 23:55:48,122] INFO Partition [fcatalog_returns,13] on broker 2: Shrinking ISR for partition [fcatalog_returns,13] from 2,0 to 2 (kafka.cluster.Partition)
[2017-11-02 23:55:48,202] INFO Rolled new log segment for 'catalog_sales-19' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:48,252] INFO Rolled new log segment for 'fweb_sales-4' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:48,847] INFO Rolled new log segment for 'fstore_sales-6' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:48,930] INFO Rolled new log segment for 'fweb_sales-17' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:48,962] INFO Rolled new log segment for 'fstore_sales-10' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:48,986] INFO Rolled new log segment for 'fstore_sales-16' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:49,083] INFO Rolled new log segment for 'fstore_sales-12' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:49,130] INFO Rolled new log segment for 'fstore_sales-0' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:49,328] INFO Rolled new log segment for 'fstore_sales-18' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:49,379] INFO Rolled new log segment for 'fweb_returns-16' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:49,401] INFO Rolled new log segment for 'fcatalog_sales-10' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:49,407] INFO Rolled new log segment for 'fcatalog_sales-18' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:49,438] INFO Rolled new log segment for 'fcatalog_sales-16' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:49,445] INFO Rolled new log segment for 'fcatalog_sales-6' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:49,451] INFO Rolled new log segment for 'catalog_sales-7' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:49,454] INFO Rolled new log segment for 'fcatalog_sales-4' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:49,456] INFO Rolled new log segment for 'catalog_sales-5' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:49,458] INFO Rolled new log segment for 'catalog_sales-15' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:49,462] INFO Rolled new log segment for 'fcatalog_sales-12' in 0 ms. (kafka.log.Log)
[2017-11-02 23:55:49,484] INFO Rolled new log segment for 'catalog_sales-13' in 1 ms. (kafka.log.Log)
[2017-11-02 23:55:49,602] FATAL [ReplicaFetcherThread-0-0], Disk error while replicating data for catalog_sales-3 (kafka.server.ReplicaFetcherThread)
kafka.common.KafkaStorageException: I/O exception in append to log 'catalog_sales-3'
	at kafka.log.Log.append(Log.scala:349)
	at kafka.server.ReplicaFetcherThread.processPartitionData(ReplicaFetcherThread.scala:130)
	at kafka.server.ReplicaFetcherThread.processPartitionData(ReplicaFetcherThread.scala:42)
	at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2$$anonfun$apply$mcV$sp$1$$anonfun$apply$2.apply(AbstractFetcherThread.scala:159)
	at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2$$anonfun$apply$mcV$sp$1$$anonfun$apply$2.apply(AbstractFetcherThread.scala:141)
	at scala.Option.foreach(Option.scala:257)
	at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2$$anonfun$apply$mcV$sp$1.apply(AbstractFetcherThread.scala:141)
	at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2$$anonfun$apply$mcV$sp$1.apply(AbstractFetcherThread.scala:138)
	at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
	at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
	at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2.apply$mcV$sp(AbstractFetcherThread.scala:138)
	at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2.apply(AbstractFetcherThread.scala:138)
	at kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$2.apply(AbstractFetcherThread.scala:138)
	at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:234)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:136)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:103)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
Caused by: java.io.IOException: Map failed
	at sun.nio.ch.FileChannelImpl.map(FileChannelImpl.java:940)
	at kafka.log.AbstractIndex$$anonfun$resize$1.apply(AbstractIndex.scala:116)
	at kafka.log.AbstractIndex$$anonfun$resize$1.apply(AbstractIndex.scala:106)
	at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:234)
	at kafka.log.AbstractIndex.resize(AbstractIndex.scala:106)
	at kafka.log.AbstractIndex$$anonfun$trimToValidSize$1.apply$mcV$sp(AbstractIndex.scala:160)
	at kafka.log.AbstractIndex$$anonfun$trimToValidSize$1.apply(AbstractIndex.scala:160)
	at kafka.log.AbstractIndex$$anonfun$trimToValidSize$1.apply(AbstractIndex.scala:160)
	at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:234)
	at kafka.log.AbstractIndex.trimToValidSize(AbstractIndex.scala:159)
	at kafka.log.Log.roll(Log.scala:771)
	at kafka.log.Log.maybeRoll(Log.scala:742)
	at kafka.log.Log.append(Log.scala:405)
	... 16 more
Caused by: java.lang.OutOfMemoryError: Map failed
	at sun.nio.ch.FileChannelImpl.map0(Native Method)
	at sun.nio.ch.FileChannelImpl.map(FileChannelImpl.java:937)
	... 28 more