> On May 26, 2015, 7:08 a.m., Michael Noll wrote: > > core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala, line 81 > > <https://reviews.apache.org/r/34641/diff/1/?file=971195#file971195line81> > > > > Should we also consider reassignments that are in-progress as "errors"? > > > > The reasoning is that you'd like to do the following in (say) Ansible: > > "Trigger reassignment of partitions, wait until all are completed, and only > > then continue with the next action." > > > > That being said, there are other ways to achieve this in tools like > > Ansible. For instance, you can trigger reassignents, then repeatedly call > > `--verify` in a loop and capture its STDOUT, looking for "is still in > > progress" and "failed". However, this is arguably more error prone because > > the log messages can change between Kafka versions (and oftentimes such > > changes are not prominently advertised, so you only notice this once your > > deployment script breaks). > > Manikumar Reddy O wrote: > Yes, we can consider in-progress as "errors". Other option could be > returning a different error code. Let us wait for others suggestions/concerns.
I wouldn't consider in-progress as error, since in-progress is pretty much the expected behavior here (reassigning takes a while and the tool exits immediately). As you mentioned, the ansible script should include triggering re-assignment and then polling periodically until its completed. (like you would for HDFS rebalance, Oozie job, MR job, etc) Perhaps just commenting on --verify output that this is a public API and should never change would be ok? - Gwen ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34641/#review85154 ----------------------------------------------------------- On July 10, 2015, 4:28 p.m., Manikumar Reddy O wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/34641/ > ----------------------------------------------------------- > > (Updated July 10, 2015, 4:28 p.m.) > > > Review request for kafka. > > > Bugs: KAFKA-2214 > https://issues.apache.org/jira/browse/KAFKA-2214 > > > Repository: kafka > > > Description > ------- > > rebase > > > Diffs > ----- > > core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala > ea345895a52977c25bff57e95e12b8662331d7fe > > Diff: https://reviews.apache.org/r/34641/diff/ > > > Testing > ------- > > > Thanks, > > Manikumar Reddy O > >
