From 4d7b0270febc7b346a9e17a5878255a814355b8d Mon Sep 17 00:00:00 2001 From: zgg2001 <397606244@qq.com> Date: Fri, 19 Jan 2024 10:38:11 +0800 Subject: [PATCH] bugfix: fix panic when sync reader needed to exit --- internal/reader/sync_standalone_reader.go | 1 - 1 file changed, 1 deletion(-) 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