rocketmq-client-go icon indicating copy to clipboard operation
rocketmq-client-go copied to clipboard

issue: the `ctx` not work for consumer.PullFrom method

Open zl03jsj opened this issue 1 year ago • 0 comments

The context not work in consumer.PullFrom method:

	c, err := consumer2.NewPullConsumer(
		consumer2.WithNameServer([]string{cfg.NameSvr}),
		consumer2.WithGroupName(consumerGroupName),
		consumer2.WithConsumeFromWhere(consumer2.ConsumeFromLastOffset),
		consumer2.WithConsumerOrder(true),
		consumer2.WithRetry(1),
	)
	ctx, _ = context.WithTimeout(context.Background(), time.Second)

	result, err := c.PullFrom(ctx, mq, offset, maxPullCount)

even if the ctx is timeout, or was canceled(if message queue have no new message) manually, it will still block for 30 seconds.

zl03jsj avatar Mar 08 '24 11:03 zl03jsj