分区比较栈溢出bug修复

This commit is contained in:
许晓东
2022-01-18 20:42:11 +08:00
parent e8fe2ea1c7
commit a311a34537

View File

@@ -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;