diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java index a8e11fc618093..a67c5e04e3d9b 100644 --- a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java +++ b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java @@ -294,7 +294,7 @@ protected boolean shouldIgnoreEvent(MetadataEvent event, GetResult existingValue } // ignore event if metadata is ephemeral or // sequential - if (options.contains(CreateOption.Ephemeral) || event.getOptions().contains(CreateOption.Sequential)) { + if (options.contains(CreateOption.Ephemeral) || options.contains(CreateOption.Sequential)) { return true; } // ignore the event if event occurred before the