(kafka) branch 4.3 updated: MINOR: Consumer tidying (#21832)

[chia7712]

This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch 4.3
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/4.3 by this push:
     new 754b347a5bb MINOR: Consumer tidying (#21832)
754b347a5bb is described below

commit 754b347a5bbcd077d87f81dee0c29d86c70c478d
Author: Andrew Schofield <aschofi...@confluent.io>
AuthorDate: Fri Mar 20 14:29:46 2026 +0000

    MINOR: Consumer tidying (#21832)
    
    Resolves a couple of review comments from
    https://github.com/apache/kafka/pull/21711. The remaining comments are
    in `ShareConsumerTest` and will be addressed separately.
    
    Reviewers: Lianet Magrans <lmagr...@confluent.io>, Viktor Somogyi-Vass
     <viktorsomo...@gmail.com>, Chia-Ping Tsai <chia7...@gmail.com>
---
 .../apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java   | 4 ++--
 .../apache/kafka/clients/consumer/internals/ShareConsumerImpl.java    | 3 ++-
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java
 
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java
index c08dcfa325a..12cee2eb464 100644
--- 
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java
+++ 
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java
@@ -1814,7 +1814,7 @@ public class AsyncKafkaConsumer<K, V> implements 
ConsumerDelegate<K, V> {
     }
 
     /**
-     * Get the current subscription.  or an empty set if no such call has
+     * Get the current subscription, or an empty set if no such call has
      * been made.
      * @return The set of topics currently subscribed to
      */
@@ -1822,7 +1822,7 @@ public class AsyncKafkaConsumer<K, V> implements 
ConsumerDelegate<K, V> {
     public Set<String> subscription() {
         acquireAndEnsureOpen();
         try {
-            return Collections.unmodifiableSet(subscriptions.subscription());
+            return Set.copyOf(subscriptions.subscription());
         } finally {
             release();
         }
diff --git 
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java
 
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java
index 448e3436bd9..35115acaf7b 100644
--- 
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java
+++ 
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java
@@ -81,6 +81,7 @@ import java.net.InetSocketAddress;
 import java.time.Duration;
 import java.util.Arrays;
 import java.util.Collection;
+import java.util.Collections;
 import java.util.ConcurrentModificationException;
 import java.util.HashMap;
 import java.util.LinkedList;
@@ -955,7 +956,7 @@ public class ShareConsumerImpl<K, V> implements 
ShareConsumerDelegate<K, V> {
      */
     @Override
     public Map<MetricName, ? extends Metric> metrics() {
-        return Map.copyOf(metrics.metrics());
+        return Collections.unmodifiableMap(metrics.metrics());
     }
 
     /**