diff --git a/src/main/java/com/xuxd/kafka/console/beans/TopicPartition.java b/src/main/java/com/xuxd/kafka/console/beans/TopicPartition.java index fa6aab2..293cd29 100644 --- a/src/main/java/com/xuxd/kafka/console/beans/TopicPartition.java +++ b/src/main/java/com/xuxd/kafka/console/beans/TopicPartition.java @@ -21,7 +21,7 @@ public class TopicPartition implements Comparable { } TopicPartition other = (TopicPartition) o; if (!this.topic.equals(other.getTopic())) { - return this.compareTo(other); + return this.topic.compareTo(other.topic); } return this.partition - other.partition;