[
https://issues.apache.org/jira/browse/KAFKA-3415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927867#comment-15927867
]
ASF GitHub Bot commented on KAFKA-3415:
---------------------------------------
Github user edoardocomar closed the pull request at:
https://github.com/apache/kafka/pull/1089
> 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 not 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.15#6346)
