Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- [2018-01-05 13:40:32,138] FATAL [Replica Manager on Broker 3]: Halting due to unrecoverable I/O error while handling produce request: (kafka.server.ReplicaManager)
- kafka.common.KafkaStorageException: I/O exception in append to log '__consumer_offsets-53'
- 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.immutable.Map$Map1.foreach(Map.scala:116)
- 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.coordinator.GroupMetadataManager.store(GroupMetadataManager.scala:225)
- at kafka.coordinator.GroupCoordinator$$anonfun$onCompleteJoin$6.apply(GroupCoordinator.scala:726)
- at kafka.coordinator.GroupCoordinator$$anonfun$onCompleteJoin$6.apply(GroupCoordinator.scala:726)
- at scala.Option.foreach(Option.scala:257)
- at kafka.coordinator.GroupCoordinator.onCompleteJoin(GroupCoordinator.scala:726)
- at kafka.coordinator.DelayedJoin.onComplete(DelayedJoin.scala:43)
- at kafka.server.DelayedOperation.forceComplete(DelayedOperation.scala:66)
- at kafka.coordinator.DelayedJoin$$anonfun$tryComplete$1.apply$mcZ$sp(DelayedJoin.scala:41)
- at kafka.coordinator.GroupCoordinator.tryCompleteJoin(GroupCoordinator.scala:672)
- at kafka.coordinator.DelayedJoin.tryComplete(DelayedJoin.scala:41)
- at kafka.coordinator.DelayedJoin.safeTryComplete(DelayedJoin.scala:39)
- at kafka.server.DelayedOperationPurgatory$Watchers.tryCompleteWatched(DelayedOperation.scala:322)
- at kafka.server.DelayedOperationPurgatory.checkAndComplete(DelayedOperation.scala:240)
- at kafka.coordinator.GroupCoordinator.onMemberFailure(GroupCoordinator.scala:665)
- at kafka.coordinator.GroupCoordinator.onExpireHeartbeat(GroupCoordinator.scala:740)
- at kafka.coordinator.DelayedHeartbeat.onExpiration(DelayedHeartbeat.scala:38)
- at kafka.server.DelayedOperation.run(DelayedOperation.scala:113)
- at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
- at java.util.concurrent.FutureTask.run(FutureTask.java:266)
- at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
- at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: java.nio.channels.ClosedChannelException
- at sun.nio.ch.FileChannelImpl.ensureOpen(FileChannelImpl.java:110)
- at sun.nio.ch.FileChannelImpl.size(FileChannelImpl.java:300)
- at kafka.log.FileMessageSet.truncateTo(FileMessageSet.scala:405)
- at kafka.log.FileMessageSet.trim(FileMessageSet.scala:378)
- at kafka.log.Log.roll(Log.scala:775)
- at kafka.log.Log.maybeRoll(Log.scala:744)
- at kafka.log.Log.append(Log.scala:405)
- ... 36 more
Advertisement
Add Comment
Please, Sign In to add comment