diff --git a/sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/PulsarMessage.java b/sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/PulsarMessage.java
index 739d34c98604..326671ad8fc3 100644
--- a/sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/PulsarMessage.java
+++ b/sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/PulsarMessage.java
@@ -31,19 +31,19 @@
 @DefaultSchema(AutoValueSchema.class)
 @AutoValue
 public abstract class PulsarMessage {
-  abstract @Nullable String getTopic();
+  public abstract @Nullable String getTopic();
 
-  abstract long getPublishTimestamp();
+  public abstract long getPublishTimestamp();
 
-  abstract @Nullable String getKey();
+  public abstract @Nullable String getKey();
 
   @SuppressWarnings("mutable")
-  abstract byte[] getValue();
+  public abstract byte[] getValue();
 
-  abstract @Nullable Map<String, String> getProperties();
+  public abstract @Nullable Map<String, String> getProperties();
 
   @SuppressWarnings("mutable")
-  abstract byte[] getMessageId();
+  public abstract byte[] getMessageId();
 
   public static PulsarMessage create(
       @Nullable String topicName,