From 3c2ec2bf8bfd94eded46b42c5089dd8321afd096 Mon Sep 17 00:00:00 2001 From: Lari Hotari Date: Mon, 20 Jan 2025 10:42:51 -0800 Subject: [PATCH] [improve][broker] Improve Consumer.equals performance (#23864) --- .../main/java/org/apache/pulsar/broker/service/Consumer.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java index 0baba13cc0b07..b46e10a20fd34 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java @@ -1048,6 +1048,9 @@ public CompletableFuture checkPermissionsAsync() { @Override public boolean equals(Object obj) { + if (this == obj) { + return true; + } if (obj instanceof Consumer) { Consumer other = (Consumer) obj; return consumerId == other.consumerId && Objects.equals(cnx.clientAddress(), other.cnx.clientAddress());