Skip to content

Commit 3010ce9

Browse files
wenxuwan文徐
andauthored
feat: Add pause initialization to default PullConsumer to prevent panic (#1226)
* fix pull consumer panic --------- Co-authored-by: 文徐 <[email protected]>
1 parent f1792b8 commit 3010ce9

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

consumer/pull_consumer.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -113,6 +113,7 @@ func NewPullConsumer(options ...Option) (*defaultPullConsumer, error) {
113113
consumerGroup: utils.WrapNamespace(defaultOpts.Namespace, defaultOpts.GroupName),
114114
cType: _PullConsume,
115115
state: atomic2.NewInt32(int32(internal.StateCreateJust)),
116+
pause: atomic2.NewBool(false),
116117
prCh: make(chan PullRequest, 4),
117118
model: defaultOpts.ConsumerModel,
118119
option: defaultOpts,

0 commit comments

Comments
 (0)