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

Sriharsha Chintalapani commented on KAFKA-1507:
-----------------------------------------------

[~jkreps] Since create/update/topic requests are part of KIP-4. Your proposal 
if the producer is throwing errors like UnknownTopicOrPartition users should 
catch this error and use AdminClient create a topic?. I still see a benefit of 
allowing users to pass in their required topic config( partitions, replication 
etcc) and if there is no topic exists send a createTopicRequest. If this is not 
desirable as per your suggestion we need to implement AdminClient?. In this 
case they can use AdminUtils and we should modify the AdminUtils send requests 
to broker instead of directly sending requests to zookeeper. This will also 
help KAFKA-1688 as all the create/update/delete requests will go through broker 
authorizer. Let me know if this what your thinking.

> Using GetOffsetShell against non-existent topic creates the topic 
> unintentionally
> ---------------------------------------------------------------------------------
>
>                 Key: KAFKA-1507
>                 URL: https://issues.apache.org/jira/browse/KAFKA-1507
>             Project: Kafka
>          Issue Type: Bug
>    Affects Versions: 0.8.1.1
>         Environment: centos
>            Reporter: Luke Forehand
>            Assignee: Sriharsha Chintalapani
>            Priority: Minor
>              Labels: newbie
>         Attachments: KAFKA-1507.patch, KAFKA-1507.patch, 
> KAFKA-1507_2014-07-22_10:27:45.patch, KAFKA-1507_2014-07-23_17:07:20.patch, 
> KAFKA-1507_2014-08-12_18:09:06.patch, KAFKA-1507_2014-08-22_11:06:38.patch, 
> KAFKA-1507_2014-08-22_11:08:51.patch
>
>
> A typo in using GetOffsetShell command can cause a
> topic to be created which cannot be deleted (because deletion is still in
> progress)
> ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list
> kafka10:9092,kafka11:9092,kafka12:9092,kafka13:9092 --topic typo --time 1
> ./kafka-topics.sh --zookeeper stormqa1/kafka-prod --describe --topic typo
> Topic:typo      PartitionCount:8        ReplicationFactor:1     Configs:
>          Topic: typo     Partition: 0    Leader: 10      Replicas: 10
>   Isr: 10
> ...



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

Reply via email to