oRookie opened a new issue #568:
URL: https://github.com/apache/rocketmq-client-go/issues/568
A race condition occurred when starting the consumer
==================
WARNING: DATA RACE
Write at 0x00c0003081e0 by goroutine 58:
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).pullMessage()
github.com/apache/rocketmq-client-go/[email protected]/consumer/push_consumer.go:471
github.com/apache/rocketmq-client-go/[email protected]/consumer/push_consumer.go:156
Previous read at 0x00c00065a120 by goroutine 71:
github.com/apache/rocketmq-client-go/v2/consumer.(*processQueue).isPullExpired()
github.com/apache/rocketmq-client-go/[email protected]/consumer/process_queue.go:198
+0x6d
github.com/apache/rocketmq-client-go/v2/consumer.(*defaultConsumer).updateProcessQueueTable.func1()
github.com/apache/rocketmq-client-go/[email protected]/consumer/consumer.go:673
+0x28c
sync.(*Map).Range()
/usr/local/go/src/sync/map.go:345 +0x16b
github.com/apache/rocketmq-client-go/v2/consumer.(*defaultConsumer).updateProcessQueueTable()
github.com/apache/rocketmq-client-go/[email protected]/consumer/consumer.go:659
+0x1e6
github.com/apache/rocketmq-client-go/v2/consumer.(*defaultConsumer).doBalance.func1()
github.com/apache/rocketmq-client-go/[email protected]/consumer/consumer.go:409 +0x484
sync.(*Map).Range()
/usr/local/go/src/sync/map.go:345 +0x16b
github.com/apache/rocketmq-client-go/v2/consumer.(*defaultConsumer).doBalance()
github.com/apache/rocketmq-client-go/[email protected]/consumer/consumer.go:362 +0x64
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).Rebalance()
github.com/apache/rocketmq-client-go/[email protected]/consumer/push_consumer.go:247
+0x4b
github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).RebalanceImmediately.func1()
github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:680
+0x62
sync.(*Map).Range()
/usr/local/go/src/sync/map.go:345 +0x16b
github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).RebalanceImmediately()
github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:678
+0x9a
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).Start()
github.com/apache/rocketmq-client-go/[email protected]/consumer/push_consumer.go:206
+0x410
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
