kafka-topic.sh should show adding and removing replicas
Reviewers: Colin P. McCabe
@@ -146,6 +146,10 @@ object TopicCommand extends Logging {
print("\tLeader: " + (if (hasLeader) info.leader.id else "none"))
print("\tReplicas: " + info.replicas.asScala.map(_.id).mkString(","))
print("\tIsr: " + info.isr.asScala.map(_.id).mkString(","))
+ if (reassignment.nonEmpty) {
+ print("\tAdding Replicas: " + reassignment.get.addingReplicas().asScala.mkString(","))
+ print("\tRemoving Replicas: " + reassignment.get.removingReplicas().asScala.mkString(","))
+ }
print(if (markedForDeletion) "\tMarkedForDeletion: true" else "")
println()
}
