We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5779a79 commit a896317Copy full SHA for a896317
internal/topic/topiclistenerinternal/stream_listener.go
@@ -339,11 +339,6 @@ func (l *streamListener) onStopPartitionRequest(
339
m *rawtopicreader.StopPartitionSessionRequest,
340
) error {
341
session, err := l.sessions.Get(m.PartitionSessionID)
342
- if !m.Graceful && session == nil {
343
- // stop partition may be received twice: graceful and force
344
- // the sdk we can forget about the session after graceful stop
345
- return nil
346
- }
347
if err != nil {
348
return err
349
}
0 commit comments