diff --git a/internal/reader/sync_standalone_reader.go b/internal/reader/sync_standalone_reader.go
index 8c2eae17..5ca14b52 100644
--- a/internal/reader/sync_standalone_reader.go
+++ b/internal/reader/sync_standalone_reader.go
@@ -108,7 +108,6 @@ func (r *syncStandaloneReader) StartRead(ctx context.Context) chan *entry.Entry
 			r.sendAOF(startOffset)
 		}
 		close(r.ch)
-		r.client.Close()
 	}()
 
 	return r.ch