From d69291f9941afcef26dbeca1f06127b37f8d1ab2 Mon Sep 17 00:00:00 2001 From: Jiwei Guo Date: Sat, 6 Jun 2026 11:10:51 +0800 Subject: [PATCH 1/2] Fix compile issue --- .../handlers/mqtt/broker/rest/MQTTAdditionalServlet.java | 5 +++-- .../mqtt/broker/impl/PulsarMessageConverterTest.java | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/mqtt-broker/src/main/java/io/streamnative/pulsar/handlers/mqtt/broker/rest/MQTTAdditionalServlet.java b/mqtt-broker/src/main/java/io/streamnative/pulsar/handlers/mqtt/broker/rest/MQTTAdditionalServlet.java index 1472a23ee..dd37d580d 100644 --- a/mqtt-broker/src/main/java/io/streamnative/pulsar/handlers/mqtt/broker/rest/MQTTAdditionalServlet.java +++ b/mqtt-broker/src/main/java/io/streamnative/pulsar/handlers/mqtt/broker/rest/MQTTAdditionalServlet.java @@ -16,6 +16,7 @@ import org.apache.pulsar.broker.PulsarService; import org.apache.pulsar.broker.web.plugin.servlet.AdditionalServletWithPulsarService; import org.apache.pulsar.common.configuration.PulsarConfiguration; +import org.eclipse.jetty.servlet.ServletHolder; /** * MQTT additional servlet. @@ -35,8 +36,8 @@ public String getBasePath() { } @Override - public Object getServletInstance() { - return new MQTTServiceServlet(pulsarService); + public ServletHolder getServletHolder() { + return new ServletHolder(new MQTTServiceServlet(pulsarService)); } @Override diff --git a/mqtt-broker/src/test/java/io/streamnative/pulsar/handlers/mqtt/broker/impl/PulsarMessageConverterTest.java b/mqtt-broker/src/test/java/io/streamnative/pulsar/handlers/mqtt/broker/impl/PulsarMessageConverterTest.java index 83babfbda..1fdd13456 100644 --- a/mqtt-broker/src/test/java/io/streamnative/pulsar/handlers/mqtt/broker/impl/PulsarMessageConverterTest.java +++ b/mqtt-broker/src/test/java/io/streamnative/pulsar/handlers/mqtt/broker/impl/PulsarMessageConverterTest.java @@ -39,7 +39,7 @@ public void testMqttPayloadReleaseDoesNotReleaseEntry() { .setPublishTime(System.currentTimeMillis()); ByteBuf metadataAndPayload = Commands.serializeMetadataAndPayload(Commands.ChecksumType.None, metadata, payload); - EntryImpl entry = EntryImpl.create(PositionFactory.create(1, 1), metadataAndPayload, 1); + EntryImpl entry = EntryImpl.create(PositionFactory.create(1, 1), metadataAndPayload); metadataAndPayload.release(); payload.release(); From 3fefec8856d122fc9e8742ef78dbde9261362b9f Mon Sep 17 00:00:00 2001 From: streamnativebot Date: Sat, 6 Jun 2026 03:13:09 +0000 Subject: [PATCH 2/2] "Created by snbot" --- mqtt-broker/pom.xml | 2 +- mqtt-common/pom.xml | 2 +- mqtt-proxy/pom.xml | 2 +- pom.xml | 6 +++--- tests/pom.xml | 2 +- 5 files changed, 7 insertions(+), 7 deletions(-) diff --git a/mqtt-broker/pom.xml b/mqtt-broker/pom.xml index 2293b02ff..862820449 100644 --- a/mqtt-broker/pom.xml +++ b/mqtt-broker/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-mqtt-parent io.streamnative.pulsar.handlers - 3.4.0-SNAPSHOT + 4.0.10.5 4.0.0 pulsar-protocol-handler-mqtt diff --git a/mqtt-common/pom.xml b/mqtt-common/pom.xml index 707ea52b6..283808de6 100644 --- a/mqtt-common/pom.xml +++ b/mqtt-common/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-mqtt-parent io.streamnative.pulsar.handlers - 3.4.0-SNAPSHOT + 4.0.10.5 4.0.0 pulsar-protocol-handler-mqtt-common diff --git a/mqtt-proxy/pom.xml b/mqtt-proxy/pom.xml index 47fdb6df7..44c009233 100644 --- a/mqtt-proxy/pom.xml +++ b/mqtt-proxy/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-mqtt-parent io.streamnative.pulsar.handlers - 3.4.0-SNAPSHOT + 4.0.10.5 4.0.0 pulsar-protocol-handler-mqtt-proxy diff --git a/pom.xml b/pom.xml index 3d9a64b9d..6a903ae17 100644 --- a/pom.xml +++ b/pom.xml @@ -19,7 +19,7 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> io.streamnative.pulsar.handlers pulsar-protocol-handler-mqtt-parent - 3.4.0-SNAPSHOT + 4.0.10.5 StreamNative :: Pulsar Protocol Handler :: MoP Parent Parent for MQTT on Pulsar implemented using Pulsar Protocol Handler. @@ -51,8 +51,8 @@ 2.22.0 6.14.3 4.0.2 - 4.0.6.8 - 4.0.6.8 + 4.0.10.5 + 4.0.10.5 2.18.0 1.16 1.2.2 diff --git a/tests/pom.xml b/tests/pom.xml index dc84b2694..43dac17fe 100644 --- a/tests/pom.xml +++ b/tests/pom.xml @@ -20,7 +20,7 @@ pulsar-protocol-handler-mqtt-parent io.streamnative.pulsar.handlers - 3.4.0-SNAPSHOT + 4.0.10.5 4.0.0 pulsar-protocol-handler-mqtt-tests