xxd763795151 commented on issue #568: URL: https://github.com/apache/rocketmq-client-go/issues/568#issuecomment-753734273
We also have a similar problem: conditon: * one consumer group subscribe multi topic * message has accumulated a lot when starting the consumer client log info: > WARNING: DATA RACE > Read at 0x00c0006b6a88 by goroutine 272: > github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).pullMessage() > /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/push_consumer.go:488 +0xac2 > github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).Start.func1.1.1() > /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/push_consumer.go:156 +0x42 > > Previous write at 0x00c0006b6a88 by goroutine 326: > sync/atomic.AddInt64() > /usr/local/go1.14.7/src/runtime/race_amd64.s:276 +0xb > github.com/apache/rocketmq-client-go/v2/consumer.(*processQueue).removeMessage() > /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/process_queue.go:181 +0x2c1 > github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).consumeMessageCurrently.func1() > /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/push_consumer.go:941 +0xa35 > github.com/apache/rocketmq-client-go/v2/primitive.WithRecover() > /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/primitive/base.go:96 +0x5a > > Goroutine 272 (running) created at: > github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsu mer).Start.func1.1() > /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/push_consumer.go:155 +0x6b > > Goroutine 326 (running) created at: > github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).consumeMessageCurrently() > /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/push_consumer.go:875 +0xe6 > github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).consumeMessageCurrently-fm() > /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/push_consumer.go:860 +0x55 > github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).pullMessage.func1() > /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/consumer/push_consumer.go:443 +0xbc > github.com/apache/rocketmq-client-go/v2/primitive.WithRecover() > /data/ci_build/finance/sg-finance-ledger/f576b2dc_20201231191943/vendor/github.com/apache/rocketmq-client-go/v2/primitive/base.go:96 +0x5a ---------------------------------------------------------------- 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]
