(pulsar) branch master updated: [improve][client] Use SHA-256 for generated reader subscription names (#26153)

[davekj]

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

david-streamlio pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 73d61e413ec4 [improve][client] Use SHA-256 for generated reader 
subscription names (#26153)
73d61e413ec4 is described below

commit 73d61e413ec43ebd1200b7956fa6748620b24aa6
Author: David Kjerrumgaard <35466513+david-stream...@users.noreply.github.com>
AuthorDate: Thu Jul 9 07:53:28 2026 -0700

    [improve][client] Use SHA-256 for generated reader subscription names 
(#26153)
---
 .../main/java/org/apache/pulsar/client/impl/MultiTopicsReaderImpl.java | 3 ++-
 .../src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java        | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsReaderImpl.java
 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsReaderImpl.java
index dec9ce2435e8..eb245750f2f1 100644
--- 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsReaderImpl.java
+++ 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsReaderImpl.java
@@ -61,7 +61,8 @@ public class MultiTopicsReaderImpl<T> implements Reader<T> {
         if (StringUtils.isNotBlank(readerConfiguration.getSubscriptionName())) 
{
             subscription = readerConfiguration.getSubscriptionName();
         } else {
-            subscription = "multiTopicsReader-" + 
DigestUtils.sha1Hex(UUID.randomUUID().toString()).substring(0, 10);
+            subscription = "multiTopicsReader-"
+                    + 
DigestUtils.sha256Hex(UUID.randomUUID().toString()).substring(0, 10);
             if 
(StringUtils.isNotBlank(readerConfiguration.getSubscriptionRolePrefix())) {
                 subscription = readerConfiguration.getSubscriptionRolePrefix() 
+ "-" + subscription;
             }
diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java
index fc3687f546b3..6ef232d9387d 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java
@@ -65,7 +65,7 @@ public class ReaderImpl<T> implements Reader<T> {
         if (StringUtils.isNotBlank(readerConfiguration.getSubscriptionName())) 
{
             subscription = readerConfiguration.getSubscriptionName();
         } else {
-            subscription = "reader-" + 
DigestUtils.sha1Hex(UUID.randomUUID().toString()).substring(0, 10);
+            subscription = "reader-" + 
DigestUtils.sha256Hex(UUID.randomUUID().toString()).substring(0, 10);
             if 
(StringUtils.isNotBlank(readerConfiguration.getSubscriptionRolePrefix())) {
                 subscription = readerConfiguration.getSubscriptionRolePrefix() 
+ "-" + subscription;
             }