From 69e638a99539aced6f0de6fd54a6f9f6b72e8366 Mon Sep 17 00:00:00 2001
From: Lari Hotari <lhotari@users.noreply.github.com>
Date: Mon, 20 Jan 2025 10:42:51 -0800
Subject: [PATCH] [improve][broker] Improve Consumer.equals performance
 (#23864)

(cherry picked from commit 3c2ec2bf8bfd94eded46b42c5089dd8321afd096)
(cherry picked from commit 69caf71c7232bbb7db87c1dc3a5e3b5b7b615282)
---
 .../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 183c6040205bc..80db47eda1c5d 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
@@ -958,6 +958,9 @@ public CompletableFuture<Void> 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());