(pulsar) branch master updated: [fix] Fix typos in class Message and Producer (#25265)

[penghui]

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

penghui 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 629ddebeec0 [fix] Fix typos in class Message and Producer    (#25265)
629ddebeec0 is described below

commit 629ddebeec08438536a6b63f413c11caaf445b1f
Author: Hm <khm052...@gmail.com>
AuthorDate: Thu Mar 5 14:45:55 2026 +0900

    [fix] Fix typos in class Message and Producer    (#25265)
---
 .../src/main/java/org/apache/pulsar/broker/service/Producer.java        | 2 +-
 .../src/main/java/org/apache/pulsar/client/api/Message.java             | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java
index 9d0c1080254..9534dfd7575 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java
@@ -838,7 +838,7 @@ public class Producer {
                     .allowTopicOperationAsync(topicName, 
TopicOperation.PRODUCE, appId, cnx.getAuthenticationData())
                     .handle((ok, ex) -> {
                         if (ex != null) {
-                            log.warn("[{}] Get unexpected error while 
autorizing [{}]  {}", appId, topic.getName(),
+                            log.warn("[{}] Get unexpected error while 
authorizing [{}]  {}", appId, topic.getName(),
                                     ex.getMessage(), ex);
                         }
 
diff --git 
a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Message.java 
b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Message.java
index d76618b1e1d..029beaf590e 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Message.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Message.java
@@ -185,7 +185,7 @@ public interface Message<T> {
      * {@link EncryptionContext} contains encryption and compression 
information in it using which application can
      * decrypt consumed message with encrypted-payload.
      *
-     * @return the optiona encryption context
+     * @return the optional encryption context
      */
     Optional<EncryptionContext> getEncryptionCtx();