[2019-05-20 14:07:13,950] INFO [ReplicaAlterLogDirsThread-1]: Starting (kafka.server.ReplicaAlterLogDirsThread)
[2019-05-20 14:07:13,951] INFO [ReplicaAlterLogDirsManager on broker 0] Added fetcher to broker BrokerEndPoint(id=0, host=localhost:-1) for partitions Map(test-0 -> (offset=0, leaderEpoch=0)) (kafka.server.ReplicaAlterLogDirsManager)
[2019-05-20 14:07:13,954] INFO [ReplicaAlterLogDirsThread-1]: Truncating partition test-0 to local high watermark 0 (kafka.server.ReplicaAlterLogDirsThread)
[2019-05-20 14:07:13,956] INFO [Log partition=test-0, dir=/tmp/test-topic] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.Log)
[2019-05-20 14:07:13,974] INFO Compaction for partition test-0 is resumed (kafka.log.LogManager)
[2019-05-20 14:07:13,974] INFO [ProducerStateManager partition=test-0] Writing producer snapshot at offset 8 (kafka.log.ProducerStateManager)
[2019-05-20 14:07:13,987] INFO The current replica is successfully replaced with the future replica for test-0 (kafka.log.LogManager)
[2019-05-20 14:07:16,621] INFO [ReplicaAlterLogDirsThread-1]: Shutting down (kafka.server.ReplicaAlterLogDirsThread)
[2019-05-20 14:07:16,623] INFO [ReplicaAlterLogDirsThread-1]: Stopped (kafka.server.ReplicaAlterLogDirsThread)
[2019-05-20 14:07:16,623] INFO [ReplicaAlterLogDirsThread-1]: Shutdown completed (kafka.server.ReplicaAlterLogDirsThread)
[2019-05-20 14:08:13,996] INFO Deleted log /tmp/kafka-logs/test-0.567a0d8ff88b45ab95794020d0b2e66f-delete/00000000000000000000.log. (kafka.log.LogSegment)
[2019-05-20 14:08:13,999] ERROR Error unmapping index /tmp/kafka-logs/test-0.567a0d8ff88b45ab95794020d0b2e66f-delete/00000000000000000000.index (kafka.log.OffsetIndex)
java.lang.NullPointerException
        at org.apache.kafka.common.utils.MappedByteBuffers.unmap(MappedByteBuffers.java:73)
        at kafka.log.AbstractIndex.forceUnmap(AbstractIndex.scala:318)
        at kafka.log.AbstractIndex.safeForceUnmap(AbstractIndex.scala:308)
        at kafka.log.AbstractIndex.$anonfun$closeHandler$1(AbstractIndex.scala:257)
        at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
        at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251)
        at kafka.log.AbstractIndex.closeHandler(AbstractIndex.scala:257)
        at kafka.log.AbstractIndex.deleteIfExists(AbstractIndex.scala:226)
        at kafka.log.LogSegment.$anonfun$deleteIfExists$6(LogSegment.scala:597)
        at kafka.log.LogSegment.delete$1(LogSegment.scala:585)
        at kafka.log.LogSegment.$anonfun$deleteIfExists$5(LogSegment.scala:597)
        at kafka.utils.CoreUtils$.$anonfun$tryAll$1(CoreUtils.scala:115)
        at kafka.utils.CoreUtils$.$anonfun$tryAll$1$adapted(CoreUtils.scala:114)
        at scala.collection.immutable.List.foreach(List.scala:392)
        at kafka.utils.CoreUtils$.tryAll(CoreUtils.scala:114)
        at kafka.log.LogSegment.deleteIfExists(LogSegment.scala:599)
        at kafka.log.Log.$anonfun$delete$3(Log.scala:1762)
        at kafka.log.Log.$anonfun$delete$3$adapted(Log.scala:1762)
        at scala.collection.Iterator.foreach(Iterator.scala:941)
        at scala.collection.Iterator.foreach$(Iterator.scala:941)
        at scala.collection.AbstractIterator.foreach(Iterator.scala:1429)
        at scala.collection.IterableLike.foreach(IterableLike.scala:74)
        at scala.collection.IterableLike.foreach$(IterableLike.scala:73)
        at scala.collection.AbstractIterable.foreach(Iterable.scala:56)
        at kafka.log.Log.$anonfun$delete$2(Log.scala:1762)
        at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
        at kafka.log.Log.maybeHandleIOException(Log.scala:2013)
        at kafka.log.Log.delete(Log.scala:1759)
        at kafka.log.LogManager.deleteLogs(LogManager.scala:761)
        at kafka.log.LogManager.$anonfun$deleteLogs$6(LogManager.scala:775)
        at kafka.utils.KafkaScheduler.$anonfun$schedule$2(KafkaScheduler.scala:114)
        at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:63)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
[2019-05-20 14:08:14,005] INFO Deleted offset index /tmp/kafka-logs/test-0.567a0d8ff88b45ab95794020d0b2e66f-delete/00000000000000000000.index. (kafka.log.LogSegment)
[2019-05-20 14:08:14,006] ERROR Error unmapping index /tmp/kafka-logs/test-0.567a0d8ff88b45ab95794020d0b2e66f-delete/00000000000000000000.timeindex (kafka.log.TimeIndex)
java.lang.NullPointerException
        at org.apache.kafka.common.utils.MappedByteBuffers.unmap(MappedByteBuffers.java:73)
        at kafka.log.AbstractIndex.forceUnmap(AbstractIndex.scala:318)
        at kafka.log.AbstractIndex.safeForceUnmap(AbstractIndex.scala:308)
        at kafka.log.AbstractIndex.$anonfun$closeHandler$1(AbstractIndex.scala:257)
        at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
        at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251)
        at kafka.log.AbstractIndex.closeHandler(AbstractIndex.scala:257)
        at kafka.log.AbstractIndex.deleteIfExists(AbstractIndex.scala:226)
        at kafka.log.LogSegment.$anonfun$deleteIfExists$8(LogSegment.scala:598)
        at kafka.log.LogSegment.delete$1(LogSegment.scala:585)
        at kafka.log.LogSegment.$anonfun$deleteIfExists$7(LogSegment.scala:598)
        at kafka.utils.CoreUtils$.$anonfun$tryAll$1(CoreUtils.scala:115)
        at kafka.utils.CoreUtils$.$anonfun$tryAll$1$adapted(CoreUtils.scala:114)
        at scala.collection.immutable.List.foreach(List.scala:392)
        at kafka.utils.CoreUtils$.tryAll(CoreUtils.scala:114)
        at kafka.log.LogSegment.deleteIfExists(LogSegment.scala:599)
        at kafka.log.Log.$anonfun$delete$3(Log.scala:1762)
        at kafka.log.Log.$anonfun$delete$3$adapted(Log.scala:1762)
        at scala.collection.Iterator.foreach(Iterator.scala:941)
        at scala.collection.Iterator.foreach$(Iterator.scala:941)
        at scala.collection.AbstractIterator.foreach(Iterator.scala:1429)
        at scala.collection.IterableLike.foreach(IterableLike.scala:74)
        at scala.collection.IterableLike.foreach$(IterableLike.scala:73)
        at scala.collection.AbstractIterable.foreach(Iterable.scala:56)
        at kafka.log.Log.$anonfun$delete$2(Log.scala:1762)
        at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
        at kafka.log.Log.maybeHandleIOException(Log.scala:2013)
        at kafka.log.Log.delete(Log.scala:1759)
        at kafka.log.LogManager.deleteLogs(LogManager.scala:761)
        at kafka.log.LogManager.$anonfun$deleteLogs$6(LogManager.scala:775)
        at kafka.utils.KafkaScheduler.$anonfun$schedule$2(KafkaScheduler.scala:114)
        at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:63)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
[2019-05-20 14:08:14,007] INFO Deleted time index /tmp/kafka-logs/test-0.567a0d8ff88b45ab95794020d0b2e66f-delete/00000000000000000000.timeindex. (kafka.log.LogSegment)
[2019-05-20 14:08:14,008] INFO Deleted log /tmp/kafka-logs/test-0.567a0d8ff88b45ab95794020d0b2e66f-delete/00000000000000000002.log. (kafka.log.LogSegment)
[2019-05-20 14:08:14,009] ERROR Error unmapping index /tmp/kafka-logs/test-0.567a0d8ff88b45ab95794020d0b2e66f-delete/00000000000000000002.index (kafka.log.OffsetIndex)
java.lang.NullPointerException
        at org.apache.kafka.common.utils.MappedByteBuffers.unmap(MappedByteBuffers.java:73)
        at kafka.log.AbstractIndex.forceUnmap(AbstractIndex.scala:318)
        at kafka.log.AbstractIndex.safeForceUnmap(AbstractIndex.scala:308)
        at kafka.log.AbstractIndex.$anonfun$closeHandler$1(AbstractIndex.scala:257)
        at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
        at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251)
        at kafka.log.AbstractIndex.closeHandler(AbstractIndex.scala:257)
        at kafka.log.AbstractIndex.deleteIfExists(AbstractIndex.scala:226)
        at kafka.log.LogSegment.$anonfun$deleteIfExists$6(LogSegment.scala:597)
        at kafka.log.LogSegment.delete$1(LogSegment.scala:585)
        at kafka.log.LogSegment.$anonfun$deleteIfExists$5(LogSegment.scala:597)
        at kafka.utils.CoreUtils$.$anonfun$tryAll$1(CoreUtils.scala:115)
        at kafka.utils.CoreUtils$.$anonfun$tryAll$1$adapted(CoreUtils.scala:114)
        at scala.collection.immutable.List.foreach(List.scala:392)
        at kafka.utils.CoreUtils$.tryAll(CoreUtils.scala:114)
        at kafka.log.LogSegment.deleteIfExists(LogSegment.scala:599)
        at kafka.log.Log.$anonfun$delete$3(Log.scala:1762)
        at kafka.log.Log.$anonfun$delete$3$adapted(Log.scala:1762)
        at scala.collection.Iterator.foreach(Iterator.scala:941)
        at scala.collection.Iterator.foreach$(Iterator.scala:941)
        at scala.collection.AbstractIterator.foreach(Iterator.scala:1429)
        at scala.collection.IterableLike.foreach(IterableLike.scala:74)
        at scala.collection.IterableLike.foreach$(IterableLike.scala:73)
        at scala.collection.AbstractIterable.foreach(Iterable.scala:56)
        at kafka.log.Log.$anonfun$delete$2(Log.scala:1762)
        at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
        at kafka.log.Log.maybeHandleIOException(Log.scala:2013)
        at kafka.log.Log.delete(Log.scala:1759)
        at kafka.log.LogManager.deleteLogs(LogManager.scala:761)
        at kafka.log.LogManager.$anonfun$deleteLogs$6(LogManager.scala:775)
        at kafka.utils.KafkaScheduler.$anonfun$schedule$2(KafkaScheduler.scala:114)
        at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:63)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
[2019-05-20 14:08:14,010] INFO Deleted offset index /tmp/kafka-logs/test-0.567a0d8ff88b45ab95794020d0b2e66f-delete/00000000000000000002.index. (kafka.log.LogSegment)
[2019-05-20 14:08:14,010] ERROR Error unmapping index /tmp/kafka-logs/test-0.567a0d8ff88b45ab95794020d0b2e66f-delete/00000000000000000002.timeindex (kafka.log.TimeIndex)
java.lang.NullPointerException
        at org.apache.kafka.common.utils.MappedByteBuffers.unmap(MappedByteBuffers.java:73)
        at kafka.log.AbstractIndex.forceUnmap(AbstractIndex.scala:318)
        at kafka.log.AbstractIndex.safeForceUnmap(AbstractIndex.scala:308)
        at kafka.log.AbstractIndex.$anonfun$closeHandler$1(AbstractIndex.scala:257)
        at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
        at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251)
        at kafka.log.AbstractIndex.closeHandler(AbstractIndex.scala:257)
        at kafka.log.AbstractIndex.deleteIfExists(AbstractIndex.scala:226)
        at kafka.log.LogSegment.$anonfun$deleteIfExists$8(LogSegment.scala:598)
        at kafka.log.LogSegment.delete$1(LogSegment.scala:585)
        at kafka.log.LogSegment.$anonfun$deleteIfExists$7(LogSegment.scala:598)
        at kafka.utils.CoreUtils$.$anonfun$tryAll$1(CoreUtils.scala:115)
        at kafka.utils.CoreUtils$.$anonfun$tryAll$1$adapted(CoreUtils.scala:114)
        at scala.collection.immutable.List.foreach(List.scala:392)
        at kafka.utils.CoreUtils$.tryAll(CoreUtils.scala:114)
        at kafka.log.LogSegment.deleteIfExists(LogSegment.scala:599)
        at kafka.log.Log.$anonfun$delete$3(Log.scala:1762)
        at kafka.log.Log.$anonfun$delete$3$adapted(Log.scala:1762)
        at scala.collection.Iterator.foreach(Iterator.scala:941)
        at scala.collection.Iterator.foreach$(Iterator.scala:941)
        at scala.collection.AbstractIterator.foreach(Iterator.scala:1429)
        at scala.collection.IterableLike.foreach(IterableLike.scala:74)
        at scala.collection.IterableLike.foreach$(IterableLike.scala:73)
        at scala.collection.AbstractIterable.foreach(Iterable.scala:56)
        at kafka.log.Log.$anonfun$delete$2(Log.scala:1762)
        at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
        at kafka.log.Log.maybeHandleIOException(Log.scala:2013)
        at kafka.log.Log.delete(Log.scala:1759)
        at kafka.log.LogManager.deleteLogs(LogManager.scala:761)
        at kafka.log.LogManager.$anonfun$deleteLogs$6(LogManager.scala:775)
        at kafka.utils.KafkaScheduler.$anonfun$schedule$2(KafkaScheduler.scala:114)
        at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:63)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
[2019-05-20 14:08:14,012] INFO Deleted time index /tmp/kafka-logs/test-0.567a0d8ff88b45ab95794020d0b2e66f-delete/00000000000000000002.timeindex. (kafka.log.LogSegment)
[2019-05-20 14:08:14,022] INFO Deleted log for partition test-0 in /tmp/kafka-logs/test-0.567a0d8ff88b45ab95794020d0b2e66f-delete. (kafka.log.LogManager)