diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/ManagedLedgerInterceptorImpl.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/ManagedLedgerInterceptorImpl.java index bcc4a0754ad80..e3b94ec94a4c1 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/ManagedLedgerInterceptorImpl.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/ManagedLedgerInterceptorImpl.java @@ -64,6 +64,7 @@ public long getIndex() { for (BrokerEntryMetadataInterceptor interceptor : brokerEntryMetadataInterceptors) { if (interceptor instanceof AppendIndexMetadataInterceptor) { index = ((AppendIndexMetadataInterceptor) interceptor).getIndex(); + break; } } return index; @@ -89,6 +90,7 @@ public void onManagedLedgerPropertiesInitialize(Map propertiesMa if (interceptor instanceof AppendIndexMetadataInterceptor) { ((AppendIndexMetadataInterceptor) interceptor) .recoveryIndexGenerator(Long.parseLong(propertiesMap.get(INDEX))); + break; } } } @@ -117,6 +119,7 @@ public CompletableFuture onManagedLedgerLastLedgerInitialize(String name, ((AppendIndexMetadataInterceptor) interceptor) .recoveryIndexGenerator(brokerEntryMetadata.getIndex()); } + break; } } } @@ -144,6 +147,7 @@ public void onUpdateManagedLedgerInfo(Map propertiesMap) { for (BrokerEntryMetadataInterceptor interceptor : brokerEntryMetadataInterceptors) { if (interceptor instanceof AppendIndexMetadataInterceptor) { propertiesMap.put(INDEX, String.valueOf(((AppendIndexMetadataInterceptor) interceptor).getIndex())); + break; } } }