[2017-11-03 00:55:44,204] INFO Scheduling log segment 2771506424 for log store_sales-12 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,204] INFO Scheduling log segment 2771740854 for log store_sales-12 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,204] INFO Scheduling log segment 2771975535 for log store_sales-12 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,204] INFO Scheduling log segment 2772210466 for log store_sales-12 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,205] INFO Scheduling log segment 2772445545 for log store_sales-12 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,205] INFO Scheduling log segment 2772680301 for log store_sales-12 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,205] INFO Scheduling log segment 2772914645 for log store_sales-12 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,205] INFO Scheduling log segment 2773148707 for log store_sales-12 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,205] INFO Scheduling log segment 698260482 for log web_sales-5 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,205] INFO Scheduling log segment 698448733 for log web_sales-5 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,205] INFO Scheduling log segment 698636966 for log web_sales-5 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,205] INFO Scheduling log segment 1391054797 for log catalog_sales-7 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,206] INFO Scheduling log segment 1391239732 for log catalog_sales-7 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,206] INFO Scheduling log segment 1391424958 for log catalog_sales-7 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,206] INFO Scheduling log segment 1391609980 for log catalog_sales-7 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,206] INFO Scheduling log segment 1391794873 for log catalog_sales-7 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,206] INFO Scheduling log segment 1391979845 for log catalog_sales-7 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,206] INFO Scheduling log segment 2763767519 for log store_sales-3 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,206] INFO Scheduling log segment 2764002610 for log store_sales-3 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,206] INFO Scheduling log segment 2764237486 for log store_sales-3 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,206] INFO Scheduling log segment 2764472147 for log store_sales-3 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,206] INFO Scheduling log segment 2764706241 for log store_sales-3 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,207] INFO Scheduling log segment 2764940327 for log store_sales-3 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,207] INFO Scheduling log segment 682256528 for log web_sales-16 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,207] INFO Scheduling log segment 682444766 for log web_sales-16 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,207] INFO Scheduling log segment 682633005 for log web_sales-16 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,208] INFO Scheduling log segment 266569202 for log store_returns-6 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,208] INFO Scheduling log segment 713204726 for log inventory-14 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,208] INFO Scheduling log segment 719367983 for log inventory-16 for deletion. (kafka.log.Log)
[2017-11-03 00:55:44,287] INFO Partition [web_returns,3] on broker 0: Shrinking ISR for partition [web_returns,3] from 0,1,2 to 0,2 (kafka.cluster.Partition)
[2017-11-03 00:55:44,294] INFO Partition [catalog_returns,17] on broker 0: Shrinking ISR for partition [catalog_returns,17] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:44,298] INFO Partition [web_returns,9] on broker 0: Shrinking ISR for partition [web_returns,9] from 0,1,2 to 0,2 (kafka.cluster.Partition)
[2017-11-03 00:55:44,303] INFO Partition [catalog_returns,11] on broker 0: Shrinking ISR for partition [catalog_returns,11] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:44,308] INFO Partition [catalog_returns,5] on broker 0: Shrinking ISR for partition [catalog_returns,5] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:44,312] INFO Partition [web_returns,6] on broker 0: Shrinking ISR for partition [web_returns,6] from 0,1,2 to 0,2 (kafka.cluster.Partition)
[2017-11-03 00:55:44,317] INFO Partition [catalog_returns,8] on broker 0: Shrinking ISR for partition [catalog_returns,8] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:44,322] INFO Partition [web_returns,15] on broker 0: Shrinking ISR for partition [web_returns,15] from 0,1,2 to 0,2 (kafka.cluster.Partition)
[2017-11-03 00:55:44,326] INFO Partition [web_returns,18] on broker 0: Shrinking ISR for partition [web_returns,18] from 0,1,2 to 0,2 (kafka.cluster.Partition)
[2017-11-03 00:55:44,331] INFO Partition [catalog_returns,14] on broker 0: Shrinking ISR for partition [catalog_returns,14] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:44,335] INFO Partition [catalog_returns,2] on broker 0: Shrinking ISR for partition [catalog_returns,2] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:44,340] INFO Partition [web_returns,12] on broker 0: Shrinking ISR for partition [web_returns,12] from 0,1,2 to 0,2 (kafka.cluster.Partition)
[2017-11-03 00:55:44,344] INFO Partition [web_returns,0] on broker 0: Shrinking ISR for partition [web_returns,0] from 0,1,2 to 0,2 (kafka.cluster.Partition)
[2017-11-03 00:55:44,758] INFO Rolled new log segment for 'web_sales-15' in 0 ms. (kafka.log.Log)
[2017-11-03 00:55:44,764] INFO Rolled new log segment for 'web_sales-12' in 0 ms. (kafka.log.Log)
[2017-11-03 00:55:44,851] INFO Rolled new log segment for 'catalog_sales-14' in 0 ms. (kafka.log.Log)
[2017-11-03 00:55:44,854] INFO Rolled new log segment for 'catalog_sales-4' in 0 ms. (kafka.log.Log)
[2017-11-03 00:55:44,860] INFO Rolled new log segment for 'catalog_sales-10' in 0 ms. (kafka.log.Log)
[2017-11-03 00:55:46,361] INFO Rolled new log segment for 'web_sales-19' in 1 ms. (kafka.log.Log)
[2017-11-03 00:55:47,540] INFO Rolled new log segment for 'store_sales-12' in 1 ms. (kafka.log.Log)
[2017-11-03 00:55:47,793] INFO Rolled new log segment for 'fcatalog_sales-19' in 0 ms. (kafka.log.Log)
[2017-11-03 00:55:47,796] INFO Rolled new log segment for 'catalog_sales-2' in 0 ms. (kafka.log.Log)
[2017-11-03 00:55:47,800] INFO Rolled new log segment for 'catalog_sales-16' in 0 ms. (kafka.log.Log)
[2017-11-03 00:55:48,498] INFO Rolled new log segment for 'store_sales-16' in 1 ms. (kafka.log.Log)
[2017-11-03 00:55:48,844] INFO Rolled new log segment for 'store_sales-10' in 1 ms. (kafka.log.Log)
[2017-11-03 00:55:48,888] INFO Rolled new log segment for 'store_sales-6' in 1 ms. (kafka.log.Log)
[2017-11-03 00:55:49,357] INFO Partition [inventory,0] on broker 0: Expanding ISR for partition [inventory,0] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:55:49,365] INFO Partition [inventory,15] on broker 0: Expanding ISR for partition [inventory,15] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:55:49,370] INFO Partition [inventory,18] on broker 0: Expanding ISR for partition [inventory,18] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:55:49,374] INFO Partition [inventory,6] on broker 0: Expanding ISR for partition [inventory,6] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:55:49,379] INFO Partition [inventory,12] on broker 0: Expanding ISR for partition [inventory,12] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:55:49,384] INFO Partition [inventory,3] on broker 0: Expanding ISR for partition [inventory,3] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:55:49,389] INFO Partition [inventory,9] on broker 0: Expanding ISR for partition [inventory,9] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:55:49,599] INFO Partition [web_returns,18] on broker 0: Expanding ISR for partition [web_returns,18] from 0,2 to 0,2,1 (kafka.cluster.Partition)
[2017-11-03 00:55:49,605] INFO Partition [web_returns,6] on broker 0: Expanding ISR for partition [web_returns,6] from 0,2 to 0,2,1 (kafka.cluster.Partition)
[2017-11-03 00:55:49,610] INFO Partition [web_returns,9] on broker 0: Expanding ISR for partition [web_returns,9] from 0,2 to 0,2,1 (kafka.cluster.Partition)
[2017-11-03 00:55:49,615] INFO Partition [web_returns,3] on broker 0: Expanding ISR for partition [web_returns,3] from 0,2 to 0,2,1 (kafka.cluster.Partition)
[2017-11-03 00:55:49,619] INFO Partition [web_returns,12] on broker 0: Expanding ISR for partition [web_returns,12] from 0,2 to 0,2,1 (kafka.cluster.Partition)
[2017-11-03 00:55:49,624] INFO Partition [web_returns,15] on broker 0: Expanding ISR for partition [web_returns,15] from 0,2 to 0,2,1 (kafka.cluster.Partition)
[2017-11-03 00:55:49,629] INFO Partition [web_returns,0] on broker 0: Expanding ISR for partition [web_returns,0] from 0,2 to 0,2,1 (kafka.cluster.Partition)
[2017-11-03 00:55:49,747] INFO Rolled new log segment for 'store_sales-4' in 1 ms. (kafka.log.Log)
[2017-11-03 00:55:50,015] INFO Rolled new log segment for 'store_sales-0' in 0 ms. (kafka.log.Log)
[2017-11-03 00:55:50,329] INFO Rolled new log segment for 'store_sales-18' in 1 ms. (kafka.log.Log)
[2017-11-03 00:55:50,646] INFO Rolled new log segment for 'web_sales-14' in 1 ms. (kafka.log.Log)
[2017-11-03 00:55:51,354] INFO Rolled new log segment for 'catalog_returns-0' in 1 ms. (kafka.log.Log)
[2017-11-03 00:55:51,361] INFO Rolled new log segment for 'catalog_returns-12' in 0 ms. (kafka.log.Log)
[2017-11-03 00:55:54,287] INFO Partition [web_returns,3] on broker 0: Shrinking ISR for partition [web_returns,3] from 0,2,1 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,295] INFO Partition [inventory,15] on broker 0: Shrinking ISR for partition [inventory,15] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,302] INFO Partition [inventory,12] on broker 0: Shrinking ISR for partition [inventory,12] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,310] INFO Partition [inventory,0] on broker 0: Shrinking ISR for partition [inventory,0] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,318] INFO Partition [customer_address,18] on broker 0: Shrinking ISR for partition [customer_address,18] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,325] INFO Partition [inventory,3] on broker 0: Shrinking ISR for partition [inventory,3] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,333] INFO Partition [inventory,6] on broker 0: Shrinking ISR for partition [inventory,6] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,342] INFO Partition [customer_address,0] on broker 0: Shrinking ISR for partition [customer_address,0] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,350] INFO Partition [web_returns,9] on broker 0: Shrinking ISR for partition [web_returns,9] from 0,2,1 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,352] INFO Rolled new log segment for 'web_sales-11' in 1 ms. (kafka.log.Log)
[2017-11-03 00:55:54,358] INFO Partition [customer_address,6] on broker 0: Shrinking ISR for partition [customer_address,6] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,366] INFO Partition [customer_address,15] on broker 0: Shrinking ISR for partition [customer_address,15] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,374] INFO Partition [web_returns,6] on broker 0: Shrinking ISR for partition [web_returns,6] from 0,2,1 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,382] INFO Partition [web_returns,15] on broker 0: Shrinking ISR for partition [web_returns,15] from 0,2,1 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,390] INFO Partition [customer_address,12] on broker 0: Shrinking ISR for partition [customer_address,12] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,398] INFO Partition [web_returns,18] on broker 0: Shrinking ISR for partition [web_returns,18] from 0,2,1 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,406] INFO Partition [inventory,18] on broker 0: Shrinking ISR for partition [inventory,18] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,414] INFO Partition [inventory,9] on broker 0: Shrinking ISR for partition [inventory,9] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,623] INFO Partition [web_returns,12] on broker 0: Shrinking ISR for partition [web_returns,12] from 0,2,1 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,630] INFO Partition [customer_address,3] on broker 0: Shrinking ISR for partition [customer_address,3] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,639] INFO Partition [web_returns,0] on broker 0: Shrinking ISR for partition [web_returns,0] from 0,2,1 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,647] INFO Partition [customer_address,9] on broker 0: Shrinking ISR for partition [customer_address,9] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:55:54,963] INFO Rolled new log segment for 'store_returns-14' in 1 ms. (kafka.log.Log)
[2017-11-03 00:55:55,059] INFO Partition [web_returns,9] on broker 0: Expanding ISR for partition [web_returns,9] from 0 to 0,2 (kafka.cluster.Partition)
[2017-11-03 00:55:55,069] INFO Partition [web_returns,18] on broker 0: Expanding ISR for partition [web_returns,18] from 0 to 0,2 (kafka.cluster.Partition)
[2017-11-03 00:55:55,077] INFO Partition [web_returns,0] on broker 0: Expanding ISR for partition [web_returns,0] from 0 to 0,2 (kafka.cluster.Partition)
[2017-11-03 00:55:55,085] INFO Partition [web_returns,6] on broker 0: Expanding ISR for partition [web_returns,6] from 0 to 0,2 (kafka.cluster.Partition)
[2017-11-03 00:55:55,092] INFO Partition [web_returns,3] on broker 0: Expanding ISR for partition [web_returns,3] from 0 to 0,2 (kafka.cluster.Partition)
[2017-11-03 00:55:55,100] INFO Partition [web_returns,12] on broker 0: Expanding ISR for partition [web_returns,12] from 0 to 0,2 (kafka.cluster.Partition)
[2017-11-03 00:55:55,107] INFO Partition [web_returns,15] on broker 0: Expanding ISR for partition [web_returns,15] from 0 to 0,2 (kafka.cluster.Partition)
[2017-11-03 00:55:55,158] INFO Partition [web_returns,18] on broker 0: Expanding ISR for partition [web_returns,18] from 0,2 to 0,2,1 (kafka.cluster.Partition)
[2017-11-03 00:55:55,166] INFO Partition [web_returns,6] on broker 0: Expanding ISR for partition [web_returns,6] from 0,2 to 0,2,1 (kafka.cluster.Partition)
[2017-11-03 00:55:55,174] INFO Partition [web_returns,9] on broker 0: Expanding ISR for partition [web_returns,9] from 0,2 to 0,2,1 (kafka.cluster.Partition)
[2017-11-03 00:55:55,182] INFO Partition [web_returns,3] on broker 0: Expanding ISR for partition [web_returns,3] from 0,2 to 0,2,1 (kafka.cluster.Partition)
[2017-11-03 00:55:55,191] INFO Partition [web_returns,12] on broker 0: Expanding ISR for partition [web_returns,12] from 0,2 to 0,2,1 (kafka.cluster.Partition)
[2017-11-03 00:55:55,199] INFO Partition [web_returns,15] on broker 0: Expanding ISR for partition [web_returns,15] from 0,2 to 0,2,1 (kafka.cluster.Partition)
[2017-11-03 00:55:55,207] INFO Partition [web_returns,0] on broker 0: Expanding ISR for partition [web_returns,0] from 0,2 to 0,2,1 (kafka.cluster.Partition)
[2017-11-03 00:55:55,909] INFO Rolled new log segment for 'inventory-0' in 1 ms. (kafka.log.Log)
[2017-11-03 00:55:58,514] INFO Rolled new log segment for 'inventory-3' in 1 ms. (kafka.log.Log)
[2017-11-03 00:55:59,085] INFO Partition [customer_address,9] on broker 0: Expanding ISR for partition [customer_address,9] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:55:59,093] INFO Partition [customer_address,0] on broker 0: Expanding ISR for partition [customer_address,0] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:55:59,097] INFO Partition [customer_address,18] on broker 0: Expanding ISR for partition [customer_address,18] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:55:59,102] INFO Partition [customer_address,15] on broker 0: Expanding ISR for partition [customer_address,15] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:55:59,106] INFO Partition [customer_address,3] on broker 0: Expanding ISR for partition [customer_address,3] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:55:59,110] INFO Partition [customer_address,6] on broker 0: Expanding ISR for partition [customer_address,6] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:55:59,114] INFO Partition [customer_address,12] on broker 0: Expanding ISR for partition [customer_address,12] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:55:59,251] INFO Rolled new log segment for 'web_sales-6' in 0 ms. (kafka.log.Log)
[2017-11-03 00:55:59,263] INFO Rolled new log segment for 'inventory-6' in 1 ms. (kafka.log.Log)
[2017-11-03 00:55:59,306] INFO Rolled new log segment for 'fcatalog_sales-1' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:00,962] INFO Rolled new log segment for 'web_sales-5' in 5 ms. (kafka.log.Log)
[2017-11-03 00:56:01,215] INFO Partition [customer_address,0] on broker 0: Expanding ISR for partition [customer_address,0] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:01,225] INFO Partition [customer_address,9] on broker 0: Expanding ISR for partition [customer_address,9] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:01,231] INFO Partition [customer_address,18] on broker 0: Expanding ISR for partition [customer_address,18] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:01,442] INFO Partition [customer_address,15] on broker 0: Expanding ISR for partition [customer_address,15] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:01,446] INFO Partition [customer_address,6] on broker 0: Expanding ISR for partition [customer_address,6] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:01,452] INFO Partition [customer_address,12] on broker 0: Expanding ISR for partition [customer_address,12] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:01,457] INFO Partition [customer_address,3] on broker 0: Expanding ISR for partition [customer_address,3] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:03,106] INFO Rolled new log segment for 'inventory-9' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:03,463] INFO Rolled new log segment for 'web_sales-17' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:03,643] INFO Partition [catalog_returns,11] on broker 0: Expanding ISR for partition [catalog_returns,11] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:03,650] INFO Partition [catalog_returns,17] on broker 0: Expanding ISR for partition [catalog_returns,17] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:03,655] INFO Partition [catalog_returns,2] on broker 0: Expanding ISR for partition [catalog_returns,2] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:03,661] INFO Partition [catalog_returns,5] on broker 0: Expanding ISR for partition [catalog_returns,5] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:03,703] INFO Rolled new log segment for 'inventory-15' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:03,745] INFO Rolled new log segment for 'inventory-12' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:03,867] INFO Partition [catalog_returns,8] on broker 0: Expanding ISR for partition [catalog_returns,8] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:03,871] INFO Partition [catalog_returns,14] on broker 0: Expanding ISR for partition [catalog_returns,14] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:05,509] INFO Rolled new log segment for 'store_sales-2' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:05,937] INFO Rolled new log segment for 'store_sales-8' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:05,944] INFO Rolled new log segment for 'store_sales-3' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:06,513] INFO Rolled new log segment for 'store_sales-15' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:06,966] INFO Partition [catalog_returns,2] on broker 0: Expanding ISR for partition [catalog_returns,2] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:06,971] INFO Partition [catalog_returns,17] on broker 0: Expanding ISR for partition [catalog_returns,17] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:06,976] INFO Partition [catalog_returns,11] on broker 0: Expanding ISR for partition [catalog_returns,11] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:06,981] INFO Partition [catalog_returns,5] on broker 0: Expanding ISR for partition [catalog_returns,5] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:06,986] INFO Partition [catalog_returns,8] on broker 0: Expanding ISR for partition [catalog_returns,8] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:06,990] INFO Partition [catalog_returns,14] on broker 0: Expanding ISR for partition [catalog_returns,14] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:07,034] INFO Rolled new log segment for 'store_sales-9' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:07,429] INFO Rolled new log segment for 'store_sales-14' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:08,275] INFO Rolled new log segment for 'inventory-18' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:10,421] INFO Rolled new log segment for 'web_sales-18' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:14,012] INFO Rolled new log segment for 'fstore_sales-12' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:14,287] INFO Partition [customer_demographics,17] on broker 0: Shrinking ISR for partition [customer_demographics,17] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:56:14,292] INFO Partition [customer_demographics,14] on broker 0: Shrinking ISR for partition [customer_demographics,14] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:56:14,296] INFO Partition [customer_demographics,2] on broker 0: Shrinking ISR for partition [customer_demographics,2] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:56:14,300] INFO Partition [customer_demographics,11] on broker 0: Shrinking ISR for partition [customer_demographics,11] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:56:14,303] INFO Partition [customer_demographics,8] on broker 0: Shrinking ISR for partition [customer_demographics,8] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:56:14,307] INFO Partition [customer_demographics,5] on broker 0: Shrinking ISR for partition [customer_demographics,5] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:56:15,727] INFO Partition [customer_demographics,8] on broker 0: Expanding ISR for partition [customer_demographics,8] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:15,733] INFO Partition [customer_demographics,14] on broker 0: Expanding ISR for partition [customer_demographics,14] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:15,738] INFO Partition [customer_demographics,11] on broker 0: Expanding ISR for partition [customer_demographics,11] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:15,743] INFO Partition [customer_demographics,2] on broker 0: Expanding ISR for partition [customer_demographics,2] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:15,747] INFO Partition [customer_demographics,5] on broker 0: Expanding ISR for partition [customer_demographics,5] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:15,751] INFO Partition [customer_demographics,17] on broker 0: Expanding ISR for partition [customer_demographics,17] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:15,756] INFO Partition [store_returns,11] on broker 0: Expanding ISR for partition [store_returns,11] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:15,762] INFO Partition [store_returns,8] on broker 0: Expanding ISR for partition [store_returns,8] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:15,766] INFO Partition [store_returns,2] on broker 0: Expanding ISR for partition [store_returns,2] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:15,770] INFO Partition [store_returns,17] on broker 0: Expanding ISR for partition [store_returns,17] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:15,774] INFO Partition [store_returns,5] on broker 0: Expanding ISR for partition [store_returns,5] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:16,550] INFO Rolled new log segment for 'fstore_sales-4' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:16,557] INFO Rolled new log segment for 'fstore_sales-16' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:17,818] INFO Partition [customer_demographics,11] on broker 0: Expanding ISR for partition [customer_demographics,11] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:17,827] INFO Partition [customer_demographics,2] on broker 0: Expanding ISR for partition [customer_demographics,2] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:17,832] INFO Partition [customer_demographics,5] on broker 0: Expanding ISR for partition [customer_demographics,5] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:17,838] INFO Partition [customer_demographics,8] on broker 0: Expanding ISR for partition [customer_demographics,8] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:17,844] INFO Partition [customer_demographics,14] on broker 0: Expanding ISR for partition [customer_demographics,14] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:17,851] INFO Partition [customer_demographics,17] on broker 0: Expanding ISR for partition [customer_demographics,17] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:17,863] INFO Rolled new log segment for 'web_sales-7' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:18,727] INFO Rolled new log segment for 'catalog_sales-5' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:19,054] INFO Rolled new log segment for 'store_sales-1' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:19,065] INFO Rolled new log segment for 'store_sales-19' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:19,072] INFO Rolled new log segment for 'store_sales-5' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:19,082] INFO Rolled new log segment for 'store_sales-17' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:19,132] INFO Rolled new log segment for 'fstore_sales-18' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:20,311] INFO Rolled new log segment for 'catalog_sales-17' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:20,350] INFO Rolled new log segment for 'catalog_sales-0' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:20,465] INFO Rolled new log segment for 'catalog_sales-6' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:20,556] INFO Rolled new log segment for 'catalog_sales-12' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:20,582] INFO Rolled new log segment for 'catalog_sales-11' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:20,919] INFO Rolled new log segment for 'catalog_sales-18' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:21,349] INFO Partition [store_returns,14] on broker 0: Expanding ISR for partition [store_returns,14] from 0 to 0,1 (kafka.cluster.Partition)
[2017-11-03 00:56:21,679] INFO Rolled new log segment for 'store_sales-11' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:21,693] INFO Rolled new log segment for 'store_sales-7' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:21,702] INFO Rolled new log segment for 'store_sales-13' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:21,706] INFO Rolled new log segment for 'fstore_sales-10' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:21,714] INFO Rolled new log segment for 'fstore_sales-0' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:21,726] INFO Rolled new log segment for 'fstore_sales-6' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:23,327] INFO Rolled new log segment for 'web_sales-3' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:24,159] INFO Partition [store_returns,8] on broker 0: Expanding ISR for partition [store_returns,8] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:24,166] INFO Partition [store_returns,2] on broker 0: Expanding ISR for partition [store_returns,2] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:24,170] INFO Partition [store_returns,17] on broker 0: Expanding ISR for partition [store_returns,17] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:24,174] INFO Partition [store_returns,5] on broker 0: Expanding ISR for partition [store_returns,5] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:24,178] INFO Partition [store_returns,11] on broker 0: Expanding ISR for partition [store_returns,11] from 0,1 to 0,1,2 (kafka.cluster.Partition)
[2017-11-03 00:56:24,287] INFO Partition [customer,2] on broker 0: Shrinking ISR for partition [customer,2] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:56:24,294] INFO Partition [customer,17] on broker 0: Shrinking ISR for partition [customer,17] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:56:24,299] INFO Partition [customer,5] on broker 0: Shrinking ISR for partition [customer,5] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:56:24,304] INFO Partition [customer,14] on broker 0: Shrinking ISR for partition [customer,14] from 0,2,1 to 0 (kafka.cluster.Partition)
[2017-11-03 00:56:24,514] INFO Partition [customer,8] on broker 0: Shrinking ISR for partition [customer,8] from 0,1,2 to 0 (kafka.cluster.Partition)
[2017-11-03 00:56:24,519] INFO Partition [customer,11] on broker 0: Shrinking ISR for partition [customer,11] from 0,2,1 to 0 (kafka.cluster.Partition)
[2017-11-03 00:56:25,786] INFO Rolled new log segment for 'web_sales-4' in 0 ms. (kafka.log.Log)
[2017-11-03 00:56:27,583] INFO Rolled new log segment for 'store_sales-12' in 1 ms. (kafka.log.Log)
[2017-11-03 00:56:28,484] FATAL [Replica Manager on Broker 0]: Halting due to unrecoverable I/O error while handling produce request:  (kafka.server.ReplicaManager)
kafka.common.KafkaStorageException: I/O exception in append to log 'store_sales-16'
	at kafka.log.Log.append(Log.scala:349)
	at kafka.cluster.Partition$$anonfun$10.apply(Partition.scala:443)
	at kafka.cluster.Partition$$anonfun$10.apply(Partition.scala:429)
	at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:234)
	at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:240)
	at kafka.cluster.Partition.appendMessagesToLeader(Partition.scala:429)
	at kafka.server.ReplicaManager$$anonfun$appendToLocalLog$2.apply(ReplicaManager.scala:407)
	at kafka.server.ReplicaManager$$anonfun$appendToLocalLog$2.apply(ReplicaManager.scala:393)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:99)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:99)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:230)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:40)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:99)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
	at scala.collection.AbstractTraversable.map(Traversable.scala:104)
	at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:393)
	at kafka.server.ReplicaManager.appendMessages(ReplicaManager.scala:330)
	at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:425)
	at kafka.server.KafkaApis.handle(KafkaApis.scala:78)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60)
	at java.lang.Thread.run(Thread.java:745)
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)
	... 22 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)
	... 34 more