You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Alex Galperin <al...@gmail.com> on 2018/01/05 12:28:17 UTC
Exception during topic deletion when Kafka is hosted in Docker in Windows.
Hi,
I host Kafka in Docker container in Windows. I mounted volume for storing
Kafka data log.
When I try to delete topic, I receive the following error:
ERROR Error while deleting test-0 in dir /var/lib/kafka.
(kafka.server.LogDirFailureChannel)
java.io.IOException: Failed to rename log directory from
/var/lib/kafka/test-0 to
/var/lib/kafka/test-0.a81ff9700e4e4c3e8b20c6d949971b64-delete
at kafka.log.LogManager.asyncDelete(LogManager.scala:671)
at kafka.cluster.Partition.$anonfun$delete$1(Partition.scala:178)
at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:217)
at kafka.utils.CoreUtils$.inWriteLock(CoreUtils.scala:225)
at kafka.cluster.Partition.delete(Partition.scala:173)
at kafka.server.ReplicaManager.stopReplica(ReplicaManager.scala:341)
at
kafka.server.ReplicaManager.$anonfun$stopReplicas$2(ReplicaManager.scala:373)
at scala.collection.Iterator.foreach(Iterator.scala:929)
at scala.collection.Iterator.foreach$(Iterator.scala:929)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1417)
at scala.collection.IterableLike.foreach(IterableLike.scala:71)
at scala.collection.IterableLike.foreach$(IterableLike.scala:70)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at kafka.server.ReplicaManager.stopReplicas(ReplicaManager.scala:371)
at kafka.server.KafkaApis.handleStopReplicaRequest(KafkaApis.scala:190)
at kafka.server.KafkaApis.handle(KafkaApis.scala:104)
at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:65)
at java.lang.Thread.run(Thread.java:748)
Could somebody help me to cope with this issue?
Thank you in advance,
/Alex
Re: Exception during topic deletion when Kafka is hosted in Docker in Windows.
Posted by Ted Yu <yu...@gmail.com>.
Which Kafka release are you using ?
Most likely /var/lib/kafka/test-0 was still being referenced by some thread.
There have been fixes in this area recently.
Cheers
On Fri, Jan 5, 2018 at 4:28 AM, Alex Galperin <al...@gmail.com>
wrote:
> Hi,
> I host Kafka in Docker container in Windows. I mounted volume for storing
> Kafka data log.
> When I try to delete topic, I receive the following error:
>
> ERROR Error while deleting test-0 in dir /var/lib/kafka.
> (kafka.server.LogDirFailureChannel)
> java.io.IOException: Failed to rename log directory from
> /var/lib/kafka/test-0 to
> /var/lib/kafka/test-0.a81ff9700e4e4c3e8b20c6d949971b64-delete
> at kafka.log.LogManager.asyncDelete(LogManager.scala:671)
> at kafka.cluster.Partition.$anonfun$delete$1(Partition.scala:178)
> at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:217)
> at kafka.utils.CoreUtils$.inWriteLock(CoreUtils.scala:225)
> at kafka.cluster.Partition.delete(Partition.scala:173)
> at kafka.server.ReplicaManager.stopReplica(ReplicaManager.scala:341)
> at
> kafka.server.ReplicaManager.$anonfun$stopReplicas$2(
> ReplicaManager.scala:373)
> at scala.collection.Iterator.foreach(Iterator.scala:929)
> at scala.collection.Iterator.foreach$(Iterator.scala:929)
> at scala.collection.AbstractIterator.foreach(Iterator.scala:1417)
> at scala.collection.IterableLike.foreach(IterableLike.scala:71)
> at scala.collection.IterableLike.foreach$(IterableLike.scala:70)
> at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> at kafka.server.ReplicaManager.stopReplicas(ReplicaManager.scala:371)
> at kafka.server.KafkaApis.handleStopReplicaRequest(KafkaApis.scala:190)
> at kafka.server.KafkaApis.handle(KafkaApis.scala:104)
> at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:65)
> at java.lang.Thread.run(Thread.java:748)
>
> Could somebody help me to cope with this issue?
>
> Thank you in advance,
> /Alex
>