[FLINK-29580][Connector/Pulsar] Remove pulsar.consumer.autoUpdatePart…

…itionsIntervalSeconds option. (apache#21070)
mbalassi · Oct 18, 2022 · 2bab5ad · 2bab5ad
1 parent 959fe97
commit 2bab5ad
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 18 deletions.
diff --git a/docs/layouts/shortcodes/generated/pulsar_consumer_configuration.html b/docs/layouts/shortcodes/generated/pulsar_consumer_configuration.html
@@ -32,12 +32,6 @@
  <td>Boolean</td>
  <td>Buffering a large number of outstanding uncompleted chunked messages can bring memory pressure and it can be guarded by providing this <code class="highlighter-rouge">pulsar.consumer.maxPendingChunkedMessage</code> threshold. Once a consumer reaches this threshold, it drops the outstanding unchunked-messages by silently acknowledging if <code class="highlighter-rouge">pulsar.consumer.autoAckOldestChunkedMessageOnQueueFull</code> is true. Otherwise, it marks them for redelivery.</td>
  </tr>
- <tr>
- <td><h5>pulsar.consumer.autoUpdatePartitionsIntervalSeconds</h5></td>
- <td style="word-wrap: break-word;">60</td>
- <td>Integer</td>
- <td>The interval (in seconds) of updating partitions. This only works if autoUpdatePartitions is enabled.</td>
- </tr>
  <tr>
  <td><h5>pulsar.consumer.consumerName</h5></td>
  <td style="word-wrap: break-word;">(none)</td>

diff --git a/...or-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java b/...or-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java
@@ -584,13 +584,6 @@ private PulsarSourceOptions() {
  .defaultValue(false)
  .withDescription("If enabled, the consumer will automatically retry messages.");
 
- public static final ConfigOption<Integer> PULSAR_AUTO_UPDATE_PARTITIONS_INTERVAL_SECONDS =
- ConfigOptions.key(CONSUMER_CONFIG_PREFIX + "autoUpdatePartitionsIntervalSeconds")
- .intType()
- .defaultValue(60)
- .withDescription(
- "The interval (in seconds) of updating partitions. This only works if autoUpdatePartitions is enabled.");
-
  public static final ConfigOption<Boolean> PULSAR_REPLICATE_SUBSCRIPTION_STATE =
  ConfigOptions.key(CONSUMER_CONFIG_PREFIX + "replicateSubscriptionState")
  .booleanType()

diff --git a/...rc/main/java/org/apache/flink/connector/pulsar/source/config/PulsarSourceConfigUtils.java b/...rc/main/java/org/apache/flink/connector/pulsar/source/config/PulsarSourceConfigUtils.java
@@ -35,7 +35,6 @@
 
 import static java.util.concurrent.TimeUnit.MICROSECONDS;
 import static java.util.concurrent.TimeUnit.MILLISECONDS;
-import static java.util.concurrent.TimeUnit.SECONDS;
 import static org.apache.flink.connector.pulsar.common.config.PulsarOptions.PULSAR_ADMIN_URL;
 import static org.apache.flink.connector.pulsar.common.config.PulsarOptions.PULSAR_AUTH_PARAMS;
 import static org.apache.flink.connector.pulsar.common.config.PulsarOptions.PULSAR_AUTH_PARAM_MAP;
@@ -44,7 +43,6 @@
 import static org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_ACK_RECEIPT_ENABLED;
 import static org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_ACK_TIMEOUT_MILLIS;
 import static org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_AUTO_ACK_OLDEST_CHUNKED_MESSAGE_ON_QUEUE_FULL;
-import static org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_AUTO_UPDATE_PARTITIONS_INTERVAL_SECONDS;
 import static org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_CONSUMER_NAME;
 import static org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_CONSUMER_PROPERTIES;
 import static org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_CRYPTO_FAILURE_ACTION;
@@ -121,9 +119,6 @@ public static <T> ConsumerBuilder<T> createConsumerBuilder(
  configuration.useOption(PULSAR_READ_COMPACTED, builder::readCompacted);
  configuration.useOption(PULSAR_PRIORITY_LEVEL, builder::priorityLevel);
  createDeadLetterPolicy(configuration).ifPresent(builder::deadLetterPolicy);
- configuration.useOption(
- PULSAR_AUTO_UPDATE_PARTITIONS_INTERVAL_SECONDS,
- v -> builder.autoUpdatePartitionsInterval(v, SECONDS));
  configuration.useOption(PULSAR_RETRY_ENABLE, builder::enableRetry);
  configuration.useOption(
  PULSAR_MAX_PENDING_CHUNKED_MESSAGE, builder::maxPendingChunkedMessage);