wolftankk opened a new issue #139: fatal error: concurrent map writes URL: https://github.com/apache/rocketmq-client-go/issues/139 In the newest sdk, get the errors: ```bash fatal error: concurrent map writes goroutine 55 [running]: runtime.throw(0x5ddf1e, 0x15) /usr/lib/golang/src/runtime/panic.go:617 +0x72 fp=0xc0001076b0 sp=0xc000107680 pc=0x42ccc2 runtime.mapassign_fast64(0x5a01e0, 0xc0001e2660, 0x0, 0x75fd00) /usr/lib/golang/src/runtime/map_fast64.go:101 +0x35f fp=0xc0001076f0 sp=0xc0001076b0 pc=0x41220f github.com/apache/rocketmq-client-go/consumer.(*localFileOffsetStore).update(0xc00009ec90, 0xc0001a2b70, 0x16, 0xc00012c000) /home/work/rocketmq-client-go/consumer/offset_store.go:137 +0x1e1 fp=0xc000107748 sp=0xc0001076f0 pc=0x5639e1 github.com/apache/rocketmq-client-go/consumer.(*pushConsumer).pullMessage.func2(0xc00007c700, 0xc0001a2c90) /home/work/rocketmq-client-go/consumer/push_consumer.go:482 +0x7b fp=0xc0001077d0 sp=0xc000107748 pc=0x5719eb runtime.goexit() /usr/lib/golang/src/runtime/asm_amd64.s:1337 +0x1 fp=0xc0001077d8 sp=0xc0001077d0 pc=0x458311 created by github.com/apache/rocketmq-client-go/consumer.(*pushConsumer).pullMessage /home/work/rocketmq-client-go/consumer/push_consumer.go:480 +0x138b goroutine 1 [sleep]: runtime.goparkunlock(...) /usr/lib/golang/src/runtime/proc.go:307 time.Sleep(0x34630b8a000) /usr/lib/golang/src/runtime/time.go:105 +0x159 main.main() /home/work/rocketmq-client-go/examples/consumer/simple/main.go:51 +0x258 goroutine 5 [sleep]: runtime.goparkunlock(...) /usr/lib/golang/src/runtime/proc.go:307 time.Sleep(0x2540be400) /usr/lib/golang/src/runtime/time.go:105 +0x159 github.com/apache/rocketmq-client-go/consumer.(*statsItemSet).init.func1(0xc00007c5c0) /home/work/rocketmq-client-go/consumer/statistics.go:149 +0x3b created by github.com/apache/rocketmq-client-go/consumer.(*statsItemSet).init /home/work/rocketmq-client-go/consumer/statistics.go:146 +0x43 goroutine 6 [sleep]: runtime.goparkunlock(...) /usr/lib/golang/src/runtime/proc.go:307 time.Sleep(0x8bb2c97000) /usr/lib/golang/src/runtime/time.go:105 +0x159 github.com/apache/rocketmq-client-go/consumer.(*statsItemSet).init.func2(0xc00007c5c0) /home/work/rocketmq-client-go/consumer/statistics.go:156 +0x3b created by github.com/apache/rocketmq-client-go/consumer.(*statsItemSet).init /home/work/rocketmq-client-go/consumer/statistics.go:153 +0x65 ``` test code: ```golang package main import ( "context" "fmt" "os" "time" "github.com/apache/rocketmq-client-go" "github.com/apache/rocketmq-client-go/consumer" "github.com/apache/rocketmq-client-go/primitive" ) func main() { c, _ := rocketmq.NewPushConsumer( consumer.WithGroupName("testGroup"), consumer.WithNameServer([]string{"127.0.0.1:9876"}), consumer.WithConsumeFromWhere(consumer.ConsumeFromFirstOffset), ) err := c.Subscribe("TopicTest", consumer.MessageSelector{}, func(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) { fmt.Printf("subscribe callback: %v \n", msgs) return consumer.ConsumeSuccess, nil }) if err != nil { fmt.Println(err.Error()) } // Note: start after subscribe err = c.Start() if err != nil { fmt.Println(err.Error()) os.Exit(-1) } time.Sleep(time.Hour) } ```
---------------------------------------------------------------- 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] With regards, Apache Git Services
