Skip to content

Commit b01c4b4

Browse files
yaron2cicoyle
andauthored
Fix panic when processing incoming messages after close (#3984)
Signed-off-by: yaron2 <[email protected]> Co-authored-by: Cassie Coyle <[email protected]>
1 parent 3b9591e commit b01c4b4

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

common/component/azure/eventhubs/eventhubs.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -450,7 +450,6 @@ func (aeh *AzureEventHubs) Close() (err error) {
450450

451451
// Remove the cached checkpoint store and metadata
452452
aeh.checkpointStoreCache = nil
453-
aeh.metadata = nil
454453

455454
return nil
456455
}

0 commit comments

Comments
 (0)