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

Swapnil Ghike commented on KAFKA-330:
-------------------------------------

Replying to a few comments, will follow up with changes according to others:

On the controller side: 
1. I think that the delete topics command will not take too long to complete, 
in any case it won't take any longer than Preferred Replica Election command. 
Both commands write to /admin zk path and trigger listeners that may send send 
some requests and update some zk paths. I believed that the reason for 
relinquishing the lock in ReassignPartitions listeners after every partition 
reassignment was that the controller waits for the new replicas to join the 
ISR, which could take long.
2. Hence I think that we should not relinquish the lock between deletion of two 
topics.
3. So maybe we don't need to use two separate zk paths? If we rerun the 
DeleteTopicsCommand, it should complain that the topics are absent in zookeeper 
if the topics were successfully deleted.

On the broker side:
4. LogManager: 
1. deleteLogs() indeed removes the logs from allLogs.
2. delete() is invoked on every individual log.
3. Yes, following up on this.

5. Log: 
1. The lock is acquired by all these functions, but I will double check if it 
needs to be acquired at the top level for our purpose.
3. Well, log.delete() takes care of deleting the individual segments. 

Will make modifications to Log*, hopefully they will address all your comments.

                
> Add delete topic support 
> -------------------------
>
>                 Key: KAFKA-330
>                 URL: https://issues.apache.org/jira/browse/KAFKA-330
>             Project: Kafka
>          Issue Type: Bug
>          Components: controller, log, replication
>    Affects Versions: 0.8
>            Reporter: Neha Narkhede
>            Assignee: Swapnil Ghike
>            Priority: Blocker
>              Labels: features, kafka-0.8, p2, project
>             Fix For: 0.8
>
>         Attachments: kafka-330-v1.patch
>
>
> One proposal of this API is here - 
> https://cwiki.apache.org/confluence/display/KAFKA/Kafka+replication+detailed+design+V2#KafkareplicationdetaileddesignV2-Deletetopic

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira

Reply via email to