We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0c2ce13 commit e439b97Copy full SHA for e439b97
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
@@ -498,7 +498,7 @@ protected void receivedSessionEvent(SessionEvent event) {
498
isConnected = event.isConnected();
499
500
// Clear cache after session expired.
501
- if (event == SessionEvent.SessionReestablished) {
+ if (event == SessionEvent.SessionReestablished || event == SessionEvent.Reconnected) {
502
for (MetadataCacheImpl metadataCache : metadataCaches) {
503
metadataCache.invalidateAll();
504
}
0 commit comments