[
https://issues.apache.org/jira/browse/KAFKA-3415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15199990#comment-15199990
]
Edoardo Comar commented on KAFKA-3415:
--------------------------------------
As the user opening the JIRA stated, they use the scripts as part of
automation.
Having the script behave idempotently is actually simpler than checking the
number of partitions and bumping up only if needed.
> 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)
