diff --git a/tests/pulsar-client-admin-shade-test/pom.xml b/tests/pulsar-client-admin-shade-test/pom.xml index 1ce482ad2323a..cdb1fb3b59336 100644 --- a/tests/pulsar-client-admin-shade-test/pom.xml +++ b/tests/pulsar-client-admin-shade-test/pom.xml @@ -62,6 +62,12 @@ test + + io.netty + netty-buffer + test + + diff --git a/tests/pulsar-client-admin-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java b/tests/pulsar-client-admin-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java index d8ad93d570a33..fc5f4e0b300ad 100644 --- a/tests/pulsar-client-admin-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java +++ b/tests/pulsar-client-admin-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java @@ -21,6 +21,8 @@ import static org.testng.Assert.assertEquals; import static org.testng.Assert.assertNull; import static org.testng.Assert.assertTrue; +import io.netty.buffer.ByteBuf; +import io.netty.buffer.Unpooled; import java.io.IOException; import java.net.URI; import java.nio.ByteBuffer; @@ -58,8 +60,7 @@ import org.apache.pulsar.common.compression.CompressionCodecProvider; import org.apache.pulsar.common.policies.data.TenantInfoImpl; import org.apache.pulsar.common.protocol.Commands; -import org.apache.pulsar.shade.io.netty.buffer.ByteBuf; -import org.apache.pulsar.shade.io.netty.buffer.Unpooled; + import org.apache.pulsar.tests.TestRetrySupport; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/tests/pulsar-client-all-shade-test/pom.xml b/tests/pulsar-client-all-shade-test/pom.xml index ce2705bb3c97f..9ff229e7e02b5 100644 --- a/tests/pulsar-client-all-shade-test/pom.xml +++ b/tests/pulsar-client-all-shade-test/pom.xml @@ -61,6 +61,12 @@ ${project.version} + + io.netty + netty-buffer + test + + diff --git a/tests/pulsar-client-all-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java b/tests/pulsar-client-all-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java index 69ee2d0ebcbd0..f9ea3dd506eb3 100644 --- a/tests/pulsar-client-all-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java +++ b/tests/pulsar-client-all-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java @@ -21,6 +21,8 @@ import static org.testng.Assert.assertEquals; import static org.testng.Assert.assertNull; import static org.testng.Assert.assertTrue; +import io.netty.buffer.ByteBuf; +import io.netty.buffer.Unpooled; import java.io.IOException; import java.net.URI; import java.nio.ByteBuffer; @@ -58,8 +60,6 @@ import org.apache.pulsar.common.compression.CompressionCodecProvider; import org.apache.pulsar.common.policies.data.TenantInfo; import org.apache.pulsar.common.protocol.Commands; -import org.apache.pulsar.shade.io.netty.buffer.ByteBuf; -import org.apache.pulsar.shade.io.netty.buffer.Unpooled; import org.apache.pulsar.tests.TestRetrySupport; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/tests/pulsar-client-shade-test/pom.xml b/tests/pulsar-client-shade-test/pom.xml index 7a5746c7861a9..53fae401ff70d 100644 --- a/tests/pulsar-client-shade-test/pom.xml +++ b/tests/pulsar-client-shade-test/pom.xml @@ -56,6 +56,12 @@ test + + io.netty + netty-buffer + test + + diff --git a/tests/pulsar-client-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java b/tests/pulsar-client-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java index a0a54e4604ae8..9a4758f97c12d 100644 --- a/tests/pulsar-client-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java +++ b/tests/pulsar-client-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java @@ -21,6 +21,8 @@ import static org.testng.Assert.assertEquals; import static org.testng.Assert.assertNull; import static org.testng.Assert.assertTrue; +import io.netty.buffer.ByteBuf; +import io.netty.buffer.Unpooled; import java.io.IOException; import java.net.URI; import java.nio.ByteBuffer; @@ -58,8 +60,6 @@ import org.apache.pulsar.common.compression.CompressionCodecProvider; import org.apache.pulsar.common.policies.data.TenantInfo; import org.apache.pulsar.common.protocol.Commands; -import org.apache.pulsar.shade.io.netty.buffer.ByteBuf; -import org.apache.pulsar.shade.io.netty.buffer.Unpooled; import org.apache.pulsar.tests.TestRetrySupport; import org.slf4j.Logger; import org.slf4j.LoggerFactory;