Skip to content

Commit f1cff36

Browse files
committed
Sort replicas and ISR fields in topic command
closes #44
1 parent 4206b97 commit f1cff36

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

cmd/kaf/topic.go

+7-1
Original file line numberDiff line numberDiff line change
@@ -148,7 +148,13 @@ var describeTopicCmd = &cobra.Command{
148148
highWatermarks := getHighWatermarks(args[0], partitions)
149149

150150
for _, partition := range detail.Partitions {
151-
fmt.Fprintf(w, "\t%v\t%v\t%v\t%v\t%v\t\n", partition.ID, highWatermarks[partition.ID], partition.Leader, partition.Replicas, partition.Isr)
151+
sortedReplicas := partition.Replicas
152+
sort.Slice(sortedReplicas, func(i, j int) bool { return sortedReplicas[i] < sortedReplicas[j] })
153+
154+
sortedISR := partition.Isr
155+
sort.Slice(sortedISR, func(i, j int) bool { return sortedISR[i] < sortedISR[j] })
156+
157+
fmt.Fprintf(w, "\t%v\t%v\t%v\t%v\t%v\t\n", partition.ID, highWatermarks[partition.ID], partition.Leader, sortedReplicas, sortedISR)
152158
}
153159
fmt.Fprintf(w, "Config:\n")
154160
fmt.Fprintf(w, "\tName\tValue\tReadOnly\tSensitive\t\n")

0 commit comments

Comments
 (0)