You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "abdulmuqueet mohammed (JIRA)" <ji...@apache.org> on 2018/05/31 19:34:00 UTC

[jira] [Commented] (KAFKA-6406) Topic deletion fails and kafka shuts down (on windows only)

    [ https://issues.apache.org/jira/browse/KAFKA-6406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16497050#comment-16497050 ] 

abdulmuqueet mohammed commented on KAFKA-6406:
----------------------------------------------

[https://stackoverflow.com/questions/48114040/exception-during-topic-deletion-when-kafka-is-hosted-in-docker-in-windows.]

Zeeman Solution is a workaround.

> Topic deletion fails and kafka shuts down (on windows only)
> -----------------------------------------------------------
>
>                 Key: KAFKA-6406
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6406
>             Project: Kafka
>          Issue Type: Bug
>          Components: core
>    Affects Versions: 1.0.0
>         Environment: Windows only, 
> Linux is ok
>            Reporter: pre sto
>            Priority: Major
>              Labels: windows
>
> [2017-12-28 21:30:40,593] INFO [GroupMetadataManager brokerId=1] Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
> [2017-12-28 21:30:40,607] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions skytest-0 (kafka.server.ReplicaFetcherManager)
> [2017-12-28 21:30:40,610] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions  (kafka.server.ReplicaFetcherManager)
> [2017-12-28 21:30:40,611] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions skytest-0 (kafka.server.ReplicaFetcherManager)
> [2017-12-28 21:30:40,633] ERROR Error while deleting skytest-0 in dir E:\dev\trunkA\runtime\target\x86_64\windows\skyboxview\server\bin\..\..\data\kafka\db. (kafka.server.LogDirFailureChannel)
> java.io.IOException: Failed to rename log directory from E:\dev\trunkA\runtime\target\x86_64\windows\skyboxview\server\bin\..\..\data\kafka\db\skytest-0 to E:\dev\trunkA\runtime\target\x86_64\windows\skyboxview\server\bin\..\..\data\kafka\db\skytest-0.2397c4520a0946f0a1887e31f056477b-delete
> 	at kafka.log.LogManager.asyncDelete(LogManager.scala:671)
> 	at kafka.cluster.Partition$$anonfun$delete$1.apply(Partition.scala:178)
> 	at kafka.cluster.Partition$$anonfun$delete$1.apply(Partition.scala:173)
> 	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.apply(ReplicaManager.scala:373)
> 	at kafka.server.ReplicaManager$$anonfun$stopReplicas$2.apply(ReplicaManager.scala:371)
> 	at scala.collection.Iterator$class.foreach(Iterator.scala:891)
> 	at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
> 	at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
> 	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)
> [2017-12-28 21:30:40,634] INFO [ReplicaManager broker=1] Stopping serving replicas in dir E:\dev\trunkA\runtime\target\x86_64\windows\skyboxview\server\bin\..\..\data\kafka\db (kafka.server.ReplicaManager)
> [2017-12-28 21:30:40,635] INFO [ReplicaManager broker=1] Partitions  are offline due to failure on log directory E:\dev\trunkA\runtime\target\x86_64\windows\skyboxview\server\bin\..\..\data\kafka\db (kafka.server.ReplicaManager)
> [2017-12-28 21:30:40,636] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions  (kafka.server.ReplicaFetcherManager)
> [2017-12-28 21:30:40,637] INFO [ReplicaManager broker=1] Broker 1 stopped fetcher for partitions  because they are in the failed log dir E:\dev\trunkA\runtime\target\x86_64\windows\skyboxview\server\bin\..\..\data\kafka\db (kafka.server.ReplicaManager)
> [2017-12-28 21:30:40,637] INFO Stopping serving logs in dir E:\dev\trunkA\runtime\target\x86_64\windows\skyboxview\server\bin\..\..\data\kafka\db (kafka.log.LogManager)
> [2017-12-28 21:30:40,638] FATAL Shutdown broker because all log dirs in E:\dev\trunkA\runtime\target\x86_64\windows\skyboxview\server\bin\..\..\data\kafka\db have failed (kafka.log.LogManager)



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)