[2019-01-18 17:00:36,206] INFO [ProducerStateManager partition=test-70] Writing producer snapshot at offset 209016590 (kafka.log.ProducerStateManager) [2019-01-18 17:00:36,207] INFO [Log partition=test-70, dir=/data0/kafka] Rolled new log segment at offset 209016590 in 3 ms. (kafka.log.Log) [2019-01-18 17:00:59,000] INFO [ProducerStateManager partition=test-68] Writing producer snapshot at offset 308476629 (kafka.log.ProducerStateManager) [2019-01-18 17:00:59,004] INFO [Log partition=test-68, dir=/data0/kafka] Rolled new log segment at offset 308476629 in 4 ms. (kafka.log.Log) [2019-01-18 17:01:08,842] INFO [ProducerStateManager partition=test-22] Writing producer snapshot at offset 333717142 (kafka.log.ProducerStateManager) [2019-01-18 17:01:08,842] INFO [Log partition=test-22, dir=/data0/kafka] Rolled new log segment at offset 333717142 in 2 ms. (kafka.log.Log) [2019-01-18 17:01:09,081] INFO [ProducerStateManager partition=test-102] Writing producer snapshot at offset 305882470 (kafka.log.ProducerStateManager) [2019-01-18 17:01:09,082] INFO [Log partition=test-102, dir=/data0/kafka] Rolled new log segment at offset 305882470 in 2 ms. (kafka.log.Log) [2019-01-18 17:01:09,923] INFO [ProducerStateManager partition=test-148] Writing producer snapshot at offset 272608132 (kafka.log.ProducerStateManager) [2019-01-18 17:01:09,923] INFO [Log partition=test-148, dir=/data0/kafka] Rolled new log segment at offset 272608132 in 2 ms. (kafka.log.Log) [2019-01-18 17:01:31,261] INFO [ProducerStateManager partition=test-69] Writing producer snapshot at offset 251395223 (kafka.log.ProducerStateManager) [2019-01-18 17:01:31,261] INFO [Log partition=test-69, dir=/data0/kafka] Rolled new log segment at offset 251395223 in 2 ms. (kafka.log.Log) [2019-01-18 17:02:19,115] INFO [ProducerStateManager partition=test-149] Writing producer snapshot at offset 266019778 (kafka.log.ProducerStateManager) [2019-01-18 17:02:19,116] INFO [Log partition=test-149, dir=/data0/kafka] Rolled new log segment at offset 266019778 in 2 ms. (kafka.log.Log) [2019-01-18 17:02:47,377] INFO [ProducerStateManager partition=test-22] Writing producer snapshot at offset 334984773 (kafka.log.ProducerStateManager) [2019-01-18 17:02:47,378] INFO [Log partition=test-22, dir=/data0/kafka] Rolled new log segment at offset 334984773 in 2 ms. (kafka.log.Log) [2019-01-18 17:03:30,966] INFO [ProducerStateManager partition=test-147] Writing producer snapshot at offset 256921693 (kafka.log.ProducerStateManager) [2019-01-18 17:03:30,967] INFO [Log partition=test-147, dir=/data0/kafka] Rolled new log segment at offset 256921693 in 2 ms. (kafka.log.Log) [2019-01-18 17:03:52,923] INFO Updated PartitionLeaderEpoch. New: {epoch:1, offset:335754988}, Current: {epoch:0, offset:327360712} for Partition: test-22. Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:04:46,687] INFO [ProducerStateManager partition=test-70] Writing producer snapshot at offset 210129966 (kafka.log.ProducerStateManager) [2019-01-18 17:04:46,687] INFO [Log partition=test-70, dir=/data0/kafka] Rolled new log segment at offset 210129966 in 3 ms. (kafka.log.Log) [2019-01-18 17:04:50,324] INFO [ProducerStateManager partition=test-68] Writing producer snapshot at offset 309748624 (kafka.log.ProducerStateManager) [2019-01-18 17:04:50,324] INFO [Log partition=test-68, dir=/data0/kafka] Rolled new log segment at offset 309748624 in 2 ms. (kafka.log.Log) [2019-01-18 17:05:24,037] INFO [ProducerStateManager partition=test-148] Writing producer snapshot at offset 273813026 (kafka.log.ProducerStateManager) [2019-01-18 17:05:24,038] INFO [Log partition=test-148, dir=/data0/kafka] Rolled new log segment at offset 273813026 in 3 ms. (kafka.log.Log) [2019-01-18 17:05:27,594] INFO [ProducerStateManager partition=test-102] Writing producer snapshot at offset 307206612 (kafka.log.ProducerStateManager) [2019-01-18 17:05:27,594] INFO [Log partition=test-102, dir=/data0/kafka] Rolled new log segment at offset 307206612 in 2 ms. (kafka.log.Log) [2019-01-18 17:05:56,178] INFO [ProducerStateManager partition=test-69] Writing producer snapshot at offset 252622782 (kafka.log.ProducerStateManager) [2019-01-18 17:05:56,178] INFO [Log partition=test-69, dir=/data0/kafka] Rolled new log segment at offset 252622782 in 2 ms. (kafka.log.Log) [2019-01-18 17:07:11,689] INFO [ProducerStateManager partition=test-147] Writing producer snapshot at offset 258201389 (kafka.log.ProducerStateManager) [2019-01-18 17:07:11,689] INFO [Log partition=test-147, dir=/data0/kafka] Rolled new log segment at offset 258201389 in 1 ms. (kafka.log.Log) [2019-01-18 17:07:39,642] INFO [ProducerStateManager partition=test-149] Writing producer snapshot at offset 267211159 (kafka.log.ProducerStateManager) [2019-01-18 17:07:39,642] INFO [Log partition=test-149, dir=/data0/kafka] Rolled new log segment at offset 267211159 in 3 ms. (kafka.log.Log) [2019-01-18 17:07:48,868] INFO [Partition test-88 broker=25] Expanding ISR from 25,50,8,44 to 25,46,44,50,8 (kafka.cluster.Partition) [2019-01-18 17:08:06,918] INFO [Partition test-88 broker=25] Expanding ISR from 25,46,44,50,8 to 25,46,44,50,11,8 (kafka.cluster.Partition) [2019-01-18 17:08:22,045] INFO [Partition test-88 broker=25] Expanding ISR from 25,46,44,50,11,8 to 25,46,45,44,50,11,8 (kafka.cluster.Partition) [2019-01-18 17:08:22,063] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-88 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:08:22,063] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-88 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:08:22,065] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-88 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:08:22,065] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-88 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:08:22,082] INFO Log for partition test-88 is renamed to /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete and is scheduled for deletion (kafka.log.LogManager) [2019-01-18 17:08:51,388] INFO [ProducerStateManager partition=test-68] Writing producer snapshot at offset 311063591 (kafka.log.ProducerStateManager) [2019-01-18 17:08:51,388] INFO [Log partition=test-68, dir=/data0/kafka] Rolled new log segment at offset 311063591 in 2 ms. (kafka.log.Log) [2019-01-18 17:09:13,062] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-111 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:09:13,062] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-111 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:09:13,063] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-111 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:09:13,063] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-111 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:09:13,089] INFO Log for partition test-111 is renamed to /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete and is scheduled for deletion (kafka.log.LogManager) [2019-01-18 17:09:19,409] INFO [ProducerStateManager partition=test-70] Writing producer snapshot at offset 211257474 (kafka.log.ProducerStateManager) [2019-01-18 17:09:19,409] INFO [Log partition=test-70, dir=/data0/kafka] Rolled new log segment at offset 211257474 in 1 ms. (kafka.log.Log) [2019-01-18 17:09:22,095] INFO Deleted log /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000125114283.log. (kafka.log.LogSegment) [2019-01-18 17:09:22,100] INFO Deleted offset index /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000125114283.index. (kafka.log.LogSegment) [2019-01-18 17:09:22,107] INFO Deleted time index /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000125114283.timeindex. (kafka.log.LogSegment) [2019-01-18 17:09:22,121] INFO Deleted log /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000125922190.log. (kafka.log.LogSegment) [2019-01-18 17:09:22,128] INFO Deleted offset index /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000125922190.index. (kafka.log.LogSegment) [2019-01-18 17:09:22,134] INFO Deleted time index /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000125922190.timeindex. (kafka.log.LogSegment) [2019-01-18 17:09:22,147] INFO Deleted log /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000126748050.log. (kafka.log.LogSegment) [2019-01-18 17:09:22,151] INFO Deleted offset index /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000126748050.index. (kafka.log.LogSegment) [2019-01-18 17:09:22,157] INFO Deleted time index /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000126748050.timeindex. (kafka.log.LogSegment) [2019-01-18 17:09:22,211] INFO Deleted log /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000127571835.log. (kafka.log.LogSegment) [2019-01-18 17:09:22,211] INFO Deleted offset index /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000127571835.index. (kafka.log.LogSegment) [2019-01-18 17:09:22,211] INFO Deleted time index /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000127571835.timeindex. (kafka.log.LogSegment) [2019-01-18 17:09:22,294] INFO Deleted log /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000128383166.log. (kafka.log.LogSegment) [2019-01-18 17:09:22,297] INFO Deleted offset index /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000128383166.index. (kafka.log.LogSegment) [2019-01-18 17:09:22,299] INFO Deleted time index /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete/00000000000128383166.timeindex. (kafka.log.LogSegment) [2019-01-18 17:09:22,300] INFO Deleted log for partition test-88 in /data0/kafka/test-88.7a54ef5186524a949d1921908f13850f-delete. (kafka.log.LogManager) [2019-01-18 17:09:34,284] INFO [ProducerStateManager partition=test-148] Writing producer snapshot at offset 275009897 (kafka.log.ProducerStateManager) [2019-01-18 17:09:34,284] INFO [Log partition=test-148, dir=/data0/kafka] Rolled new log segment at offset 275009897 in 3 ms. (kafka.log.Log) [2019-01-18 17:09:56,671] INFO [ProducerStateManager partition=test-102] Writing producer snapshot at offset 308577646 (kafka.log.ProducerStateManager) [2019-01-18 17:09:56,671] INFO [Log partition=test-102, dir=/data0/kafka] Rolled new log segment at offset 308577646 in 2 ms. (kafka.log.Log) [2019-01-18 17:10:13,090] INFO Deleted log /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000305691724.log. (kafka.log.LogSegment) [2019-01-18 17:10:13,096] INFO Deleted offset index /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000305691724.index. (kafka.log.LogSegment) [2019-01-18 17:10:13,103] INFO Deleted time index /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000305691724.timeindex. (kafka.log.LogSegment) [2019-01-18 17:10:13,104] INFO Deleted log /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000306992495.log. (kafka.log.LogSegment) [2019-01-18 17:10:13,108] INFO Deleted offset index /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000306992495.index. (kafka.log.LogSegment) [2019-01-18 17:10:13,115] INFO Deleted time index /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000306992495.timeindex. (kafka.log.LogSegment) [2019-01-18 17:10:13,115] INFO Deleted log /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000308339670.log. (kafka.log.LogSegment) [2019-01-18 17:10:13,121] INFO Deleted offset index /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000308339670.index. (kafka.log.LogSegment) [2019-01-18 17:10:13,130] INFO Deleted time index /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000308339670.timeindex. (kafka.log.LogSegment) [2019-01-18 17:10:13,130] INFO Deleted log /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000309642824.log. (kafka.log.LogSegment) [2019-01-18 17:10:13,134] INFO Deleted offset index /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000309642824.index. (kafka.log.LogSegment) [2019-01-18 17:10:13,140] INFO Deleted time index /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000309642824.timeindex. (kafka.log.LogSegment) [2019-01-18 17:10:13,140] INFO Deleted log /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000311012035.log. (kafka.log.LogSegment) [2019-01-18 17:10:13,140] INFO Deleted offset index /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000311012035.index. (kafka.log.LogSegment) [2019-01-18 17:10:13,140] INFO Deleted time index /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000311012035.timeindex. (kafka.log.LogSegment) [2019-01-18 17:10:13,160] INFO Deleted log /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000312309341.log. (kafka.log.LogSegment) [2019-01-18 17:10:13,160] INFO Deleted offset index /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000312309341.index. (kafka.log.LogSegment) [2019-01-18 17:10:13,160] INFO Deleted time index /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000312309341.timeindex. (kafka.log.LogSegment) [2019-01-18 17:10:13,193] INFO Deleted log /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000313660003.log. (kafka.log.LogSegment) [2019-01-18 17:10:13,195] INFO Deleted offset index /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000313660003.index. (kafka.log.LogSegment) [2019-01-18 17:10:13,196] INFO Deleted time index /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete/00000000000313660003.timeindex. (kafka.log.LogSegment) [2019-01-18 17:10:13,196] INFO Deleted log for partition test-111 in /data0/kafka/test-111.9f8b4b8e5ff24067854adf73934f55e5-delete. (kafka.log.LogManager) [2019-01-18 17:10:32,240] INFO [ProducerStateManager partition=test-69] Writing producer snapshot at offset 253865773 (kafka.log.ProducerStateManager) [2019-01-18 17:10:32,240] INFO [Log partition=test-69, dir=/data0/kafka] Rolled new log segment at offset 253865773 in 2 ms. (kafka.log.Log) [2019-01-18 17:10:43,854] INFO [ProducerStateManager partition=test-147] Writing producer snapshot at offset 259433640 (kafka.log.ProducerStateManager) [2019-01-18 17:10:43,854] INFO [Log partition=test-147, dir=/data0/kafka] Rolled new log segment at offset 259433640 in 2 ms. (kafka.log.Log) [2019-01-18 17:10:50,851] INFO [Partition test-38 broker=25] Expanding ISR from 25,41,50,8 to 25,41,73,50,8 (kafka.cluster.Partition) [2019-01-18 17:11:17,645] INFO [Partition test-38 broker=25] Expanding ISR from 25,41,73,50,8 to 25,41,73,50,8,75 (kafka.cluster.Partition) [2019-01-18 17:11:27,320] INFO [Partition test-38 broker=25] Expanding ISR from 25,41,73,50,8,75 to 25,74,41,73,50,8,75 (kafka.cluster.Partition) [2019-01-18 17:11:27,335] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-38 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:11:27,335] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-38 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:11:27,336] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-38 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:11:27,336] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-38 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:11:27,355] INFO Log for partition test-38 is renamed to /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete and is scheduled for deletion (kafka.log.LogManager) [2019-01-18 17:12:24,749] INFO [ProducerStateManager partition=test-149] Writing producer snapshot at offset 268433124 (kafka.log.ProducerStateManager) [2019-01-18 17:12:24,750] INFO [Log partition=test-149, dir=/data0/kafka] Rolled new log segment at offset 268433124 in 2 ms. (kafka.log.Log) [2019-01-18 17:12:27,370] INFO Deleted log /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000312883090.log. (kafka.log.LogSegment) [2019-01-18 17:12:27,375] INFO Deleted offset index /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000312883090.index. (kafka.log.LogSegment) [2019-01-18 17:12:27,390] INFO Deleted time index /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000312883090.timeindex. (kafka.log.LogSegment) [2019-01-18 17:12:27,409] INFO Deleted log /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000314170908.log. (kafka.log.LogSegment) [2019-01-18 17:12:27,413] INFO Deleted offset index /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000314170908.index. (kafka.log.LogSegment) [2019-01-18 17:12:27,421] INFO Deleted time index /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000314170908.timeindex. (kafka.log.LogSegment) [2019-01-18 17:12:27,433] INFO Deleted log /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000315488907.log. (kafka.log.LogSegment) [2019-01-18 17:12:27,438] INFO Deleted offset index /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000315488907.index. (kafka.log.LogSegment) [2019-01-18 17:12:27,446] INFO Deleted time index /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000315488907.timeindex. (kafka.log.LogSegment) [2019-01-18 17:12:27,459] INFO Deleted log /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000316782527.log. (kafka.log.LogSegment) [2019-01-18 17:12:27,463] INFO Deleted offset index /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000316782527.index. (kafka.log.LogSegment) [2019-01-18 17:12:27,468] INFO Deleted time index /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000316782527.timeindex. (kafka.log.LogSegment) [2019-01-18 17:12:27,480] INFO Deleted log /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000318108111.log. (kafka.log.LogSegment) [2019-01-18 17:12:27,485] INFO Deleted offset index /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000318108111.index. (kafka.log.LogSegment) [2019-01-18 17:12:27,491] INFO Deleted time index /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000318108111.timeindex. (kafka.log.LogSegment) [2019-01-18 17:12:27,575] INFO Deleted log /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000319407305.log. (kafka.log.LogSegment) [2019-01-18 17:12:27,576] INFO Deleted offset index /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000319407305.index. (kafka.log.LogSegment) [2019-01-18 17:12:27,576] INFO Deleted time index /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000319407305.timeindex. (kafka.log.LogSegment) [2019-01-18 17:12:27,674] INFO Deleted log /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000320712393.log. (kafka.log.LogSegment) [2019-01-18 17:12:27,676] INFO Deleted offset index /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000320712393.index. (kafka.log.LogSegment) [2019-01-18 17:12:27,679] INFO Deleted time index /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete/00000000000320712393.timeindex. (kafka.log.LogSegment) [2019-01-18 17:12:27,680] INFO Deleted log for partition test-38 in /data0/kafka/test-38.b4ed50c693dd480ebb1342c17a197ab8-delete. (kafka.log.LogManager) [2019-01-18 17:12:39,117] INFO Updated PartitionLeaderEpoch. New: {epoch:1, offset:260372687}, Current: {epoch:0, offset:253179614} for Partition: test-147. Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:12:43,075] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-147 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:12:43,077] INFO [ReplicaFetcherManager on broker 25] Added fetcher for partitions List([test-147, initOffset 260416676 to broker BrokerEndPoint(70,dtsa70st.prod.yiran.com,9092)] ) (kafka.server.ReplicaFetcherManager) [2019-01-18 17:12:43,101] INFO [Log partition=test-147, dir=/data0/kafka] Truncating to offset 260416676 (kafka.log.Log) [2019-01-18 17:12:43,115] INFO [Log partition=test-147, dir=/data0/kafka] Loading producer state from offset 260416676 with message format version 2 (kafka.log.Log) [2019-01-18 17:12:43,116] INFO [ProducerStateManager partition=test-147] Loading producer state from snapshot file '/data0/kafka/test-147/00000000000259433640.snapshot' (kafka.log.ProducerStateManager) [2019-01-18 17:12:44,396] INFO Updated PartitionLeaderEpoch. New: {epoch:6, offset:260416676}, Current: {epoch:1, offset:260372687} for Partition: test-147. Cache now contains 2 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:12:44,856] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-11 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:12:44,856] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-11 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:12:44,861] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-11 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:12:44,861] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-11 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:12:44,875] INFO Log for partition test-11 is renamed to /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete and is scheduled for deletion (kafka.log.LogManager) [2019-01-18 17:12:45,831] INFO [ProducerStateManager partition=test-70] Writing producer snapshot at offset 212372166 (kafka.log.ProducerStateManager) [2019-01-18 17:12:45,831] INFO [Log partition=test-70, dir=/data0/kafka] Rolled new log segment at offset 212372166 in 2 ms. (kafka.log.Log) [2019-01-18 17:12:46,751] INFO [ProducerStateManager partition=test-68] Writing producer snapshot at offset 312342330 (kafka.log.ProducerStateManager) [2019-01-18 17:12:46,751] INFO [Log partition=test-68, dir=/data0/kafka] Rolled new log segment at offset 312342330 in 1 ms. (kafka.log.Log) [2019-01-18 17:12:49,007] INFO [ProducerStateManager partition=test-102] Writing producer snapshot at offset 309891601 (kafka.log.ProducerStateManager) [2019-01-18 17:12:49,007] INFO [Log partition=test-102, dir=/data0/kafka] Rolled new log segment at offset 309891601 in 2 ms. (kafka.log.Log) [2019-01-18 17:13:12,139] INFO Updated PartitionLeaderEpoch. New: {epoch:1, offset:212753276}, Current: {epoch:0, offset:206773254} for Partition: test-70. Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:13:14,288] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-70 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:13:14,289] INFO [ReplicaFetcherManager on broker 25] Added fetcher for partitions List([test-70, initOffset 212789741 to broker BrokerEndPoint(73,dtsa73st.prod.yiran.com,9092)] ) (kafka.server.ReplicaFetcherManager) [2019-01-18 17:13:14,741] INFO [ReplicaFetcher replicaId=25, leaderId=73, fetcherId=0] Based on follower's leader epoch, leader replied with an offset 212789741 >= the follower's log end offset 212789741 in test-70. No truncation needed. (kafka.server.ReplicaFetcherThread) [2019-01-18 17:13:14,741] INFO [Log partition=test-70, dir=/data0/kafka] Truncating to 212789741 has no effect as the largest offset in the log is 212789740 (kafka.log.Log) [2019-01-18 17:13:14,743] INFO Updated PartitionLeaderEpoch. New: {epoch:5, offset:212789741}, Current: {epoch:1, offset:212753276} for Partition: test-70. Cache now contains 2 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:13:24,889] INFO [ProducerStateManager partition=test-148] Writing producer snapshot at offset 276216188 (kafka.log.ProducerStateManager) [2019-01-18 17:13:24,890] INFO [Log partition=test-148, dir=/data0/kafka] Rolled new log segment at offset 276216188 in 2 ms. (kafka.log.Log) [2019-01-18 17:13:36,752] INFO [Partition test-138 broker=25] Expanding ISR from 25,8,44,17 to 25,17,44,16,8 (kafka.cluster.Partition) [2019-01-18 17:13:44,876] INFO Deleted log /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000169864831.log. (kafka.log.LogSegment) [2019-01-18 17:13:44,879] INFO Deleted offset index /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000169864831.index. (kafka.log.LogSegment) [2019-01-18 17:13:44,885] INFO Deleted time index /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000169864831.timeindex. (kafka.log.LogSegment) [2019-01-18 17:13:44,885] INFO Deleted log /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000170822356.log. (kafka.log.LogSegment) [2019-01-18 17:13:44,889] INFO Deleted offset index /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000170822356.index. (kafka.log.LogSegment) [2019-01-18 17:13:44,894] INFO Deleted time index /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000170822356.timeindex. (kafka.log.LogSegment) [2019-01-18 17:13:44,895] INFO Deleted log /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000171781023.log. (kafka.log.LogSegment) [2019-01-18 17:13:44,899] INFO Deleted offset index /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000171781023.index. (kafka.log.LogSegment) [2019-01-18 17:13:44,904] INFO Deleted time index /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000171781023.timeindex. (kafka.log.LogSegment) [2019-01-18 17:13:44,906] INFO Deleted log /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000172756291.log. (kafka.log.LogSegment) [2019-01-18 17:13:44,906] INFO Deleted offset index /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000172756291.index. (kafka.log.LogSegment) [2019-01-18 17:13:44,907] INFO Deleted time index /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000172756291.timeindex. (kafka.log.LogSegment) [2019-01-18 17:13:44,942] INFO Deleted log /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000173713933.log. (kafka.log.LogSegment) [2019-01-18 17:13:44,945] INFO Deleted offset index /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000173713933.index. (kafka.log.LogSegment) [2019-01-18 17:13:44,948] INFO Deleted time index /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete/00000000000173713933.timeindex. (kafka.log.LogSegment) [2019-01-18 17:13:44,949] INFO Deleted log for partition test-11 in /data0/kafka/test-11.9d4bcc85a7bf4a079a8d5611bca569ca-delete. (kafka.log.LogManager) [2019-01-18 17:14:03,219] INFO [ProducerStateManager partition=test-102] Writing producer snapshot at offset 311249936 (kafka.log.ProducerStateManager) [2019-01-18 17:14:03,219] INFO [Log partition=test-102, dir=/data0/kafka] Rolled new log segment at offset 311249936 in 2 ms. (kafka.log.Log) [2019-01-18 17:14:15,431] INFO Updated PartitionLeaderEpoch. New: {epoch:1, offset:311464673}, Current: {epoch:0, offset:303194308} for Partition: test-102. Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:14:16,769] INFO [ProducerStateManager partition=test-69] Writing producer snapshot at offset 255093823 (kafka.log.ProducerStateManager) [2019-01-18 17:14:16,769] INFO [Log partition=test-69, dir=/data0/kafka] Rolled new log segment at offset 255093823 in 2 ms. (kafka.log.Log) [2019-01-18 17:14:33,117] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-102 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:14:33,117] INFO [Partition test-102 broker=25] test-102 starts at Leader Epoch 2 from offset 311522442. Previous Leader Epoch was: 1 (kafka.cluster.Partition) [2019-01-18 17:14:33,122] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-102 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:14:33,122] INFO [Partition test-102 broker=25] test-102 starts at Leader Epoch 6 from offset 311522442. Previous Leader Epoch was: 2 (kafka.cluster.Partition) [2019-01-18 17:14:33,278] INFO Updated PartitionLeaderEpoch. New: {epoch:6, offset:311522442}, Current: {epoch:1, offset:311464673} for Partition: test-102. Cache now contains 2 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:14:34,507] INFO Updated PartitionLeaderEpoch. New: {epoch:1, offset:255618776}, Current: {epoch:0, offset:248930158} for Partition: test-69. Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:14:35,863] INFO Updated PartitionLeaderEpoch. New: {epoch:5, offset:255664816}, Current: {epoch:1, offset:255618776} for Partition: test-69. Cache now contains 2 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:14:36,120] INFO [Partition test-138 broker=25] Expanding ISR from 25,17,44,16,8 to 25,61,17,44,16,8 (kafka.cluster.Partition) [2019-01-18 17:14:43,776] INFO [Partition test-138 broker=25] Expanding ISR from 25,61,17,44,16,8 to 25,61,17,44,16,8,15 (kafka.cluster.Partition) [2019-01-18 17:14:44,697] INFO [Partition test-138 broker=25] Expanding ISR from 25,61,17,44,16,8,15 to 25,14,61,17,44,16,8,15 (kafka.cluster.Partition) [2019-01-18 17:14:44,720] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-138 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:14:44,720] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-138 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:14:44,721] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-138 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:14:44,721] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-138 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:14:44,741] INFO Log for partition test-138 is renamed to /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete and is scheduled for deletion (kafka.log.LogManager) [2019-01-18 17:15:19,876] INFO [ProducerStateManager partition=test-68] Writing producer snapshot at offset 313633889 (kafka.log.ProducerStateManager) [2019-01-18 17:15:19,876] INFO [Log partition=test-68, dir=/data0/kafka] Rolled new log segment at offset 313633889 in 2 ms. (kafka.log.Log) [2019-01-18 17:15:25,395] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-61 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:15:25,395] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-61 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:15:25,396] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-61 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:15:25,396] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-61 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:15:25,411] INFO Log for partition test-61 is renamed to /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete and is scheduled for deletion (kafka.log.LogManager) [2019-01-18 17:15:27,135] INFO [ProducerStateManager partition=test-149] Writing producer snapshot at offset 269612860 (kafka.log.ProducerStateManager) [2019-01-18 17:15:27,136] INFO [Log partition=test-149, dir=/data0/kafka] Rolled new log segment at offset 269612860 in 2 ms. (kafka.log.Log) [2019-01-18 17:15:40,945] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-22 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:15:40,945] INFO [Partition test-22 broker=25] test-22 starts at Leader Epoch 2 from offset 335818661. Previous Leader Epoch was: 1 (kafka.cluster.Partition) [2019-01-18 17:15:40,950] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-22 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:15:40,950] INFO [Partition test-22 broker=25] test-22 starts at Leader Epoch 6 from offset 335818661. Previous Leader Epoch was: 2 (kafka.cluster.Partition) [2019-01-18 17:15:41,128] INFO Updated PartitionLeaderEpoch. New: {epoch:6, offset:335818661}, Current: {epoch:1, offset:335754988} for Partition: test-22. Cache now contains 2 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:15:44,355] ERROR [ReplicaManager broker=25] Error processing append operation on partition test-22 (kafka.server.ReplicaManager) [2019-01-18 17:15:44,753] INFO Deleted log /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000353184364.log. (kafka.log.LogSegment) [2019-01-18 17:15:44,757] INFO Deleted offset index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000353184364.index. (kafka.log.LogSegment) [2019-01-18 17:15:44,763] INFO Deleted time index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000353184364.timeindex. (kafka.log.LogSegment) [2019-01-18 17:15:44,776] INFO Deleted log /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000354544334.log. (kafka.log.LogSegment) [2019-01-18 17:15:44,780] INFO Deleted offset index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000354544334.index. (kafka.log.LogSegment) [2019-01-18 17:15:44,787] INFO Deleted time index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000354544334.timeindex. (kafka.log.LogSegment) [2019-01-18 17:15:44,800] INFO Deleted log /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000355878891.log. (kafka.log.LogSegment) [2019-01-18 17:15:44,807] INFO Deleted offset index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000355878891.index. (kafka.log.LogSegment) [2019-01-18 17:15:44,813] INFO Deleted time index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000355878891.timeindex. (kafka.log.LogSegment) [2019-01-18 17:15:44,834] INFO Deleted log /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000357237922.log. (kafka.log.LogSegment) [2019-01-18 17:15:44,838] INFO Deleted offset index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000357237922.index. (kafka.log.LogSegment) [2019-01-18 17:15:44,845] INFO Deleted time index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000357237922.timeindex. (kafka.log.LogSegment) [2019-01-18 17:15:44,857] INFO Deleted log /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000358559299.log. (kafka.log.LogSegment) [2019-01-18 17:15:44,861] INFO Deleted offset index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000358559299.index. (kafka.log.LogSegment) [2019-01-18 17:15:44,867] INFO Deleted time index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000358559299.timeindex. (kafka.log.LogSegment) [2019-01-18 17:15:44,950] INFO Deleted log /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000359943744.log. (kafka.log.LogSegment) [2019-01-18 17:15:44,954] INFO Deleted offset index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000359943744.index. (kafka.log.LogSegment) [2019-01-18 17:15:44,960] INFO Deleted time index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000359943744.timeindex. (kafka.log.LogSegment) [2019-01-18 17:15:45,119] INFO Deleted log /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000361270372.log. (kafka.log.LogSegment) [2019-01-18 17:15:45,120] INFO Deleted offset index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000361270372.index. (kafka.log.LogSegment) [2019-01-18 17:15:45,120] INFO Deleted time index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000361270372.timeindex. (kafka.log.LogSegment) [2019-01-18 17:15:45,216] INFO Deleted log /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000362619436.log. (kafka.log.LogSegment) [2019-01-18 17:15:45,219] INFO Deleted offset index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000362619436.index. (kafka.log.LogSegment) [2019-01-18 17:15:45,221] INFO Deleted time index /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete/00000000000362619436.timeindex. (kafka.log.LogSegment) [2019-01-18 17:15:45,222] INFO Deleted log for partition test-138 in /data0/kafka/test-138.0806c6d12d65482f977e6c5526e4476f-delete. (kafka.log.LogManager) [2019-01-18 17:15:46,867] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-109 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:15:46,867] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-109 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:15:46,874] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-109 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:15:46,874] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-109 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:15:46,889] INFO Log for partition test-109 is renamed to /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete and is scheduled for deletion (kafka.log.LogManager) [2019-01-18 17:15:53,308] INFO Updated PartitionLeaderEpoch. New: {epoch:1, offset:314043266}, Current: {epoch:0, offset:305898283} for Partition: test-68. Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:16:06,926] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-68 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:16:06,929] INFO [ReplicaFetcherManager on broker 25] Added fetcher for partitions List([test-68, initOffset 314104721 to broker BrokerEndPoint(71,dtsa71st.prod.yiran.com,9092)] ) (kafka.server.ReplicaFetcherManager) [2019-01-18 17:16:06,937] INFO [ReplicaFetcher replicaId=25, leaderId=71, fetcherId=2] Based on follower's leader epoch, leader replied with an offset 314104722 >= the follower's log end offset 314104722 in test-68. No truncation needed. (kafka.server.ReplicaFetcherThread) [2019-01-18 17:16:06,937] INFO [Log partition=test-68, dir=/data0/kafka] Truncating to 314104722 has no effect as the largest offset in the log is 314104721 (kafka.log.Log) [2019-01-18 17:16:07,066] INFO Updated PartitionLeaderEpoch. New: {epoch:6, offset:314104722}, Current: {epoch:1, offset:314043266} for Partition: test-68. Cache now contains 2 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:16:25,412] INFO Deleted log /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000309023945.log. (kafka.log.LogSegment) [2019-01-18 17:16:25,419] INFO Deleted offset index /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000309023945.index. (kafka.log.LogSegment) [2019-01-18 17:16:25,426] INFO Deleted time index /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000309023945.timeindex. (kafka.log.LogSegment) [2019-01-18 17:16:25,427] INFO Deleted log /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000310341755.log. (kafka.log.LogSegment) [2019-01-18 17:16:25,430] INFO Deleted offset index /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000310341755.index. (kafka.log.LogSegment) [2019-01-18 17:16:25,436] INFO Deleted time index /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000310341755.timeindex. (kafka.log.LogSegment) [2019-01-18 17:16:25,436] INFO Deleted log /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000311634483.log. (kafka.log.LogSegment) [2019-01-18 17:16:25,440] INFO Deleted offset index /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000311634483.index. (kafka.log.LogSegment) [2019-01-18 17:16:25,444] INFO Deleted time index /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000311634483.timeindex. (kafka.log.LogSegment) [2019-01-18 17:16:25,444] INFO Deleted log /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000312948656.log. (kafka.log.LogSegment) [2019-01-18 17:16:25,455] INFO Deleted offset index /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000312948656.index. (kafka.log.LogSegment) [2019-01-18 17:16:25,460] INFO Deleted time index /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000312948656.timeindex. (kafka.log.LogSegment) [2019-01-18 17:16:25,460] INFO Deleted log /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000314246519.log. (kafka.log.LogSegment) [2019-01-18 17:16:25,464] INFO Deleted offset index /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000314246519.index. (kafka.log.LogSegment) [2019-01-18 17:16:25,469] INFO Deleted time index /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000314246519.timeindex. (kafka.log.LogSegment) [2019-01-18 17:16:25,471] INFO Deleted log /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000315568529.log. (kafka.log.LogSegment) [2019-01-18 17:16:25,471] INFO Deleted offset index /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000315568529.index. (kafka.log.LogSegment) [2019-01-18 17:16:25,471] INFO Deleted time index /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000315568529.timeindex. (kafka.log.LogSegment) [2019-01-18 17:16:25,522] INFO Deleted log /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000316850893.log. (kafka.log.LogSegment) [2019-01-18 17:16:25,525] INFO Deleted offset index /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000316850893.index. (kafka.log.LogSegment) [2019-01-18 17:16:25,530] INFO Deleted time index /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete/00000000000316850893.timeindex. (kafka.log.LogSegment) [2019-01-18 17:16:25,531] INFO Deleted log for partition test-61 in /data0/kafka/test-61.de376299ae4c4c56a530ed18359079ee-delete. (kafka.log.LogManager) [2019-01-18 17:16:30,209] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-60 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:16:30,209] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-60 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:16:30,220] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-60 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:16:30,220] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-60 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:16:30,237] INFO Log for partition test-60 is renamed to /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete and is scheduled for deletion (kafka.log.LogManager) [2019-01-18 17:16:46,890] INFO Deleted log /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000354536822.log. (kafka.log.LogSegment) [2019-01-18 17:16:46,893] INFO Deleted offset index /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000354536822.index. (kafka.log.LogSegment) [2019-01-18 17:16:46,897] INFO Deleted time index /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000354536822.timeindex. (kafka.log.LogSegment) [2019-01-18 17:16:46,897] INFO Deleted log /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000355937498.log. (kafka.log.LogSegment) [2019-01-18 17:16:46,902] INFO Deleted offset index /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000355937498.index. (kafka.log.LogSegment) [2019-01-18 17:16:46,907] INFO Deleted time index /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000355937498.timeindex. (kafka.log.LogSegment) [2019-01-18 17:16:46,907] INFO Deleted log /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000357335094.log. (kafka.log.LogSegment) [2019-01-18 17:16:46,911] INFO Deleted offset index /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000357335094.index. (kafka.log.LogSegment) [2019-01-18 17:16:46,915] INFO Deleted time index /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000357335094.timeindex. (kafka.log.LogSegment) [2019-01-18 17:16:46,915] INFO Deleted log /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000358742582.log. (kafka.log.LogSegment) [2019-01-18 17:16:46,915] INFO Deleted offset index /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000358742582.index. (kafka.log.LogSegment) [2019-01-18 17:16:46,918] INFO Deleted time index /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000358742582.timeindex. (kafka.log.LogSegment) [2019-01-18 17:16:46,918] INFO Deleted log /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000360147365.log. (kafka.log.LogSegment) [2019-01-18 17:16:46,923] INFO Deleted offset index /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000360147365.index. (kafka.log.LogSegment) [2019-01-18 17:16:46,929] INFO Deleted time index /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000360147365.timeindex. (kafka.log.LogSegment) [2019-01-18 17:16:46,930] INFO Deleted log /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000361569472.log. (kafka.log.LogSegment) [2019-01-18 17:16:46,930] INFO Deleted offset index /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000361569472.index. (kafka.log.LogSegment) [2019-01-18 17:16:46,930] INFO Deleted time index /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000361569472.timeindex. (kafka.log.LogSegment) [2019-01-18 17:16:46,984] INFO Deleted log /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000362941837.log. (kafka.log.LogSegment) [2019-01-18 17:16:46,988] INFO Deleted offset index /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000362941837.index. (kafka.log.LogSegment) [2019-01-18 17:16:46,992] INFO Deleted time index /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete/00000000000362941837.timeindex. (kafka.log.LogSegment) [2019-01-18 17:16:46,993] INFO Deleted log for partition test-109 in /data0/kafka/test-109.8b4b8061c2634a688fd4d4996f534711-delete. (kafka.log.LogManager) [2019-01-18 17:17:04,003] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-110 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:17:04,003] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-110 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:17:04,010] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-110 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:17:04,010] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-110 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:17:04,025] INFO Log for partition test-110 is renamed to /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete and is scheduled for deletion (kafka.log.LogManager) [2019-01-18 17:17:10,322] INFO [ProducerStateManager partition=test-148] Writing producer snapshot at offset 277403533 (kafka.log.ProducerStateManager) [2019-01-18 17:17:10,322] INFO [Log partition=test-148, dir=/data0/kafka] Rolled new log segment at offset 277403533 in 1 ms. (kafka.log.Log) [2019-01-18 17:17:17,094] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-12 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:17:17,094] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-12 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:17:17,100] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-12 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:17:17,100] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-12 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:17:17,115] INFO Log for partition test-12 is renamed to /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete and is scheduled for deletion (kafka.log.LogManager) [2019-01-18 17:17:30,238] INFO Deleted log /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000405372492.log. (kafka.log.LogSegment) [2019-01-18 17:17:30,241] INFO Deleted offset index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000405372492.index. (kafka.log.LogSegment) [2019-01-18 17:17:30,243] INFO Deleted time index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000405372492.timeindex. (kafka.log.LogSegment) [2019-01-18 17:17:30,244] INFO Deleted log /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000406808387.log. (kafka.log.LogSegment) [2019-01-18 17:17:30,247] INFO Deleted offset index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000406808387.index. (kafka.log.LogSegment) [2019-01-18 17:17:30,253] INFO Deleted time index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000406808387.timeindex. (kafka.log.LogSegment) [2019-01-18 17:17:30,253] INFO Deleted log /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000408194844.log. (kafka.log.LogSegment) [2019-01-18 17:17:30,257] INFO Deleted offset index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000408194844.index. (kafka.log.LogSegment) [2019-01-18 17:17:30,262] INFO Deleted time index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000408194844.timeindex. (kafka.log.LogSegment) [2019-01-18 17:17:30,263] INFO Deleted log /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000409641313.log. (kafka.log.LogSegment) [2019-01-18 17:17:30,266] INFO Deleted offset index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000409641313.index. (kafka.log.LogSegment) [2019-01-18 17:17:30,272] INFO Deleted time index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000409641313.timeindex. (kafka.log.LogSegment) [2019-01-18 17:17:30,272] INFO Deleted log /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000411038506.log. (kafka.log.LogSegment) [2019-01-18 17:17:30,277] INFO Deleted offset index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000411038506.index. (kafka.log.LogSegment) [2019-01-18 17:17:30,283] INFO Deleted time index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000411038506.timeindex. (kafka.log.LogSegment) [2019-01-18 17:17:30,283] INFO Deleted log /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000412484918.log. (kafka.log.LogSegment) [2019-01-18 17:17:30,284] INFO Deleted offset index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000412484918.index. (kafka.log.LogSegment) [2019-01-18 17:17:30,288] INFO Deleted time index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000412484918.timeindex. (kafka.log.LogSegment) [2019-01-18 17:17:30,289] INFO Deleted log /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000413922825.log. (kafka.log.LogSegment) [2019-01-18 17:17:30,289] INFO Deleted offset index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000413922825.index. (kafka.log.LogSegment) [2019-01-18 17:17:30,289] INFO Deleted time index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000413922825.timeindex. (kafka.log.LogSegment) [2019-01-18 17:17:30,332] INFO Deleted log /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000415310719.log. (kafka.log.LogSegment) [2019-01-18 17:17:30,332] INFO Deleted offset index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000415310719.index. (kafka.log.LogSegment) [2019-01-18 17:17:30,332] INFO Deleted time index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000415310719.timeindex. (kafka.log.LogSegment) [2019-01-18 17:17:30,343] INFO Deleted log /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000416743870.log. (kafka.log.LogSegment) [2019-01-18 17:17:30,344] INFO Deleted offset index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000416743870.index. (kafka.log.LogSegment) [2019-01-18 17:17:30,345] INFO Deleted time index /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete/00000000000416743870.timeindex. (kafka.log.LogSegment) [2019-01-18 17:17:30,346] INFO Deleted log for partition test-60 in /data0/kafka/test-60.7dd3128779e04fb9b0dd1d341313da20-delete. (kafka.log.LogManager) [2019-01-18 17:18:04,025] INFO Deleted log /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000356458833.log. (kafka.log.LogSegment) [2019-01-18 17:18:04,029] INFO Deleted offset index /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000356458833.index. (kafka.log.LogSegment) [2019-01-18 17:18:04,036] INFO Deleted time index /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000356458833.timeindex. (kafka.log.LogSegment) [2019-01-18 17:18:04,036] INFO Deleted log /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000357824367.log. (kafka.log.LogSegment) [2019-01-18 17:18:04,039] INFO Deleted offset index /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000357824367.index. (kafka.log.LogSegment) [2019-01-18 17:18:04,045] INFO Deleted time index /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000357824367.timeindex. (kafka.log.LogSegment) [2019-01-18 17:18:04,046] INFO Deleted log /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000359214344.log. (kafka.log.LogSegment) [2019-01-18 17:18:04,049] INFO Deleted offset index /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000359214344.index. (kafka.log.LogSegment) [2019-01-18 17:18:04,055] INFO Deleted time index /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000359214344.timeindex. (kafka.log.LogSegment) [2019-01-18 17:18:04,056] INFO Deleted log /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000360594572.log. (kafka.log.LogSegment) [2019-01-18 17:18:04,059] INFO Deleted offset index /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000360594572.index. (kafka.log.LogSegment) [2019-01-18 17:18:04,066] INFO Deleted time index /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000360594572.timeindex. (kafka.log.LogSegment) [2019-01-18 17:18:04,066] INFO Deleted log /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000361980409.log. (kafka.log.LogSegment) [2019-01-18 17:18:04,070] INFO Deleted offset index /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000361980409.index. (kafka.log.LogSegment) [2019-01-18 17:18:04,075] INFO Deleted time index /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000361980409.timeindex. (kafka.log.LogSegment) [2019-01-18 17:18:04,077] INFO Deleted log /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000363377954.log. (kafka.log.LogSegment) [2019-01-18 17:18:04,077] INFO Deleted offset index /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000363377954.index. (kafka.log.LogSegment) [2019-01-18 17:18:04,077] INFO Deleted time index /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000363377954.timeindex. (kafka.log.LogSegment) [2019-01-18 17:18:04,133] INFO Deleted log /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000364736602.log. (kafka.log.LogSegment) [2019-01-18 17:18:04,137] INFO Deleted offset index /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000364736602.index. (kafka.log.LogSegment) [2019-01-18 17:18:04,149] INFO Deleted time index /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete/00000000000364736602.timeindex. (kafka.log.LogSegment) [2019-01-18 17:18:04,151] INFO Deleted log for partition test-110 in /data0/kafka/test-110.98e50c771ca14d87bc0c9dc7d93d4410-delete. (kafka.log.LogManager) [2019-01-18 17:18:08,917] INFO [ProducerStateManager partition=test-149] Writing producer snapshot at offset 270832326 (kafka.log.ProducerStateManager) [2019-01-18 17:18:08,917] INFO [Log partition=test-149, dir=/data0/kafka] Rolled new log segment at offset 270832326 in 2 ms. (kafka.log.Log) [2019-01-18 17:18:13,826] INFO Updated PartitionLeaderEpoch. New: {epoch:1, offset:270944308}, Current: {epoch:0, offset:263604188} for Partition: test-149. Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:18:15,431] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-149 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:18:15,434] INFO [ReplicaFetcherManager on broker 25] Added fetcher for partitions List([test-149, initOffset 271002961 to broker BrokerEndPoint(72,dtsa72st.prod.yiran.com,9092)] ) (kafka.server.ReplicaFetcherManager) [2019-01-18 17:18:15,443] INFO [ReplicaFetcher replicaId=25, leaderId=72, fetcherId=1] Based on follower's leader epoch, leader replied with an offset 271002961 >= the follower's log end offset 271002961 in test-149. No truncation needed. (kafka.server.ReplicaFetcherThread) [2019-01-18 17:18:15,443] INFO [Log partition=test-149, dir=/data0/kafka] Truncating to 271002961 has no effect as the largest offset in the log is 271002960 (kafka.log.Log) [2019-01-18 17:18:15,614] INFO Updated PartitionLeaderEpoch. New: {epoch:6, offset:271002961}, Current: {epoch:1, offset:270944308} for Partition: test-149. Cache now contains 2 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:18:17,116] INFO Deleted log /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000212533707.log. (kafka.log.LogSegment) [2019-01-18 17:18:17,119] INFO Deleted offset index /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000212533707.index. (kafka.log.LogSegment) [2019-01-18 17:18:17,123] INFO Deleted time index /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000212533707.timeindex. (kafka.log.LogSegment) [2019-01-18 17:18:17,123] INFO Deleted log /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000213620441.log. (kafka.log.LogSegment) [2019-01-18 17:18:17,128] INFO Deleted offset index /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000213620441.index. (kafka.log.LogSegment) [2019-01-18 17:18:17,134] INFO Deleted time index /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000213620441.timeindex. (kafka.log.LogSegment) [2019-01-18 17:18:17,134] INFO Deleted log /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000214733276.log. (kafka.log.LogSegment) [2019-01-18 17:18:17,138] INFO Deleted offset index /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000214733276.index. (kafka.log.LogSegment) [2019-01-18 17:18:17,143] INFO Deleted time index /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000214733276.timeindex. (kafka.log.LogSegment) [2019-01-18 17:18:17,143] INFO Deleted log /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000215834036.log. (kafka.log.LogSegment) [2019-01-18 17:18:17,148] INFO Deleted offset index /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000215834036.index. (kafka.log.LogSegment) [2019-01-18 17:18:17,155] INFO Deleted time index /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000215834036.timeindex. (kafka.log.LogSegment) [2019-01-18 17:18:17,162] INFO Deleted log /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000216931508.log. (kafka.log.LogSegment) [2019-01-18 17:18:17,162] INFO Deleted offset index /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000216931508.index. (kafka.log.LogSegment) [2019-01-18 17:18:17,162] INFO Deleted time index /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000216931508.timeindex. (kafka.log.LogSegment) [2019-01-18 17:18:17,201] INFO Deleted log /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000218035556.log. (kafka.log.LogSegment) [2019-01-18 17:18:17,202] INFO Deleted offset index /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000218035556.index. (kafka.log.LogSegment) [2019-01-18 17:18:17,203] INFO Deleted time index /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete/00000000000218035556.timeindex. (kafka.log.LogSegment) [2019-01-18 17:18:17,204] INFO Deleted log for partition test-12 in /data0/kafka/test-12.86be0659423f41239c2882598ae1c4ee-delete. (kafka.log.LogManager) [2019-01-18 17:18:31,493] INFO Updated PartitionLeaderEpoch. New: {epoch:1, offset:278183388}, Current: {epoch:0, offset:270207738} for Partition: test-148. Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:18:34,677] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-148 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:18:34,678] INFO [ReplicaFetcherManager on broker 25] Added fetcher for partitions List([test-148, initOffset 278244304 to broker BrokerEndPoint(71,dtsa71st.prod.yiran.com,9092)] ) (kafka.server.ReplicaFetcherManager) [2019-01-18 17:18:34,685] INFO [ReplicaFetcher replicaId=25, leaderId=71, fetcherId=2] Based on follower's leader epoch, leader replied with an offset 278244307 >= the follower's log end offset 278244307 in test-148. No truncation needed. (kafka.server.ReplicaFetcherThread) [2019-01-18 17:18:34,685] INFO [Log partition=test-148, dir=/data0/kafka] Truncating to 278244307 has no effect as the largest offset in the log is 278244306 (kafka.log.Log) [2019-01-18 17:18:34,703] INFO [Log partition=test-148, dir=/data0/kafka] Incrementing log start offset to 271166859 (kafka.log.Log) [2019-01-18 17:18:34,704] INFO Cleared earliest 0 entries from epoch cache based on passed offset 271166859 leaving 2 in EpochFile for partition test-148 (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:18:34,793] INFO Updated PartitionLeaderEpoch. New: {epoch:6, offset:278244307}, Current: {epoch:1, offset:278183388} for Partition: test-148. Cache now contains 2 entries. (kafka.server.epoch.LeaderEpochFileCache) [2019-01-18 17:18:52,532] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-62 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:18:52,532] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-62 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:18:52,533] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-62 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:18:52,533] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-62 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:18:52,548] INFO Log for partition test-62 is renamed to /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete and is scheduled for deletion (kafka.log.LogManager) [2019-01-18 17:19:52,548] INFO Deleted log /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000304646815.log. (kafka.log.LogSegment) [2019-01-18 17:19:52,552] INFO Deleted offset index /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000304646815.index. (kafka.log.LogSegment) [2019-01-18 17:19:52,557] INFO Deleted time index /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000304646815.timeindex. (kafka.log.LogSegment) [2019-01-18 17:19:52,557] INFO Deleted log /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000305924526.log. (kafka.log.LogSegment) [2019-01-18 17:19:52,562] INFO Deleted offset index /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000305924526.index. (kafka.log.LogSegment) [2019-01-18 17:19:52,567] INFO Deleted time index /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000305924526.timeindex. (kafka.log.LogSegment) [2019-01-18 17:19:52,567] INFO Deleted log /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000307247449.log. (kafka.log.LogSegment) [2019-01-18 17:19:52,572] INFO Deleted offset index /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000307247449.index. (kafka.log.LogSegment) [2019-01-18 17:19:52,578] INFO Deleted time index /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000307247449.timeindex. (kafka.log.LogSegment) [2019-01-18 17:19:52,578] INFO Deleted log /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000308531568.log. (kafka.log.LogSegment) [2019-01-18 17:19:52,582] INFO Deleted offset index /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000308531568.index. (kafka.log.LogSegment) [2019-01-18 17:19:52,588] INFO Deleted time index /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000308531568.timeindex. (kafka.log.LogSegment) [2019-01-18 17:19:52,589] INFO Deleted log /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000309869054.log. (kafka.log.LogSegment) [2019-01-18 17:19:52,592] INFO Deleted offset index /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000309869054.index. (kafka.log.LogSegment) [2019-01-18 17:19:52,598] INFO Deleted time index /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000309869054.timeindex. (kafka.log.LogSegment) [2019-01-18 17:19:52,605] INFO Deleted log /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000311151340.log. (kafka.log.LogSegment) [2019-01-18 17:19:52,605] INFO Deleted offset index /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000311151340.index. (kafka.log.LogSegment) [2019-01-18 17:19:52,605] INFO Deleted time index /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000311151340.timeindex. (kafka.log.LogSegment) [2019-01-18 17:19:52,648] INFO Deleted log /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000312462670.log. (kafka.log.LogSegment) [2019-01-18 17:19:52,649] INFO Deleted offset index /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000312462670.index. (kafka.log.LogSegment) [2019-01-18 17:19:52,651] INFO Deleted time index /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete/00000000000312462670.timeindex. (kafka.log.LogSegment) [2019-01-18 17:19:52,652] INFO Deleted log for partition test-62 in /data0/kafka/test-62.2fdec134cead45949c3ac7c6b0070bcd-delete. (kafka.log.LogManager) [2019-01-18 17:20:14,718] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-13 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:20:14,718] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-13 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:20:14,719] INFO [ReplicaFetcherManager on broker 25] Removed fetcher for partitions test-13 (kafka.server.ReplicaFetcherManager) [2019-01-18 17:20:14,719] INFO [ReplicaAlterLogDirsManager on broker 25] Removed fetcher for partitions test-13 (kafka.server.ReplicaAlterLogDirsManager) [2019-01-18 17:20:14,734] INFO Log for partition test-13 is renamed to /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete and is scheduled for deletion (kafka.log.LogManager) [2019-01-18 17:21:14,735] INFO Deleted log /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000217378255.log. (kafka.log.LogSegment) [2019-01-18 17:21:14,740] INFO Deleted offset index /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000217378255.index. (kafka.log.LogSegment) [2019-01-18 17:21:14,746] INFO Deleted time index /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000217378255.timeindex. (kafka.log.LogSegment) [2019-01-18 17:21:14,747] INFO Deleted log /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000218474095.log. (kafka.log.LogSegment) [2019-01-18 17:21:14,751] INFO Deleted offset index /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000218474095.index. (kafka.log.LogSegment) [2019-01-18 17:21:14,757] INFO Deleted time index /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000218474095.timeindex. (kafka.log.LogSegment) [2019-01-18 17:21:14,757] INFO Deleted log /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000219600314.log. (kafka.log.LogSegment) [2019-01-18 17:21:14,761] INFO Deleted offset index /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000219600314.index. (kafka.log.LogSegment) [2019-01-18 17:21:14,767] INFO Deleted time index /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000219600314.timeindex. (kafka.log.LogSegment) [2019-01-18 17:21:14,767] INFO Deleted log /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000220705812.log. (kafka.log.LogSegment) [2019-01-18 17:21:14,771] INFO Deleted offset index /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000220705812.index. (kafka.log.LogSegment) [2019-01-18 17:21:14,776] INFO Deleted time index /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000220705812.timeindex. (kafka.log.LogSegment) [2019-01-18 17:21:14,781] INFO Deleted log /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000221817957.log. (kafka.log.LogSegment) [2019-01-18 17:21:14,781] INFO Deleted offset index /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000221817957.index. (kafka.log.LogSegment) [2019-01-18 17:21:14,781] INFO Deleted time index /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000221817957.timeindex. (kafka.log.LogSegment) [2019-01-18 17:21:14,817] INFO Deleted log /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000222930921.log. (kafka.log.LogSegment) [2019-01-18 17:21:14,819] INFO Deleted offset index /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000222930921.index. (kafka.log.LogSegment) [2019-01-18 17:21:14,821] INFO Deleted time index /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete/00000000000222930921.timeindex. (kafka.log.LogSegment) [2019-01-18 17:21:14,822] INFO Deleted log for partition test-13 in /data0/kafka/test-13.8b0be8bbc20141f4ace6fcbb18c11385-delete. (kafka.log.LogManager) [2019-01-18 17:24:01,997] INFO Processing override for entityPath: topics/test with config: Map(retention.ms -> 259200000, max.message.bytes -> 6291456, min.insync.replicas -> 2) (kafka.server.DynamicConfigManager)