This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 9c7aef745d Upgrade Pulsar to 4.0.3 (#15157)
9c7aef745d is described below
commit 9c7aef745d31fda502f9e104689df0ec514313d8
Author: Xiaotian (Jackie) Jiang <[email protected]>
AuthorDate: Fri Feb 28 16:58:04 2025 -0700
Upgrade Pulsar to 4.0.3 (#15157)
---
.../pinot/plugin/stream/pulsar/PulsarStreamMetadataProvider.java | 3 +--
pom.xml | 2 +-
2 files changed, 2 insertions(+), 3 deletions(-)
diff --git
a/pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarStreamMetadataProvider.java
b/pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarStreamMetadataProvider.java
index 168b8fb96d..5384ec71b1 100644
---
a/pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarStreamMetadataProvider.java
+++
b/pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarStreamMetadataProvider.java
@@ -40,7 +40,6 @@ import org.apache.pulsar.client.api.Message;
import org.apache.pulsar.client.api.MessageId;
import org.apache.pulsar.client.api.PulsarClientException;
import org.apache.pulsar.client.api.SubscriptionMode;
-import org.apache.pulsar.client.util.ConsumerName;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -135,7 +134,7 @@ public class PulsarStreamMetadataProvider extends
PulsarPartitionLevelConnection
partitionGroupConsumptionStatus.getStartOffset()));
}
- String subscription = ConsumerName.generateRandomName();
+ String subscription = UUID.randomUUID().toString();
try {
List<String> partitionedTopicNameList =
_pulsarClient.getPartitionsForTopic(_topic).get();
diff --git a/pom.xml b/pom.xml
index d8f6cca945..856d5ab904 100644
--- a/pom.xml
+++ b/pom.xml
@@ -191,7 +191,7 @@
<kafka2.version>2.8.2</kafka2.version>
<kafka3.version>3.9.0</kafka3.version>
<confluent.version>7.7.0</confluent.version>
- <pulsar.version>3.3.1</pulsar.version>
+ <pulsar.version>4.0.3</pulsar.version>
<flink.version>1.20.1</flink.version>
<!-- Apache Commons Libraries -->
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
