Make initialSubscriptionName internal.

RobertIndie · RobertIndie · commit 0f202b5a0ca6 · 2022-01-29T15:13:41.000+08:00
Signed-off-by: Zike Yang &lt;zkyang@streamnative.io&gt;
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java
@@ -596,13 +596,4 @@ public interface ProducerBuilder<T> extends Cloneable {
      * @return the producer builder instance
      */
     ProducerBuilder<T> enableLazyStartPartitionedProducers(boolean lazyStartPartitionedProducers);
-
-    /**
-     * Use this config to automatically create an initial subscription when creating the topic.
-     * If this field is not set, the initial subscription will not be created.
-     *
-     * @param initialSubscriptionName Name of the initial subscription of the topic.
-     * @return the producer builder instance
-     */
-    ProducerBuilder<T> initialSubscriptionName(String initialSubscriptionName);
 }
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java
@@ -1871,11 +1871,12 @@ private void initDeadLetterProducerIfNeeded() {
             createProducerLock.writeLock().lock();
             try {
                 if (deadLetterProducer == null) {
-                    deadLetterProducer = client.newProducer(Schema.AUTO_PRODUCE_BYTES(schema))
-                            .topic(this.deadLetterPolicy.getDeadLetterTopic())
-                            .blockIfQueueFull(false)
-                            .initialSubscriptionName(this.deadLetterPolicy.getInitSubscriptionName())
-                            .createAsync();
+                    deadLetterProducer =
+                            ((ProducerBuilderImpl<byte[]>) client.newProducer(Schema.AUTO_PRODUCE_BYTES(schema)))
+                                    .initialSubscriptionName(this.deadLetterPolicy.getInitSubscriptionName())
+                                    .topic(this.deadLetterPolicy.getDeadLetterTopic())
+                                    .blockIfQueueFull(false)
+                                    .createAsync();
                 }
             } finally {
                 createProducerLock.writeLock().unlock();
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java
@@ -329,8 +329,15 @@ public ProducerBuilder<T> enableLazyStartPartitionedProducers(boolean lazyStartP
         return this;
     }
 
-    @Override
-    public ProducerBuilder<T> initialSubscriptionName(String initialSubscriptionName) {
+    /**
+     * Use this config to automatically create an initial subscription when creating the topic.
+     * If this field is not set, the initial subscription will not be created.
+     * This method is limited to internal use
+     *
+     * @param initialSubscriptionName Name of the initial subscription of the topic.
+     * @return the producer builder implementation instance
+     */
+    public ProducerBuilderImpl<T> initialSubscriptionName(String initialSubscriptionName) {
         conf.setInitialSubscriptionName(initialSubscriptionName);
         return this;
     }
