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

Jun Rao commented on KAFKA-3175:
--------------------------------

The issue is that during the controller failover, we call 
KafkaController.initializeTopicDeletion(), which reads the to be deleted topic 
test from ZK and uses it to initialize initialTopicsToBeDeleted in 
TopicDeletionManager without checking isDeleteTopicEnabled. Then, when the 
controller sends an UpdateMetadataRequest, 
ControllerBrokerRequestBatch.addUpdateMetadataRequestForBrokers() marks the 
topic as deleted. Then, the broker removes the topic from the metadata cache.

To fix this, we will need to check isDeleteTopicEnabled when initializing 
TopicDeletionManager.

> topic not accessible after deletion even when delete.topic.enable is disabled
> -----------------------------------------------------------------------------
>
>                 Key: KAFKA-3175
>                 URL: https://issues.apache.org/jira/browse/KAFKA-3175
>             Project: Kafka
>          Issue Type: Bug
>          Components: core
>    Affects Versions: 0.9.0.0
>            Reporter: Jun Rao
>            Assignee: Mayuresh Gharat
>
> The can be reproduced with the following steps.
> 1. start ZK and 1 broker (with default delete.topic.enable=false)
> 2. create a topic test
> bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic test 
> --partition 1 --replication-factor 1
> 3. delete topic test
> bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test
> 4. restart the broker
> Now topic test still shows up during topic description.
> bin/kafka-topics.sh --zookeeper localhost:2181 --describe
> Topic:test    PartitionCount:1        ReplicationFactor:1     Configs:
>       Topic: test     Partition: 0    Leader: 0       Replicas: 0     Isr: 0
> However, one can't produce to this topic any more.
> bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
> [2016-01-29 17:55:24,527] WARN Error while fetching metadata with correlation 
> id 0 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
> [2016-01-29 17:55:24,725] WARN Error while fetching metadata with correlation 
> id 1 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
> [2016-01-29 17:55:24,828] WARN Error while fetching metadata with correlation 
> id 2 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to