diff --git a/pulsar-metadatastore-oxia/pom.xml b/pulsar-metadatastore-oxia/pom.xml index 3592678f..5138ae2e 100644 --- a/pulsar-metadatastore-oxia/pom.xml +++ b/pulsar-metadatastore-oxia/pom.xml @@ -36,7 +36,7 @@ UTF-8 io.streamnative.pulsarmetadatastoreoxia.shaded - 2.11.0.3 + 3.0.2 10.3.3 7.7.0 @@ -61,7 +61,7 @@ ${project.version} - io.streamnative + org.apache.pulsar pulsar-metadata ${pulsar.version} provided @@ -79,13 +79,13 @@ test - io.streamnative + org.apache.pulsar buildtools ${pulsar.version} test - io.streamnative + org.apache.pulsar pulsar-metadata ${pulsar.version} test-jar diff --git a/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStore.java b/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStore.java index 7466c019..953f40af 100644 --- a/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStore.java +++ b/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStore.java @@ -57,6 +57,8 @@ public class OxiaMetadataStore extends AbstractMetadataStore { @NonNull MetadataStoreConfig metadataStoreConfig, boolean enableSessionWatcher) throws Exception { + super("oxia-metadata"); + var linger = metadataStoreConfig.getBatchingMaxDelayMillis(); if (!metadataStoreConfig.isBatchingEnabled()) { linger = 0;