This is an automated email from the ASF dual-hosted git repository.
mmerli 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 f4195874453 [improve][build] Suppress deprecation warnings across all
modules (#25421)
f4195874453 is described below
commit f419587445325503f8394f2da2d157a668212ca7
Author: Matteo Merli <[email protected]>
AuthorDate: Fri Mar 27 17:25:39 2026 -0700
[improve][build] Suppress deprecation warnings across all modules (#25421)
---
.../pulsar/client/impl/auth/AuthenticationAthenz.java | 1 +
.../java/org/apache/pulsar/admin/cli/CmdClusters.java | 1 +
.../java/org/apache/pulsar/admin/cli/CmdFunctions.java | 1 +
.../org/apache/pulsar/admin/cli/CmdNamespaces.java | 2 ++
.../apache/pulsar/admin/cli/CmdPersistentTopics.java | 1 +
.../java/org/apache/pulsar/admin/cli/CmdSinks.java | 2 ++
.../java/org/apache/pulsar/admin/cli/CmdSources.java | 1 +
.../java/org/apache/pulsar/admin/cli/CmdTopics.java | 1 +
.../apache/pulsar/client/impl/ClientBuilderImpl.java | 2 ++
.../org/apache/pulsar/client/impl/ConsumerBase.java | 3 ++-
.../apache/pulsar/client/impl/ConsumerBuilderImpl.java | 1 +
.../org/apache/pulsar/client/impl/ConsumerImpl.java | 4 +++-
.../pulsar/client/impl/ConsumerStatsRecorder.java | 1 +
.../pulsar/client/impl/ConsumerStatsRecorderImpl.java | 1 +
.../pulsar/client/impl/DnsResolverGroupImpl.java | 2 ++
.../impl/MultiTopicConsumerStatsRecorderImpl.java | 1 +
.../pulsar/client/impl/MultiTopicsConsumerImpl.java | 5 +++--
.../PartitionedTopicProducerStatsRecorderImpl.java | 1 +
.../pulsar/client/impl/ProducerStatsRecorder.java | 1 +
.../pulsar/client/impl/ProducerStatsRecorderImpl.java | 1 +
.../apache/pulsar/client/impl/PulsarClientImpl.java | 1 +
.../pulsar/client/impl/auth/AuthenticationBasic.java | 1 +
.../client/impl/auth/AuthenticationDisabled.java | 1 +
.../client/impl/auth/AuthenticationKeyStoreTls.java | 2 ++
.../pulsar/client/impl/auth/AuthenticationTls.java | 1 +
.../pulsar/client/impl/auth/AuthenticationToken.java | 2 ++
.../client/impl/auth/oauth2/AuthenticationOAuth2.java | 1 +
.../apache/pulsar/common/util/netty/EventLoopUtil.java | 5 +++--
.../apache/pulsar/functions/instance/ContextImpl.java | 3 ++-
.../pulsar/functions/instance/InstanceUtils.java | 1 +
.../functions/instance/JavaInstanceRunnable.java | 14 ++++++++------
.../functions/instance/ProducerBuilderFactory.java | 1 +
.../pulsar/functions/source/PulsarFunctionRecord.java | 1 +
.../pulsar/functions/windowing/WindowContextImpl.java | 2 ++
.../functions/windowing/WindowFunctionExecutor.java | 1 +
.../java/org/apache/pulsar/functions/LocalRunner.java | 1 +
.../auth/KubernetesSecretsTokenAuthProvider.java | 8 +++++++-
.../pulsar/functions/runtime/JavaInstanceStarter.java | 1 +
.../apache/pulsar/functions/runtime/RuntimeUtils.java | 6 ++++--
.../apache/pulsar/functions/worker/WorkerConfig.java | 4 +++-
.../pulsar/functions/utils/FunctionConfigUtils.java | 18 ++++++++++++++----
.../apache/pulsar/functions/utils/SinkConfigUtils.java | 12 +++++++++---
.../pulsar/functions/utils/SourceConfigUtils.java | 3 ++-
.../functions/worker/FunctionRuntimeManager.java | 1 +
.../pulsar/functions/worker/PulsarWorkerService.java | 1 +
.../apache/pulsar/functions/worker/WorkerUtils.java | 2 ++
.../apache/pulsar/functions/worker/rest/Resources.java | 1 +
.../worker/rest/api/v2/WorkerApiV2Resource.java | 1 +
.../worker/rest/api/v2/WorkerStatsApiV2Resource.java | 1 +
.../worker/rest/api/v3/SinksApiV3Resource.java | 1 +
.../worker/rest/api/v3/SourcesApiV3Resource.java | 1 +
.../PulsarLedgerUnderreplicationManager.java | 1 +
.../pulsar/metadata/impl/AbstractMetadataStore.java | 2 +-
.../metadata/impl/FaultInjectionMetadataStore.java | 1 +
.../pulsar/metadata/impl/PulsarZooKeeperClient.java | 2 ++
.../pulsar/proxy/extensions/ProxyExtensionsUtils.java | 4 ++--
.../apache/pulsar/proxy/server/ProxyConnection.java | 1 +
.../org/apache/pulsar/proxy/server/ProxyService.java | 1 +
.../pulsar/proxy/server/ProxyServiceStarter.java | 1 +
.../java/org/apache/pulsar/proxy/stats/ProxyStats.java | 1 +
.../pulsar/websocket/AbstractWebSocketHandler.java | 1 +
.../org/apache/pulsar/websocket/WebSocketService.java | 1 +
.../pulsar/websocket/admin/WebSocketWebResource.java | 1 +
.../websocket/admin/v2/WebSocketProxyStatsV2.java | 1 +
64 files changed, 122 insertions(+), 28 deletions(-)
diff --git
a/pulsar-client-auth-athenz/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationAthenz.java
b/pulsar-client-auth-athenz/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationAthenz.java
index bc237292e1f..f4b1bc135a1 100644
---
a/pulsar-client-auth-athenz/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationAthenz.java
+++
b/pulsar-client-auth-athenz/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationAthenz.java
@@ -95,6 +95,7 @@ public class AuthenticationAthenz implements Authentication,
EncodedAuthenticati
return "athenz";
}
+ @SuppressWarnings("deprecation")
@Override
public AuthenticationDataProvider getAuthData() throws
PulsarClientException {
Lock readLock = cachedRoleTokenLock.readLock();
diff --git
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdClusters.java
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdClusters.java
index 7ea66ef36f5..9f3aa68ca8c 100644
---
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdClusters.java
+++
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdClusters.java
@@ -117,6 +117,7 @@ public class CmdClusters extends CmdBase {
private boolean deleteAll;
@Override
+ @SuppressWarnings("deprecation")
void run() throws PulsarAdminException {
if (deleteAll) {
for (String tenant : getAdmin().tenants().getTenants()) {
diff --git
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
index 2a3b660d9b4..750aba23314 100644
---
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
+++
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
@@ -436,6 +436,7 @@ public class CmdFunctions extends CmdBase {
}
}
+ @SuppressWarnings("deprecation")
@Override
void processArguments() throws Exception {
// merge deprecated args with new args
diff --git
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java
index 8913bc38299..1030ef0c99b 100644
---
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java
+++
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java
@@ -2051,6 +2051,7 @@ public class CmdNamespaces extends CmdBase {
private String namespaceName;
@Override
+ @SuppressWarnings("deprecation")
void run() throws PulsarAdminException {
String namespace = validateNamespace(namespaceName);
System.out.println(getAdmin().namespaces().getSchemaAutoUpdateCompatibilityStrategy(namespace)
@@ -2072,6 +2073,7 @@ public class CmdNamespaces extends CmdBase {
private boolean disabled = false;
@Override
+ @SuppressWarnings("deprecation")
void run() throws PulsarAdminException {
String namespace = validateNamespace(namespaceName);
diff --git
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPersistentTopics.java
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPersistentTopics.java
index e92e48fcbd7..ae70f1aaf7b 100644
---
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPersistentTopics.java
+++
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPersistentTopics.java
@@ -607,6 +607,7 @@ public class CmdPersistentTopics extends CmdBase {
required = true)
private long entryId;
+ @SuppressWarnings("deprecation")
@Override
void run() throws PulsarAdminException {
String persistentTopic = validatePersistentTopic(topicName);
diff --git
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java
index a4fb047550d..f646f18c871 100644
---
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java
+++
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java
@@ -444,6 +444,7 @@ public class CmdSinks extends CmdBase {
}
@Override
+ @SuppressWarnings("deprecation")
void processArguments() throws Exception {
super.processArguments();
// merge deprecated args with new args
@@ -828,6 +829,7 @@ public class CmdSinks extends CmdBase {
@Command(description = "Get the list of Pulsar IO connector sinks
supported by Pulsar cluster")
public class ListBuiltInSinks extends BaseCommand {
@Override
+ @SuppressWarnings("deprecation")
void runCmd() throws Exception {
getAdmin().sinks().getBuiltInSinks().stream().filter(x ->
isNotBlank(x.getSinkClass()))
.forEach(connector -> {
diff --git
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java
index c8af7ddd954..2b90e8521f9 100644
---
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java
+++
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java
@@ -737,6 +737,7 @@ public class CmdSources extends CmdBase {
@Command(description = "Get the list of Pulsar IO connector sources
supported by Pulsar cluster")
public class ListBuiltInSources extends BaseCommand {
@Override
+ @SuppressWarnings("deprecation")
void runCmd() throws Exception {
getAdmin().sources().getBuiltInSources().stream().filter(x ->
!StringUtils.isEmpty(x.getSourceClass()))
.forEach(connector -> {
diff --git
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
index d0bdb4ddaea..17cb07afa98 100644
---
a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
+++
b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java
@@ -91,6 +91,7 @@ import picocli.CommandLine.Parameters;
@Getter
@Command(description = "Operations on persistent topics")
+@SuppressWarnings("deprecation")
public class CmdTopics extends CmdBase {
private final CmdTopics.PartitionedLookup partitionedLookup;
private final CmdTopics.DeleteCmd deleteCmd;
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java
index 7c8529ceeb7..6432083c555 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java
@@ -246,6 +246,7 @@ public class ClientBuilderImpl implements ClientBuilder {
return this;
}
+ @SuppressWarnings("deprecation")
@Override
public ClientBuilder enableTls(boolean useTls) {
conf.setUseTls(useTls);
@@ -342,6 +343,7 @@ public class ClientBuilderImpl implements ClientBuilder {
return this;
}
+ @SuppressWarnings("deprecation")
@Override
public ClientBuilder statsInterval(long statsInterval, TimeUnit unit) {
conf.setStatsIntervalSeconds(unit.toSeconds(statsInterval));
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java
index aed525c9eee..20a400803b2 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java
@@ -137,7 +137,8 @@ public abstract class ConsumerBase<T> extends HandlerState
implements Consumer<T
this.subscription = conf.getSubscriptionName();
this.conf = conf;
this.consumerName =
- conf.getConsumerName() == null ?
RandomStringUtils.randomAlphanumeric(5) : conf.getConsumerName();
+ conf.getConsumerName() == null ?
RandomStringUtils.insecure().nextAlphanumeric(5)
+ : conf.getConsumerName();
this.subscribeFuture = subscribeFuture;
this.listener = conf.getMessageListener();
this.decryptFailListener = conf.getDecryptFailListener();
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java
index 008a9b554e9..d008e068cf4 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java
@@ -427,6 +427,7 @@ public class ConsumerBuilderImpl<T> implements
ConsumerBuilder<T> {
return this;
}
+ @SuppressWarnings("deprecation")
@Override
public ConsumerBuilder<T> maxPendingChuckedMessage(int
maxPendingChuckedMessage) {
conf.setMaxPendingChunkedMessage(maxPendingChuckedMessage);
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
index 868c45b277e..af4b7d31dea 100644
---
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
@@ -789,6 +789,7 @@ public class ConsumerImpl<T> extends ConsumerBase<T>
implements ConnectionHandle
return result;
}
+ @SuppressWarnings("deprecation")
private SortedMap<String, String> getPropertiesMap(Message<?> message,
String
originMessageIdStr,
String
originTopicNameStr) {
@@ -2421,7 +2422,8 @@ public class ConsumerImpl<T> extends ConsumerBase<T>
implements ConnectionHandle
.topic(this.deadLetterPolicy.getDeadLetterTopic())
.producerName(
String.format("%s-%s-%s-%s-DLQ", this.topicName, this.subscription,
- this.consumerName,
RandomStringUtils.randomAlphanumeric(5)))
+ this.consumerName,
+
RandomStringUtils.insecure().nextAlphanumeric(5)))
.blockIfQueueFull(false)
.enableBatching(false)
.enableChunking(true);
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorder.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorder.java
index 1d0d9e734b3..8b924881667 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorder.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorder.java
@@ -24,6 +24,7 @@ import org.apache.pulsar.client.api.ConsumerStats;
import org.apache.pulsar.client.api.Message;
import org.apache.pulsar.client.api.ProducerStats;
+@SuppressWarnings("deprecation")
public interface ConsumerStatsRecorder extends ConsumerStats {
void updateNumMsgsReceived(Message<?> message);
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java
index 5cbbcc44298..444ca7a72f5 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java
@@ -39,6 +39,7 @@ import org.apache.pulsar.common.util.ObjectMapperFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+@SuppressWarnings("deprecation")
public class ConsumerStatsRecorderImpl implements ConsumerStatsRecorder {
private static final long serialVersionUID = 1L;
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/DnsResolverGroupImpl.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/DnsResolverGroupImpl.java
index 0702e6324ba..5261bd39896 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/DnsResolverGroupImpl.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/DnsResolverGroupImpl.java
@@ -54,6 +54,7 @@ public class DnsResolverGroupImpl implements AutoCloseable {
this.dnsAddressResolverGroup = createAddressResolverGroup(dnsConfig);
}
+ @SuppressWarnings("deprecation")
private DnsAddressResolverGroup createAddressResolverGroup(
PulsarClientSharedResourcesBuilderImpl.DnsResolverResourceConfig
dnsConfig) {
DnsNameResolverBuilder dnsNameResolverBuilder = new
DnsNameResolverBuilder()
@@ -98,6 +99,7 @@ public class DnsResolverGroupImpl implements AutoCloseable {
return new DnsAddressResolverGroup(dnsNameResolverBuilder);
}
+ @SuppressWarnings("deprecation")
private static DnsNameResolverBuilder createDnsNameResolverBuilder() {
DnsNameResolverBuilder dnsNameResolverBuilder = new
DnsNameResolverBuilder()
.traceEnabled(true)
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicConsumerStatsRecorderImpl.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicConsumerStatsRecorderImpl.java
index eb4a339e20b..1191b5bbcbf 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicConsumerStatsRecorderImpl.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicConsumerStatsRecorderImpl.java
@@ -28,6 +28,7 @@ import
org.apache.pulsar.client.impl.conf.ConsumerConfigurationData;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+@SuppressWarnings("deprecation")
public class MultiTopicConsumerStatsRecorderImpl extends
ConsumerStatsRecorderImpl implements MultiTopicConsumerStats {
private static final long serialVersionUID = 1L;
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
index 7865939d77d..62694179ae9 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
@@ -115,7 +115,7 @@ public class MultiTopicsConsumerImpl<T> extends
ConsumerBase<T> {
MultiTopicsConsumerImpl(PulsarClientImpl client,
ConsumerConfigurationData<T> conf,
ExecutorProvider executorProvider, CompletableFuture<Consumer<T>>
subscribeFuture, Schema<T> schema,
ConsumerInterceptors<T> interceptors, boolean
createTopicIfDoesNotExist) {
- this(client, DUMMY_TOPIC_NAME_PREFIX +
RandomStringUtils.randomAlphanumeric(5), conf, executorProvider,
+ this(client, DUMMY_TOPIC_NAME_PREFIX +
RandomStringUtils.insecure().nextAlphanumeric(5), conf, executorProvider,
subscribeFuture, schema, interceptors,
createTopicIfDoesNotExist);
}
@@ -123,7 +123,7 @@ public class MultiTopicsConsumerImpl<T> extends
ConsumerBase<T> {
ExecutorProvider executorProvider, CompletableFuture<Consumer<T>>
subscribeFuture, Schema<T> schema,
ConsumerInterceptors<T> interceptors, boolean
createTopicIfDoesNotExist, MessageId startMessageId,
long startMessageRollbackDurationInSec) {
- this(client, DUMMY_TOPIC_NAME_PREFIX +
RandomStringUtils.randomAlphanumeric(5), conf, executorProvider,
+ this(client, DUMMY_TOPIC_NAME_PREFIX +
RandomStringUtils.insecure().nextAlphanumeric(5), conf, executorProvider,
subscribeFuture, schema, interceptors,
createTopicIfDoesNotExist, startMessageId,
startMessageRollbackDurationInSec);
}
@@ -915,6 +915,7 @@ public class MultiTopicsConsumerImpl<T> extends
ConsumerBase<T> {
}
@Override
+ @SuppressWarnings("deprecation")
public synchronized ConsumerStats getStats() {
if (stats == null) {
return null;
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedTopicProducerStatsRecorderImpl.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedTopicProducerStatsRecorderImpl.java
index 65aeac40ce7..0ba5f0e46e2 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedTopicProducerStatsRecorderImpl.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedTopicProducerStatsRecorderImpl.java
@@ -27,6 +27,7 @@ import org.apache.pulsar.client.api.ProducerStats;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+@SuppressWarnings("deprecation")
public class PartitionedTopicProducerStatsRecorderImpl extends
ProducerStatsRecorderImpl
implements PartitionedTopicProducerStats {
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorder.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorder.java
index be75e38edfd..ee25a42be58 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorder.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorder.java
@@ -20,6 +20,7 @@ package org.apache.pulsar.client.impl;
import org.apache.pulsar.client.api.ProducerStats;
+@SuppressWarnings("deprecation")
public interface ProducerStatsRecorder extends ProducerStats {
void updateNumMsgsSent(long numMsgs, long totalMsgsSize);
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java
index 5e8c746ed89..d4f4991bf90 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java
@@ -33,6 +33,7 @@ import org.apache.pulsar.common.util.ObjectMapperFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+@SuppressWarnings("deprecation")
public class ProducerStatsRecorderImpl implements ProducerStatsRecorder {
private static final long serialVersionUID = 1L;
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
index 2082f8b1750..31cc1b5f5cd 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
@@ -330,6 +330,7 @@ public class PulsarClientImpl implements PulsarClient {
return new ProducerBuilderImpl<>(this, Schema.BYTES);
}
+ @SuppressWarnings("deprecation")
@Override
public <T> ProducerBuilder<T> newProducer(Schema<T> schema) {
ProducerBuilderImpl<T> producerBuilder = new
ProducerBuilderImpl<>(this, schema);
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationBasic.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationBasic.java
index 3bed5ac5dab..e73bdf46b54 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationBasic.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationBasic.java
@@ -51,6 +51,7 @@ public class AuthenticationBasic implements Authentication,
EncodedAuthenticatio
}
}
+ @SuppressWarnings("deprecation")
@Override
public void configure(Map<String, String> authParams) {
configure(new Gson().toJson(authParams));
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationDisabled.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationDisabled.java
index d1c59ea17a9..5f07bce9fe2 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationDisabled.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationDisabled.java
@@ -42,6 +42,7 @@ public class AuthenticationDisabled implements
Authentication, EncodedAuthentica
return "none";
}
+ @SuppressWarnings("deprecation")
@Override
public AuthenticationDataProvider getAuthData() throws
PulsarClientException {
return nullData;
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationKeyStoreTls.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationKeyStoreTls.java
index dd7fddd8610..98c31359a84 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationKeyStoreTls.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationKeyStoreTls.java
@@ -69,6 +69,7 @@ public class AuthenticationKeyStoreTls implements
Authentication, EncodedAuthent
return AUTH_NAME;
}
+ @SuppressWarnings("deprecation")
@Override
public AuthenticationDataProvider getAuthData() throws
PulsarClientException {
try {
@@ -99,6 +100,7 @@ public class AuthenticationKeyStoreTls implements
Authentication, EncodedAuthent
configure(params);
}
+ @SuppressWarnings("deprecation")
@Override
public void configure(Map<String, String> params) {
String keyStoreType = params.get(KEYSTORE_TYPE);
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationTls.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationTls.java
index acd15d6e1bb..b84208245a2 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationTls.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationTls.java
@@ -76,6 +76,7 @@ public class AuthenticationTls implements Authentication,
EncodedAuthenticationP
return AUTH_METHOD_NAME;
}
+ @SuppressWarnings("deprecation")
@Override
public AuthenticationDataProvider getAuthData() throws
PulsarClientException {
try {
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationToken.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationToken.java
index fcfe89a7c12..c5a5828133f 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationToken.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationToken.java
@@ -64,6 +64,7 @@ public class AuthenticationToken implements Authentication,
EncodedAuthenticatio
return AUTH_METHOD_NAME;
}
+ @SuppressWarnings("deprecation")
@Override
public AuthenticationDataProvider getAuthData() throws
PulsarClientException {
return new AuthenticationDataToken(tokenSupplier);
@@ -90,6 +91,7 @@ public class AuthenticationToken implements Authentication,
EncodedAuthenticatio
}
}
+ @SuppressWarnings("deprecation")
@Override
public void configure(Map<String, String> authParams) {
// noop
diff --git
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/AuthenticationOAuth2.java
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/AuthenticationOAuth2.java
index d40785560ba..4874f7f003e 100644
---
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/AuthenticationOAuth2.java
+++
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/AuthenticationOAuth2.java
@@ -235,6 +235,7 @@ public class AuthenticationOAuth2 implements
Authentication, EncodedAuthenticati
* @return The authentication data identifying this client that will be
sent to the broker
* @throws PulsarClientException
*/
+ @SuppressWarnings("deprecation")
@Override
public synchronized AuthenticationDataProvider getAuthData() throws
PulsarClientException {
if (isClosed) {
diff --git
a/pulsar-common/src/main/java/org/apache/pulsar/common/util/netty/EventLoopUtil.java
b/pulsar-common/src/main/java/org/apache/pulsar/common/util/netty/EventLoopUtil.java
index 9e5c7157923..7d90492e14c 100644
---
a/pulsar-common/src/main/java/org/apache/pulsar/common/util/netty/EventLoopUtil.java
+++
b/pulsar-common/src/main/java/org/apache/pulsar/common/util/netty/EventLoopUtil.java
@@ -44,7 +44,7 @@ import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ThreadFactory;
import lombok.extern.slf4j.Slf4j;
import org.apache.bookkeeper.common.util.affinity.CpuAffinity;
-import org.apache.commons.lang3.StringUtils;
+
@SuppressWarnings("checkstyle:JavadocType")
@Slf4j
@@ -93,7 +93,8 @@ public class EventLoopUtil {
private static boolean isIoUringEnabledAndAvailable() {
// By default, io_uring will not be enabled, even if available. The
environment variable will be used:
// enable.io_uring=1
- boolean ioUringEnabled =
StringUtils.equalsAnyIgnoreCase(System.getProperty(ENABLE_IO_URING), "1",
"true");
+ String ioUringSetting = System.getProperty(ENABLE_IO_URING);
+ boolean ioUringEnabled = "1".equalsIgnoreCase(ioUringSetting) ||
"true".equalsIgnoreCase(ioUringSetting);
if (ioUringEnabled) {
// Throw exception if IOUring cannot be used
IOUring.ensureAvailability();
diff --git
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java
index 3b450836f56..e24e7ded3b9 100644
---
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java
+++
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java
@@ -459,12 +459,13 @@ class ContextImpl implements Context, SinkContext,
SourceContext, AutoCloseable
return defaultStateStore.get(key);
}
+ @SuppressWarnings("deprecation")
@Override
public <T> CompletableFuture<Void> publish(String topicName, T object) {
return publish(topicName, object, "");
}
- @SuppressWarnings("unchecked")
+ @SuppressWarnings({"unchecked", "deprecation"})
@Override
public <T> CompletableFuture<Void> publish(String topicName, T object,
String schemaOrSerdeClassName) {
return publish(topicName, object,
diff --git
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceUtils.java
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceUtils.java
index bec738af6c9..8866392a2ff 100644
---
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceUtils.java
+++
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceUtils.java
@@ -152,6 +152,7 @@ public class InstanceUtils {
return properties;
}
+ @SuppressWarnings("deprecation")
public static ClientBuilder createPulsarClientBuilder(String
pulsarServiceUrl,
AuthenticationConfig
authConfig,
Optional<Long>
memoryLimit) throws PulsarClientException {
diff --git
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java
index 7c9685e90d0..403b28da056 100644
---
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java
+++
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java
@@ -324,11 +324,12 @@ public class JavaInstanceRunnable implements
AutoCloseable, Runnable {
// increment number of records received from source
stats.incrTotalReceived();
- if
(instanceConfig.getFunctionDetails().getProcessingGuarantees() ==
org.apache.pulsar.functions
- .proto.Function.ProcessingGuarantees.ATMOST_ONCE) {
- if (instanceConfig.getFunctionDetails().getAutoAck()) {
- currentRecord.ack();
- }
+ @SuppressWarnings("deprecation")
+ boolean atMostOnceAutoAck =
instanceConfig.getFunctionDetails().getProcessingGuarantees()
+ ==
org.apache.pulsar.functions.proto.Function.ProcessingGuarantees.ATMOST_ONCE
+ && instanceConfig.getFunctionDetails().getAutoAck();
+ if (atMostOnceAutoAck) {
+ currentRecord.ack();
}
JavaExecutionResult result;
@@ -420,6 +421,7 @@ public class JavaInstanceRunnable implements AutoCloseable,
Runnable {
}
@VisibleForTesting
+ @SuppressWarnings("deprecation")
void handleResult(Record<?> srcRecord, JavaExecutionResult result) throws
Exception {
if (result.getUserException() != null) {
Throwable t = result.getUserException();
@@ -775,7 +777,7 @@ public class JavaInstanceRunnable implements AutoCloseable,
Runnable {
context.updateLoggers();
}
- @SuppressWarnings({"unchecked", "rawtypes"})
+ @SuppressWarnings({"unchecked", "rawtypes", "deprecation"})
private void setupInput(ContextImpl contextImpl) throws Exception {
SourceSpec sourceSpec =
this.instanceConfig.getFunctionDetails().getSource();
diff --git
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ProducerBuilderFactory.java
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ProducerBuilderFactory.java
index 4c0396fe8a9..6cff8c6f8d5 100644
---
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ProducerBuilderFactory.java
+++
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ProducerBuilderFactory.java
@@ -68,6 +68,7 @@ public class ProducerBuilderFactory {
}
}
+ @SuppressWarnings("deprecation")
public <T> ProducerBuilder<T> createProducerBuilder(String topic,
Schema<T> schema, String producerName) {
ProducerBuilder<T> builder = client.newProducer(schema);
if (defaultConfigurer != null) {
diff --git
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarFunctionRecord.java
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarFunctionRecord.java
index 63228f353eb..a0b20f927e0 100644
---
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarFunctionRecord.java
+++
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarFunctionRecord.java
@@ -85,6 +85,7 @@ public class PulsarFunctionRecord<T> implements Record<T> {
return record.getProperties();
}
+ @SuppressWarnings("deprecation")
@Override
public void ack() {
Function.ProcessingGuarantees processingGuarantees =
functionConfig.getProcessingGuarantees();
diff --git
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowContextImpl.java
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowContextImpl.java
index cb5710f0177..6ac40221602 100644
---
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowContextImpl.java
+++
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowContextImpl.java
@@ -170,11 +170,13 @@ public class WindowContextImpl implements WindowContext {
this.context.fatal(t);
}
+ @SuppressWarnings("deprecation")
@Override
public <T> CompletableFuture<Void> publish(String topicName, T object) {
return this.context.publish(topicName, object);
}
+ @SuppressWarnings("deprecation")
@Override
public CompletableFuture<Void> publish(String topicName, Object object,
String schemaOrSerdeClassName) {
return this.context.publish(topicName, object, schemaOrSerdeClassName);
diff --git
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFunctionExecutor.java
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFunctionExecutor.java
index bd3d2dca610..42adf919f06 100644
---
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFunctionExecutor.java
+++
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFunctionExecutor.java
@@ -221,6 +221,7 @@ public class WindowFunctionExecutor<T, X> implements
Function<T, X> {
};
}
+ @SuppressWarnings("deprecation")
private void processWindow(Context context, List<Record<T>> tuples,
List<Record<T>> newTuples, List<Record<T>>
expiredTuples, Long referenceTime) {
diff --git
a/pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java
b/pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java
index 9401d33f710..711488a9d59 100644
---
a/pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java
+++
b/pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java
@@ -302,6 +302,7 @@ public class LocalRunner implements AutoCloseable {
}
}
+ @SuppressWarnings("deprecation")
public synchronized void stop() {
if (running.compareAndSet(true, false)) {
this.notify();
diff --git
a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesSecretsTokenAuthProvider.java
b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesSecretsTokenAuthProvider.java
index 4e300aad3b5..d3e7365a1eb 100644
---
a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesSecretsTokenAuthProvider.java
+++
b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesSecretsTokenAuthProvider.java
@@ -254,7 +254,11 @@ public class KubernetesSecretsTokenAuthProvider implements
KubernetesFunctionAut
String secretId;
secretId = existingFunctionAuthData.map(functionAuthData -> new
String(functionAuthData.getData()))
- .orElseGet(() -> RandomStringUtils.random(5, true,
true).toLowerCase());
+ .orElseGet(() -> {
+ @SuppressWarnings("deprecation")
+ String id = RandomStringUtils.random(5, true,
true).toLowerCase();
+ return id;
+ });
String token;
try {
@@ -298,6 +302,7 @@ public class KubernetesSecretsTokenAuthProvider implements
KubernetesFunctionAut
.numRetries(NUM_RETRIES)
.sleepBetweenInvocationsMs(SLEEP_BETWEEN_RETRIES_MS)
.supplier(() -> {
+ @SuppressWarnings("deprecation")
String id = RandomStringUtils.random(5, true,
true).toLowerCase();
V1Secret v1Secret = new V1Secret()
.metadata(new V1ObjectMeta().name(secretName))
@@ -358,6 +363,7 @@ public class KubernetesSecretsTokenAuthProvider implements
KubernetesFunctionAut
.numRetries(NUM_RETRIES)
.sleepBetweenInvocationsMs(SLEEP_BETWEEN_RETRIES_MS)
.supplier(() -> {
+ @SuppressWarnings("deprecation")
String id = RandomStringUtils.random(5, true,
true).toLowerCase();
V1Secret v1Secret = new V1Secret()
.metadata(new
V1ObjectMeta().name(getSecretName(id)))
diff --git
a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/JavaInstanceStarter.java
b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/JavaInstanceStarter.java
index 06cfca6c41a..b0992320d84 100644
---
a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/JavaInstanceStarter.java
+++
b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/JavaInstanceStarter.java
@@ -297,6 +297,7 @@ public class JavaInstanceStarter implements AutoCloseable {
return Boolean.TRUE.toString().equals(param);
}
+ @SuppressWarnings("deprecation")
@Override
public void close() {
try {
diff --git
a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeUtils.java
b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeUtils.java
index ae58fc40e2b..afdbf332168 100644
---
a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeUtils.java
+++
b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeUtils.java
@@ -169,8 +169,10 @@ public class RuntimeUtils {
goInstanceConfig.setFuncVersion(instanceConfig.getFunctionVersion());
}
- if (instanceConfig.getFunctionDetails().getAutoAck()) {
-
goInstanceConfig.setAutoAck(instanceConfig.getFunctionDetails().getAutoAck());
+ @SuppressWarnings("deprecation")
+ boolean autoAck = instanceConfig.getFunctionDetails().getAutoAck();
+ if (autoAck) {
+ goInstanceConfig.setAutoAck(autoAck);
}
if (instanceConfig.getFunctionDetails().getTenant() != null) {
diff --git
a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java
b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java
index ec217cee271..060d9831082 100644
---
a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java
+++
b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java
@@ -33,6 +33,7 @@ import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Map;
+import java.util.Objects;
import java.util.Properties;
import java.util.Set;
import java.util.TreeSet;
@@ -754,13 +755,14 @@ public class WorkerConfig implements Serializable,
PulsarConfiguration {
@Getter(AccessLevel.NONE)
private String functionAuthProviderClassName;
+ @SuppressWarnings("deprecation")
public String getFunctionAuthProviderClassName() {
// if we haven't set a value and are running kubernetes, we default to
the SecretsTokenAuthProvider
// as that matches behavior before this property could be overridden
if (!StringUtils.isEmpty(functionAuthProviderClassName)) {
return functionAuthProviderClassName;
} else {
- if (StringUtils.equals(this.getFunctionRuntimeFactoryClassName(),
KubernetesRuntimeFactory.class.getName())
+ if (Objects.equals(this.getFunctionRuntimeFactoryClassName(),
KubernetesRuntimeFactory.class.getName())
|| getKubernetesContainerFactory() != null) {
return KubernetesSecretsTokenAuthProvider.class.getName();
}
diff --git
a/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java
b/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java
index cc90ad8c037..a847e507503 100644
---
a/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java
+++
b/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java
@@ -90,6 +90,7 @@ public class FunctionConfigUtils {
}
}
+ @SuppressWarnings("deprecation")
public static FunctionDetails convert(FunctionConfig functionConfig,
ExtractedFunctionDetails extractedDetails)
throws IllegalArgumentException {
@@ -335,8 +336,9 @@ public class FunctionConfigUtils {
functionDetailsBuilder.setSecretsMap(new
Gson().toJson(functionConfig.getSecrets()));
}
- if (functionConfig.getAutoAck() != null) {
- functionDetailsBuilder.setAutoAck(functionConfig.getAutoAck());
+ Boolean autoAck = functionConfig.getAutoAck();
+ if (autoAck != null) {
+ functionDetailsBuilder.setAutoAck(autoAck);
} else {
functionDetailsBuilder.setAutoAck(true);
}
@@ -373,6 +375,7 @@ public class FunctionConfigUtils {
return validateFunctionDetails(functionDetailsBuilder.build());
}
+ @SuppressWarnings("deprecation")
public static FunctionDetails validateFunctionDetails(FunctionDetails
functionDetails)
throws IllegalArgumentException {
if (!functionDetails.getAutoAck() &&
functionDetails.getProcessingGuarantees()
@@ -388,6 +391,7 @@ public class FunctionConfigUtils {
return functionDetails;
}
+ @SuppressWarnings("deprecation")
public static FunctionConfig convertFromDetails(FunctionDetails
functionDetails) {
functionDetails = validateFunctionDetails(functionDetails);
FunctionConfig functionConfig = new FunctionConfig();
@@ -565,6 +569,7 @@ public class FunctionConfigUtils {
return producerConfig;
}
+ @SuppressWarnings("deprecation")
public static void inferMissingArguments(FunctionConfig functionConfig,
boolean
forwardSourceMessagePropertyEnabled) {
if (StringUtils.isEmpty(functionConfig.getName())) {
@@ -834,7 +839,9 @@ public class FunctionConfigUtils {
if (windowConfig != null) {
// set auto ack to false since windowing framework is responsible
// for acking and not the function framework
- if (functionConfig.getAutoAck() != null &&
functionConfig.getAutoAck()) {
+ @SuppressWarnings("deprecation")
+ Boolean windowAutoAck = functionConfig.getAutoAck();
+ if (windowAutoAck != null && windowAutoAck) {
throw new IllegalArgumentException("Cannot enable auto ack
when using windowing functionality");
}
WindowConfigUtils.validate(windowConfig);
@@ -1074,7 +1081,10 @@ public class FunctionConfigUtils {
if (newConfig.getRuntime() != null &&
!newConfig.getRuntime().equals(existingConfig.getRuntime())) {
throw new IllegalArgumentException("Runtime cannot be altered");
}
- if (newConfig.getAutoAck() != null &&
!newConfig.getAutoAck().equals(existingConfig.getAutoAck())) {
+ @SuppressWarnings("deprecation")
+ boolean autoAckChanged = newConfig.getAutoAck() != null
+ && !newConfig.getAutoAck().equals(existingConfig.getAutoAck());
+ if (autoAckChanged) {
throw new IllegalArgumentException("AutoAck cannot be altered");
}
if (newConfig.getMaxMessageRetries() != null) {
diff --git
a/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java
b/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java
index 41cf1b9b9f7..41d18e78b55 100644
---
a/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java
+++
b/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java
@@ -71,6 +71,7 @@ public class SinkConfigUtils {
private String functionClassName;
}
+ @SuppressWarnings("deprecation")
public static FunctionDetails convert(SinkConfig sinkConfig,
ExtractedSinkDetails sinkDetails) throws IOException {
FunctionDetails.Builder functionDetailsBuilder =
FunctionDetails.newBuilder();
@@ -191,8 +192,9 @@ public class SinkConfigUtils {
}
sourceSpecBuilder.setSubscriptionType(subType);
- if (sinkConfig.getAutoAck() != null) {
- functionDetailsBuilder.setAutoAck(sinkConfig.getAutoAck());
+ Boolean autoAck = sinkConfig.getAutoAck();
+ if (autoAck != null) {
+ functionDetailsBuilder.setAutoAck(autoAck);
} else {
functionDetailsBuilder.setAutoAck(true);
}
@@ -282,6 +284,7 @@ public class SinkConfigUtils {
return
FunctionConfigUtils.validateFunctionDetails(functionDetailsBuilder.build());
}
+ @SuppressWarnings("deprecation")
public static SinkConfig convertFromDetails(FunctionDetails
functionDetails) {
SinkConfig sinkConfig = new SinkConfig();
sinkConfig.setTenant(functionDetails.getTenant());
@@ -705,7 +708,10 @@ public class SinkConfigUtils {
.equals(existingConfig.getRetainKeyOrdering())) {
throw new IllegalArgumentException("Retain Key Ordering cannot be
altered");
}
- if (newConfig.getAutoAck() != null &&
!newConfig.getAutoAck().equals(existingConfig.getAutoAck())) {
+ @SuppressWarnings("deprecation")
+ boolean autoAckChanged = newConfig.getAutoAck() != null
+ && !newConfig.getAutoAck().equals(existingConfig.getAutoAck());
+ if (autoAckChanged) {
throw new IllegalArgumentException("AutoAck cannot be altered");
}
if (newConfig.getResources() != null) {
diff --git
a/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfigUtils.java
b/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfigUtils.java
index 6229bffff53..c9b70698794 100644
---
a/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfigUtils.java
+++
b/pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfigUtils.java
@@ -90,7 +90,8 @@ public class SourceConfigUtils {
functionDetailsBuilder.setParallelism(1);
}
functionDetailsBuilder.setClassName(IdentityFunction.class.getName());
- functionDetailsBuilder.setAutoAck(true);
+ @SuppressWarnings("deprecation")
+ Function.FunctionDetails.Builder autoAckBuilder =
functionDetailsBuilder.setAutoAck(true);
if (sourceConfig.getProcessingGuarantees() != null) {
functionDetailsBuilder.setProcessingGuarantees(
convertProcessingGuarantee(sourceConfig.getProcessingGuarantees()));
diff --git
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java
index b6e2bbb1ca0..c6db1309af5 100644
---
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java
+++
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java
@@ -142,6 +142,7 @@ public class FunctionRuntimeManager implements
AutoCloseable {
private final ErrorNotifier errorNotifier;
+ @SuppressWarnings("deprecation")
public FunctionRuntimeManager(WorkerConfig workerConfig,
PulsarWorkerService workerService, Namespace dlogNamespace,
MembershipManager membershipManager,
ConnectorsManager connectorsManager,
FunctionsManager functionsManager,
diff --git
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java
index 233c4fdb695..0e65d6e4a29 100644
---
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java
+++
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java
@@ -124,6 +124,7 @@ public class PulsarWorkerService implements WorkerService {
private final PulsarClientCreator clientCreator;
private StateStoreProvider stateStoreProvider;
+ @SuppressWarnings("deprecation")
public PulsarWorkerService() {
this.clientCreator = new PulsarClientCreator() {
@Override
diff --git
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerUtils.java
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerUtils.java
index e89f1081bc3..fd424b63491 100644
---
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerUtils.java
+++
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerUtils.java
@@ -176,6 +176,7 @@ public final class WorkerUtils {
return
URI.create(String.format("distributedlog://%s/pulsar/functions",
zookeeperServers));
}
+ @SuppressWarnings("deprecation")
public static URI initializeDlogNamespace(InternalConfigurationData
internalConf) throws IOException {
final String ledgersRootPath;
final String ledgersStoreServers;
@@ -274,6 +275,7 @@ public final class WorkerUtils {
allowTlsInsecureConnection,
enableTlsHostnameVerificationEnable, null);
}
+ @SuppressWarnings("deprecation")
public static PulsarClient getPulsarClient(String pulsarServiceUrl, String
authPlugin, String authParams,
Boolean useTls, String
tlsTrustCertsFilePath,
Boolean
allowTlsInsecureConnection,
diff --git
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/Resources.java
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/Resources.java
index d98ae68d966..3eabc881796 100644
---
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/Resources.java
+++
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/Resources.java
@@ -47,6 +47,7 @@ public final class Resources {
));
}
+ @SuppressWarnings("deprecation")
public static Set<Class<?>> getApiV3Resources() {
return new HashSet<>(
Arrays.asList(
diff --git
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/WorkerApiV2Resource.java
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/WorkerApiV2Resource.java
index 276d0ae86d8..c3991f509df 100644
---
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/WorkerApiV2Resource.java
+++
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/WorkerApiV2Resource.java
@@ -53,6 +53,7 @@ import org.apache.pulsar.functions.worker.service.api.Workers;
@Path("/worker")
@Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON)
+@SuppressWarnings("deprecation")
@Api(value = "/worker", description = "Workers admin api", tags = "workers")
public class WorkerApiV2Resource implements Supplier<WorkerService> {
diff --git
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/WorkerStatsApiV2Resource.java
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/WorkerStatsApiV2Resource.java
index 712505a4ba0..4b22d32cf51 100644
---
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/WorkerStatsApiV2Resource.java
+++
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/WorkerStatsApiV2Resource.java
@@ -46,6 +46,7 @@ import org.apache.pulsar.functions.worker.service.api.Workers;
@Path("/worker-stats")
@Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON)
+@SuppressWarnings("deprecation")
@Api(value = "/worker-stats", description = "Workers stats api", tags =
"workers-stats")
public class WorkerStatsApiV2Resource implements Supplier<WorkerService> {
diff --git
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/SinksApiV3Resource.java
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/SinksApiV3Resource.java
index 8081f76cfd8..4515bd525b1 100644
---
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/SinksApiV3Resource.java
+++
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/SinksApiV3Resource.java
@@ -48,6 +48,7 @@ import
org.glassfish.jersey.media.multipart.FormDataContentDisposition;
import org.glassfish.jersey.media.multipart.FormDataParam;
@Slf4j
+@SuppressWarnings("deprecation")
@Api(value = "/sinks", description = "Sinks admin apis", tags = "sinks")
@Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON)
diff --git
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/SourcesApiV3Resource.java
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/SourcesApiV3Resource.java
index 23df4230450..81122d2440f 100644
---
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/SourcesApiV3Resource.java
+++
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/SourcesApiV3Resource.java
@@ -48,6 +48,7 @@ import
org.glassfish.jersey.media.multipart.FormDataContentDisposition;
import org.glassfish.jersey.media.multipart.FormDataParam;
@Slf4j
+@SuppressWarnings("deprecation")
@Api(value = "/sources", description = "Sources admin apis", tags = "sources")
@Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON)
diff --git
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerUnderreplicationManager.java
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerUnderreplicationManager.java
index 3e5d59eebe5..2d40cb991f5 100644
---
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerUnderreplicationManager.java
+++
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerUnderreplicationManager.java
@@ -1062,6 +1062,7 @@ public class PulsarLedgerUnderreplicationManager
implements LedgerUnderreplicati
}
}
+ @SuppressWarnings("deprecation")
@Override
public void
notifyUnderReplicationLedgerChanged(BookkeeperInternalCallbacks.GenericCallback<Void>
cb)
throws ReplicationException.UnavailableException {
diff --git
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
index e71c6ff2753..f0a5eeddca4 100644
---
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
+++
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
@@ -723,7 +723,7 @@ public abstract class AbstractMetadataStore implements
MetadataStoreExtended, Co
* 3. not ends with '/', except root path "/"
*/
static boolean isValidPath(String path) {
- return StringUtils.equals(path, "/")
+ return "/".equals(path)
|| StringUtils.isNotBlank(path)
&& path.startsWith("/")
&& !path.endsWith("/");
diff --git
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/FaultInjectionMetadataStore.java
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/FaultInjectionMetadataStore.java
index de0191c7594..8a4e725d7f8 100644
---
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/FaultInjectionMetadataStore.java
+++
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/FaultInjectionMetadataStore.java
@@ -170,6 +170,7 @@ public class FaultInjectionMetadataStore implements
MetadataStoreExtended {
return
injectMetadataStoreInMetadataCache(store.getMetadataCache(typeRef,
cacheConfig));
}
+ @SuppressWarnings("deprecation")
@Override
public <T> MetadataCache<T> getMetadataCache(String cacheName,
MetadataSerde<T> serde,
MetadataCacheConfig
cacheConfig) {
diff --git
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/PulsarZooKeeperClient.java
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/PulsarZooKeeperClient.java
index 6212964674a..fcab8936e23 100644
---
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/PulsarZooKeeperClient.java
+++
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/PulsarZooKeeperClient.java
@@ -291,6 +291,7 @@ public class PulsarZooKeeperClient extends ZooKeeper
implements Watcher, AutoClo
return new Builder();
}
+ @SuppressWarnings("deprecation")
protected PulsarZooKeeperClient(String connectString,
int sessionTimeoutMs,
ZooKeeperWatcherBase watcherManager,
@@ -356,6 +357,7 @@ public class PulsarZooKeeperClient extends ZooKeeper
implements Watcher, AutoClo
watcherManager.waitForConnection();
}
+ @SuppressWarnings("deprecation")
protected ZooKeeper createZooKeeper() throws IOException,
QuorumPeerConfig.ConfigException {
if (null != configPath) {
return new ZooKeeper(connectString, sessionTimeoutMs,
watcherManager, allowReadOnlyMode,
diff --git
a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/extensions/ProxyExtensionsUtils.java
b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/extensions/ProxyExtensionsUtils.java
index d2b9f91b37b..7a5f5b073e1 100644
---
a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/extensions/ProxyExtensionsUtils.java
+++
b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/extensions/ProxyExtensionsUtils.java
@@ -133,8 +133,8 @@ class ProxyExtensionsUtils {
}
try {
- Class extensionClass = ncl.loadClass(phDef.getExtensionClass());
- Object extension = extensionClass.newInstance();
+ Class<?> extensionClass = ncl.loadClass(phDef.getExtensionClass());
+ Object extension =
extensionClass.getDeclaredConstructor().newInstance();
if (!(extension instanceof ProxyExtension)) {
throw new IOException("Class " + phDef.getExtensionClass()
+ " does not implement extension interface");
diff --git
a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java
b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java
index cfe788e5229..c4bd5c5f9b1 100644
---
a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java
+++
b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java
@@ -334,6 +334,7 @@ public class ProxyConnection extends PulsarHandler {
* @param inboundChannel input channel
* @param outboundChannel output channel
*/
+ @SuppressWarnings("deprecation")
protected static ChannelPromise spliceNIC2NIC(EpollSocketChannel
inboundChannel,
EpollSocketChannel
outboundChannel, int spliceLength) {
ChannelPromise promise = inboundChannel.newPromise();
diff --git
a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java
b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java
index 670ac08dee9..077b30300fc 100644
---
a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java
+++
b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java
@@ -164,6 +164,7 @@ public class ProxyService implements Closeable {
private boolean gracefulShutdown = true;
+ @SuppressWarnings("deprecation")
public ProxyService(ProxyConfiguration proxyConfig,
AuthenticationService authenticationService,
Authentication proxyClientAuthentication) throws
Exception {
diff --git
a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyServiceStarter.java
b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyServiceStarter.java
index 144e953ac4d..b37b42c73df 100644
---
a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyServiceStarter.java
+++
b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyServiceStarter.java
@@ -127,6 +127,7 @@ public class ProxyServiceStarter {
this(args, null, false);
}
+ @SuppressWarnings("deprecation")
public ProxyServiceStarter(String[] args, Consumer<ProxyConfiguration>
proxyConfigurationCustomizer,
boolean embeddedMode) throws Exception {
this.embeddedMode = embeddedMode;
diff --git
a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/stats/ProxyStats.java
b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/stats/ProxyStats.java
index 67fe30db161..d82c6dd5d9e 100644
--- a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/stats/ProxyStats.java
+++ b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/stats/ProxyStats.java
@@ -50,6 +50,7 @@ import org.slf4j.LoggerFactory;
@Path("/")
@Api(value = "/proxy-stats", description = "Stats for proxy", tags =
"proxy-stats", hidden = true)
@Produces(MediaType.APPLICATION_JSON)
+@SuppressWarnings("deprecation")
public class ProxyStats {
private static final Logger log =
LoggerFactory.getLogger(ProxyStats.class);
diff --git
a/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/AbstractWebSocketHandler.java
b/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/AbstractWebSocketHandler.java
index 7fc3c169dbd..115445981ac 100644
---
a/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/AbstractWebSocketHandler.java
+++
b/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/AbstractWebSocketHandler.java
@@ -90,6 +90,7 @@ public abstract class AbstractWebSocketHandler extends
WebSocketAdapter implemen
extractTopicName(request);
}
+ @SuppressWarnings("deprecation")
protected boolean checkAuth(JettyServerUpgradeResponse response) {
String authRole = "<none>";
String authMethodName = request.getHeader(PULSAR_AUTH_METHOD_NAME);
diff --git
a/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketService.java
b/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketService.java
index 654fb41c3bb..66e49b0df12 100644
---
a/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketService.java
+++
b/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketService.java
@@ -183,6 +183,7 @@ public class WebSocketService implements Closeable {
this.localCluster = clusterData;
}
+ @SuppressWarnings("deprecation")
private PulsarClient createClientInstance(ClusterData clusterData) throws
IOException {
ClientBuilder clientBuilder = PulsarClient.builder() //
.memoryLimit(SizeUnit.MEGA_BYTES.toBytes(config.getWebSocketPulsarClientMemoryLimitInMB()),
diff --git
a/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/admin/WebSocketWebResource.java
b/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/admin/WebSocketWebResource.java
index 41fef328c2f..38651234ecf 100644
---
a/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/admin/WebSocketWebResource.java
+++
b/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/admin/WebSocketWebResource.java
@@ -65,6 +65,7 @@ public class WebSocketWebResource {
*
* @return the web service caller identification
*/
+ @SuppressWarnings("deprecation")
public String clientAppId() {
if (isBlank(clientId)) {
try {
diff --git
a/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/admin/v2/WebSocketProxyStatsV2.java
b/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/admin/v2/WebSocketProxyStatsV2.java
index 779b0ec4b15..9cf1b6dd1fc 100644
---
a/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/admin/v2/WebSocketProxyStatsV2.java
+++
b/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/admin/v2/WebSocketProxyStatsV2.java
@@ -39,6 +39,7 @@ import org.apache.pulsar.websocket.stats.ProxyTopicStat;
@Path("/proxy-stats")
@Api(value = "/proxy", description = "Stats for web-socket proxy", tags =
"proxy-stats")
@Produces(MediaType.APPLICATION_JSON)
+@SuppressWarnings("deprecation")
public class WebSocketProxyStatsV2 extends WebSocketProxyStatsBase {
@GET
@Path("/metrics")
