You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zi...@apache.org on 2024/12/20 09:54:46 UTC
(pulsar-adapters) branch master updated: [Issue23555][pulsar-adapters] 4.0.0 release of pulsar-client-kafka adaptor (#59)
This is an automated email from the ASF dual-hosted git repository.
zixuan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-adapters.git
The following commit(s) were added to refs/heads/master by this push:
new 305229d [Issue23555][pulsar-adapters] 4.0.0 release of pulsar-client-kafka adaptor (#59)
305229d is described below
commit 305229da1c14c4e8ff6f167d706f9c041f275ca3
Author: VisionXu <vi...@outlook.com>
AuthorDate: Fri Dec 20 17:54:42 2024 +0800
[Issue23555][pulsar-adapters] 4.0.0 release of pulsar-client-kafka adaptor (#59)
* Fix issue: https://github.com/apache/pulsar/issues/23555.
- upgrade Pulsar to 4.0.0
* Fix issue: https://github.com/apache/pulsar/issues/23555.
- set `jcommander` version to 1.82
* Fix issue: https://github.com/apache/pulsar/issues/23555.
- Set `mockito-core` version to 3.12.4
* Fix issue: https://github.com/apache/pulsar/issues/23555.
- Change version to `4.0.0-SNAPSHOT`
* Apply suggestions from code review
Use `4.0.1` version in test.
Co-authored-by: Zixuan Liu <no...@gmail.com>
* Fix issue: https://github.com/apache/pulsar/issues/23555.
- change dependency path, `javax.xxx` -> `jakarta.xxx`
* Fix issue: https://github.com/apache/pulsar/issues/23555.
- `ConsumerName.java` has been removed. Replace ConsumerName#generateRandomName with RandomStringUtils#randomAlphanumeric (#23645)
* Fix issue: https://github.com/apache/pulsar/issues/23555.
- change docker image version.
* Fix issue: https://github.com/apache/pulsar/issues/23555.
- change docker image version.
* Fix issue: https://github.com/apache/pulsar/issues/23555.
- change docker image version.
* Fix issue: https://github.com/apache/pulsar/issues/23555.
- fix docker tag error
---------
Co-authored-by: Zixuan Liu <no...@gmail.com>
---
.github/workflows/integration-test.yaml | 12 ++++++------
README.md | 4 ++--
examples/kafka-streams/pom.xml | 4 ++--
examples/pom.xml | 2 +-
examples/spark/pom.xml | 2 +-
pom.xml | 16 +++++++++++-----
pulsar-client-kafka-compat/pom.xml | 2 +-
.../pulsar-client-kafka-shaded/pom.xml | 2 +-
.../pulsar-client-kafka-shaded_0_8/pom.xml | 2 +-
.../pulsar-client-kafka-shaded_0_9/pom.xml | 2 +-
.../pulsar-client-kafka-tests/pom.xml | 7 +------
.../pulsar-client-kafka-tests_0_8/pom.xml | 3 ++-
.../pulsar-client-kafka-tests_0_9/pom.xml | 2 +-
pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml | 2 +-
.../kafka/clients/consumer/PulsarKafkaConsumer.java | 4 ++--
.../pulsar-client-kafka_0_8/pom.xml | 2 +-
.../pulsar-client-kafka_0_9/pom.xml | 6 +++++-
.../kafka/clients/consumer/PulsarKafkaConsumer.java | 4 ++--
pulsar-log4j2-appender/pom.xml | 2 +-
pulsar-spark/pom.xml | 2 +-
pulsar-storm/pom.xml | 2 +-
tests/pom.xml | 2 +-
tests/pulsar-kafka-compat-client-test/pom.xml | 2 +-
tests/pulsar-spark-test/pom.xml | 4 ++--
tests/pulsar-storm-test/pom.xml | 4 ++--
25 files changed, 51 insertions(+), 45 deletions(-)
diff --git a/.github/workflows/integration-test.yaml b/.github/workflows/integration-test.yaml
index 9daee75..2afbca8 100644
--- a/.github/workflows/integration-test.yaml
+++ b/.github/workflows/integration-test.yaml
@@ -71,22 +71,22 @@ jobs:
distribution: 'adopt'
java-version: 17
- - name: install org.apache.pulsar.tests:integration:jar:tests:3.0.7
+ - name: install org.apache.pulsar.tests:integration:jar:tests:4.0.1
if: ${{ steps.check_changes.outputs.docs_only != 'true' }}
run: |
cd ~
- git clone --depth 50 --single-branch --branch v3.0.7 https://github.com/apache/pulsar
+ git clone --depth 50 --single-branch --branch v4.0.1 https://github.com/apache/pulsar
cd pulsar
mvn -B -ntp -f tests/pom.xml -pl org.apache.pulsar.tests:tests-parent,org.apache.pulsar.tests:integration install
- name: build apachepulsar/pulsar-test-latest-version:latest
if: ${{ steps.check_changes.outputs.docs_only != 'true' }}
run: |
- docker pull apachepulsar/pulsar-all:3.0.7
- docker pull apachepulsar/pulsar:3.0.7
- docker tag apachepulsar/pulsar-all:3.0.7 apachepulsar/pulsar-all:latest
- docker tag apachepulsar/pulsar:3.0.7 apachepulsar/pulsar:latest
cd ~/pulsar
+ docker pull apachepulsar/pulsar-all:4.0.1
+ docker pull apachepulsar/pulsar:4.0.1
+ docker tag apachepulsar/pulsar-all:4.0.1 apachepulsar/pulsar-all:4.0.1-$(git rev-parse --short=7 HEAD)
+ docker tag apachepulsar/pulsar:4.0.1 apachepulsar/pulsar:4.0.1-$(git rev-parse --short=7 HEAD)
mvn -B -ntp -f tests/docker-images/pom.xml install -pl org.apache.pulsar.tests:latest-version-image -am -Pdocker,-main -DskipTests
- name: run integration tests
diff --git a/README.md b/README.md
index 7ebe364..29ceada 100644
--- a/README.md
+++ b/README.md
@@ -34,11 +34,11 @@ mvn install
In order to build this repository the linked Pulsar release must be released to Maven Central
other wise you have to build it locally.
-For instance if this code depends on Pulsar 3.0.7 you have to build Pulsar 3.0.7 locally
+For instance if this code depends on Pulsar 4.0.1 you have to build Pulsar 4.0.1 locally
```
git clone https://github.com/apache/pulsar
-git checkout v3.0.7
+git checkout v4.0.1
mvn clean install -DskipTests
```
diff --git a/examples/kafka-streams/pom.xml b/examples/kafka-streams/pom.xml
index 3817185..201cdbc 100644
--- a/examples/kafka-streams/pom.xml
+++ b/examples/kafka-streams/pom.xml
@@ -24,7 +24,7 @@
<parent>
<groupId>org.apache.pulsar.examples</groupId>
<artifactId>pulsar-adapters-examples</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
</parent>
<artifactId>kafka-streams</artifactId>
@@ -35,7 +35,7 @@
<dependency>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-client-kafka</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
</dependency>
<!-- Apache Kafka dependencies -->
diff --git a/examples/pom.xml b/examples/pom.xml
index ed17a82..2267ec1 100644
--- a/examples/pom.xml
+++ b/examples/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-adapters</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
</parent>
<groupId>org.apache.pulsar.examples</groupId>
diff --git a/examples/spark/pom.xml b/examples/spark/pom.xml
index f59d037..92a2198 100644
--- a/examples/spark/pom.xml
+++ b/examples/spark/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.pulsar.examples</groupId>
<artifactId>pulsar-adapters-examples</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
</parent>
<artifactId>spark</artifactId>
diff --git a/pom.xml b/pom.xml
index 0f2cca6..29a118e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -32,7 +32,7 @@
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-adapters</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<name>Pulsar Adapters</name>
<description>A collections of Pulsar adapters.</description>
@@ -76,7 +76,7 @@
</issueManagement>
<properties>
- <pulsar.version>3.0.7</pulsar.version>
+ <pulsar.version>4.0.1</pulsar.version>
<kafka-client.version>2.7.2</kafka-client.version>
<storm.version>2.0.0</storm.version>
<kafka_0_8.version>0.8.1.1</kafka_0_8.version>
@@ -123,7 +123,7 @@
<surefire.version>3.0.0-M3</surefire.version>
<maven-assembly-plugin.version>3.3.0</maven-assembly-plugin.version>
<maven-dependency-plugin.version>3.1.2</maven-dependency-plugin.version>
- <maven-shade-plugin>3.4.1</maven-shade-plugin>
+ <maven-shade-plugin>3.6.0</maven-shade-plugin>
<maven-antrun-plugin.version>3.0.0</maven-antrun-plugin.version>
<nifi-nar-maven-plugin.version>1.2.0</nifi-nar-maven-plugin.version>
<maven-checkstyle-plugin.version>3.1.2</maven-checkstyle-plugin.version>
@@ -296,6 +296,12 @@
<artifactId>powermock-module-testng</artifactId>
<version>${powermock.version}</version>
</dependency>
+ <dependency>
+ <groupId>org.mockito</groupId>
+ <artifactId>mockito-core</artifactId>
+ <version>3.12.4</version>
+ <scope>test</scope>
+ </dependency>
</dependencies>
</dependencyManagement>
@@ -345,8 +351,8 @@
<scope>provided</scope>
</dependency>
<dependency>
- <groupId>javax.annotation</groupId>
- <artifactId>javax.annotation-api</artifactId>
+ <groupId>jakarta.annotation</groupId>
+ <artifactId>jakarta.annotation-api</artifactId>
<scope>provided</scope>
</dependency>
diff --git a/pulsar-client-kafka-compat/pom.xml b/pulsar-client-kafka-compat/pom.xml
index 5c965cf..f9e643c 100644
--- a/pulsar-client-kafka-compat/pom.xml
+++ b/pulsar-client-kafka-compat/pom.xml
@@ -27,7 +27,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-adapters</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml
index 3be6ef6..27a741c 100644
--- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml
+++ b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded/pom.xml
@@ -27,7 +27,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-client-kafka-compat</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml
index 22d68f9..c13e156 100644
--- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml
+++ b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_8/pom.xml
@@ -27,7 +27,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-client-kafka-compat</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml
index 5c935dd..7d82075 100644
--- a/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml
+++ b/pulsar-client-kafka-compat/pulsar-client-kafka-shaded_0_9/pom.xml
@@ -27,7 +27,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-client-kafka-compat</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml
index 9bbef89..2e16a16 100644
--- a/pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml
+++ b/pulsar-client-kafka-compat/pulsar-client-kafka-tests/pom.xml
@@ -27,7 +27,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-client-kafka-compat</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
@@ -36,11 +36,6 @@
<description>Tests to verify the correct shading configuration for the pulsar-client-kafka wrapper</description>
- <properties>
- <maven.compiler.source>17</maven.compiler.source>
- <maven.compiler.target>17</maven.compiler.target>
- </properties>
-
<dependencies>
<dependency>
<groupId>${project.groupId}</groupId>
diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/pom.xml
index 09117d9..cea9056 100644
--- a/pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/pom.xml
+++ b/pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_8/pom.xml
@@ -27,7 +27,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-client-kafka-compat</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
@@ -83,6 +83,7 @@
<dependency>
<groupId>com.beust</groupId>
<artifactId>jcommander</artifactId>
+ <version>1.82</version>
<scope>test</scope>
</dependency>
diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/pom.xml
index 340eeab..2b6de0d 100644
--- a/pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/pom.xml
+++ b/pulsar-client-kafka-compat/pulsar-client-kafka-tests_0_9/pom.xml
@@ -27,7 +27,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-client-kafka-compat</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml
index 6b01afd..d7f29d0 100644
--- a/pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml
+++ b/pulsar-client-kafka-compat/pulsar-client-kafka/pom.xml
@@ -27,7 +27,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-client-kafka-compat</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/PulsarKafkaConsumer.java b/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/PulsarKafkaConsumer.java
index 67d052b..6ae6302 100644
--- a/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/PulsarKafkaConsumer.java
+++ b/pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/kafka/clients/consumer/PulsarKafkaConsumer.java
@@ -66,7 +66,7 @@ import org.apache.pulsar.client.impl.TopicMessageIdImpl;
import org.apache.pulsar.client.kafka.compat.PulsarClientKafkaConfig;
import org.apache.pulsar.client.kafka.compat.PulsarConsumerKafkaConfig;
import org.apache.pulsar.client.kafka.compat.PulsarKafkaSchema;
-import org.apache.pulsar.client.util.ConsumerName;
+import org.apache.commons.lang3.RandomStringUtils;
import org.apache.pulsar.client.util.MessageIdUtils;
import org.apache.pulsar.common.naming.TopicName;
import org.apache.pulsar.common.util.FutureUtil;
@@ -270,7 +270,7 @@ public class PulsarKafkaConsumer<K, V> implements Consumer<K, V>, MessageListene
consumerBuilder.subscriptionName(groupId);
if (numberOfPartitions > 1) {
// Subscribe to each partition
- consumerBuilder.consumerName(ConsumerName.generateRandomName());
+ consumerBuilder.consumerName(RandomStringUtils.randomAlphanumeric(5));
for (int i = 0; i < numberOfPartitions; i++) {
String partitionName = TopicName.get(topic).getPartition(i).toString();
CompletableFuture<org.apache.pulsar.client.api.Consumer<byte[]>> future = consumerBuilder.clone()
diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml
index 9747e8e..6a9ceae 100644
--- a/pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml
+++ b/pulsar-client-kafka-compat/pulsar-client-kafka_0_8/pom.xml
@@ -27,7 +27,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-client-kafka-compat</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml b/pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml
index 5315723..ea73eed 100644
--- a/pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml
+++ b/pulsar-client-kafka-compat/pulsar-client-kafka_0_9/pom.xml
@@ -27,7 +27,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-client-kafka-compat</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
@@ -108,6 +108,10 @@
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
</dependency>
+ <dependency>
+ <groupId>org.apache.commons</groupId>
+ <artifactId>commons-lang3</artifactId>
+ </dependency>
</dependencies>
</project>
diff --git a/pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/kafka/clients/consumer/PulsarKafkaConsumer.java b/pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/kafka/clients/consumer/PulsarKafkaConsumer.java
index 0f65107..3563807 100644
--- a/pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/kafka/clients/consumer/PulsarKafkaConsumer.java
+++ b/pulsar-client-kafka-compat/pulsar-client-kafka_0_9/src/main/java/org/apache/kafka/clients/consumer/PulsarKafkaConsumer.java
@@ -60,7 +60,7 @@ import org.apache.pulsar.client.impl.PulsarClientImpl;
import org.apache.pulsar.client.kafka.compat.PulsarClientKafkaConfig;
import org.apache.pulsar.client.kafka.compat.PulsarConsumerKafkaConfig;
import org.apache.pulsar.client.kafka.compat.PulsarKafkaSchema;
-import org.apache.pulsar.client.util.ConsumerName;
+import org.apache.commons.lang3.RandomStringUtils;
import org.apache.pulsar.client.util.MessageIdUtils;
import org.apache.pulsar.common.naming.TopicName;
import org.apache.pulsar.common.util.FutureUtil;
@@ -221,7 +221,7 @@ public class PulsarKafkaConsumer<K, V> implements Consumer<K, V>, MessageListene
consumerBuilder.subscriptionName(groupId);
if (numberOfPartitions > 1) {
// Subscribe to each partition
- consumerBuilder.consumerName(ConsumerName.generateRandomName());
+ consumerBuilder.consumerName(RandomStringUtils.randomAlphanumeric(5));
for (int i = 0; i < numberOfPartitions; i++) {
String partitionName = TopicName.get(topic).getPartition(i).toString();
CompletableFuture<org.apache.pulsar.client.api.Consumer<byte[]>> future = consumerBuilder.clone()
diff --git a/pulsar-log4j2-appender/pom.xml b/pulsar-log4j2-appender/pom.xml
index 09f54d7..e88f42d 100644
--- a/pulsar-log4j2-appender/pom.xml
+++ b/pulsar-log4j2-appender/pom.xml
@@ -24,7 +24,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-adapters</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
diff --git a/pulsar-spark/pom.xml b/pulsar-spark/pom.xml
index a6bd89e..5dd0d29 100644
--- a/pulsar-spark/pom.xml
+++ b/pulsar-spark/pom.xml
@@ -26,7 +26,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-adapters</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
diff --git a/pulsar-storm/pom.xml b/pulsar-storm/pom.xml
index 4fad85e..18057c3 100644
--- a/pulsar-storm/pom.xml
+++ b/pulsar-storm/pom.xml
@@ -26,7 +26,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-adapters</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
diff --git a/tests/pom.xml b/tests/pom.xml
index 7d4b68d..d34b568 100644
--- a/tests/pom.xml
+++ b/tests/pom.xml
@@ -26,7 +26,7 @@
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-adapters</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
</parent>
<groupId>org.apache.pulsar.tests</groupId>
<artifactId>adapters-tests-parent</artifactId>
diff --git a/tests/pulsar-kafka-compat-client-test/pom.xml b/tests/pulsar-kafka-compat-client-test/pom.xml
index c3593ed..d0a3ccc 100644
--- a/tests/pulsar-kafka-compat-client-test/pom.xml
+++ b/tests/pulsar-kafka-compat-client-test/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.pulsar.tests</groupId>
<artifactId>adapters-tests-parent</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
</parent>
<artifactId>pulsar-kafka-compat-client-test</artifactId>
diff --git a/tests/pulsar-spark-test/pom.xml b/tests/pulsar-spark-test/pom.xml
index 8346d77..4289f31 100644
--- a/tests/pulsar-spark-test/pom.xml
+++ b/tests/pulsar-spark-test/pom.xml
@@ -26,7 +26,7 @@
<parent>
<groupId>org.apache.pulsar.tests</groupId>
<artifactId>adapters-tests-parent</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
</parent>
<artifactId>pulsar-spark-test</artifactId>
@@ -41,7 +41,7 @@
<dependency>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-spark</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<scope>test</scope>
</dependency>
diff --git a/tests/pulsar-storm-test/pom.xml b/tests/pulsar-storm-test/pom.xml
index f93defc..152978f 100644
--- a/tests/pulsar-storm-test/pom.xml
+++ b/tests/pulsar-storm-test/pom.xml
@@ -26,7 +26,7 @@
<parent>
<groupId>org.apache.pulsar.tests</groupId>
<artifactId>adapters-tests-parent</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
</parent>
<artifactId>pulsar-storm-test</artifactId>
@@ -43,7 +43,7 @@
<dependency>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-storm</artifactId>
- <version>3.0.7</version>
+ <version>4.0.0-SNAPSHOT</version>
<scope>test</scope>
<exclusions>
<exclusion>