[jira] [Created] (KAFKA-3415) AdminOperationException when altering Topic with same number of partitions

[JIRA]

Gérald Quintana created KAFKA-3415:
--------------------------------------

             Summary: AdminOperationException when altering Topic with same 
number of partitions
                 Key: KAFKA-3415
                 URL: https://issues.apache.org/jira/browse/KAFKA-3415
             Project: Kafka
          Issue Type: Improvement
          Components: admin
    Affects Versions: 0.9.0.1
            Reporter: Gérald Quintana
            Priority: Minor


To automate topic creation/modification, we sometimes run kafka-topics.sh 
script with the same topic config. It raises an AdminOperationException, in 
short it's idempotent

{code}
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic logfailed
Topic:logfailed PartitionCount:1        ReplicationFactor:1     
Configs:retention.ms=604800000,retention.bytes=209715200
        Topic: logfailed        Partition: 0    Leader: 1       Replicas: 1     
Isr: 1

bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic logfailed 
--partitions 1 --config retention.bytes=209715200 --config 
retention.ms=604800000
WARNING: Altering topic configuration from this script has been deprecated and 
may be removed in future releases.
         Going forward, please use kafka-configs.sh for this functionality
Updated config for topic "logfailed".
WARNING: If partitions are increased for a topic that has a key, the partition 
logic or ordering of the messages will be affected
Error while executing topic command : The number of partitions for a topic can 
only be increased
[2016-03-17 12:25:20,458] ERROR kafka.admin.AdminOperationException: The number 
of partitions for a topic can only be increased
        at kafka.admin.AdminUtils$.addPartitions(AdminUtils.scala:119)
        at 
kafka.admin.TopicCommand$$anonfun$alterTopic$1.apply(TopicCommand.scala:139)
        at 
kafka.admin.TopicCommand$$anonfun$alterTopic$1.apply(TopicCommand.scala:116)
        at 
scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
        at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
        at kafka.admin.TopicCommand$.alterTopic(TopicCommand.scala:116)
        at kafka.admin.TopicCommand$.main(TopicCommand.scala:62)
        at kafka.admin.TopicCommand.main(TopicCommand.scala)
 (kafka.admin.TopicCommand$)
{code}



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