kylebjcn opened a new issue #794: URL: https://github.com/apache/rocketmq-client-go/issues/794
The issue tracker is **ONLY** used for the go client (feature request of RocketMQ need to follow [RIP process](https://github.com/apache/rocketmq/wiki/RocketMQ-Improvement-Proposal)). Keep in mind, please check whether there is an existing same report before your raise a new one. Alternately (especially if your communication is not a bug report), you can send mail to our [mailing lists](http://rocketmq.apache.org/about/contact/). We welcome any friendly suggestions, bug fixes, collaboration, and other improvements. Please ensure that your bug report is clear and that it is complete. Otherwise, we may be unable to understand it or to reproduce it, either of which would prevent us from fixing the bug. We strongly recommend the report(bug report or feature request) could include some hints as to the following: **BUG REPORT** 1. Please describe the issue you observed: - What did you do (The steps to reproduce)? try example！ https://github.com/apache/rocketmq-client-go/ producer/simple/ - What did you expect to see? Do it correctly. - What did you see instead? Error message 2. Please tell us about your environment: - What is your OS? - win11 - What is your client version? - golang 1.18 - What is your RocketMQ version? - Rocketmq 4.91 3. Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc): unexpected fault address 0xffffffffffffffff fatal error: fault [signal 0xc0000005 code=0x0 addr=0xffffffffffffffff pc=0x7fa7f] goroutine 1 [running]: runtime.throw({0x35648f?, 0x2eec5a?}) D:/Develop/Go/src/runtime/panic.go:992 +0x76 fp=0xc000129470 sp=0xc000129440 pc=0x55f16 runtime.sigpanic() D:/Develop/Go/src/runtime/signal_windows.go:261 +0x125 fp=0xc0001294b8 sp=0xc000129470 pc=0x68f05 aeshashbody() D:/Develop/Go/src/runtime/asm_amd64.s:1343 +0x39f fp=0xc0001294c0 sp=0xc0001294b8 pc=0x7fa7f runtime.mapiternext(0xc00030c240) D:/Develop/Go/src/runtime/map.go:934 +0x2cb fp=0xc000129530 sp=0xc0001294c0 pc=0x2f8cb runtime.mapiterinit(0x1?, 0x1b?, 0x10?) D:/Develop/Go/src/runtime/map.go:861 +0x228 fp=0xc000129550 sp=0xc000129530 pc=0x2f5a8 reflect.mapiterinit(0x2f64e0?, 0x2a1f5?, 0x3070d8?) D:/Develop/Go/src/runtime/map.go:1373 +0x19 fp=0xc000129578 sp=0xc000129550 pc=0x7c259 github.com/modern-go/reflect2.(*UnsafeMapType).UnsafeIterate(...) D:/Golang/pkg/mod/github.com/modern-go/[email protected]/unsafe_map.go:112 github.com/json-iterator/go.(*mapEncoder).Encode(0xc000314780, 0xc0000728e0, 0xc0003007e0) D:/Golang/pkg/mod/github.com/json-iterator/[email protected]/reflect_map.go:257 +0x21c fp=0xc000129628 sp=0xc000129578 pc=0x13529c github.com/json-iterator/go.(*structFieldEncoder).Encode(0xc000314900, 0x2e1342?, 0xc0003007e0) D:/Golang/pkg/mod/github.com/json-iterator/[email protected]/reflect_struct_encoder.go:110 +0x56 fp=0xc0001296a0 sp=0xc000129628 pc=0x142bb6 github.com/json-iterator/go.(*structEncoder).Encode(0xc000314960, 0x0?, 0xc0003007e0) D:/Golang/pkg/mod/github.com/json-iterator/[email protected]/reflect_struct_encoder.go:158 +0x652 fp=0xc000129778 sp=0xc0001296a0 pc=0x1434b2 github.com/json-iterator/go.(*OptionalEncoder).Encode(0xc00007a0a0?, 0x0?, 0x0?) D:/Golang/pkg/mod/github.com/json-iterator/[email protected]/reflect_optional.go:74 +0xa4 fp=0xc0001297c8 sp=0xc000129778 pc=0x13abe4 github.com/json-iterator/go.(*onePtrEncoder).Encode(0xc0003085b0, 0xc0000728c0, 0xc0003140f0?) D:/Golang/pkg/mod/github.com/json-iterator/[email protected]/reflect.go:219 +0x82 fp=0xc000129800 sp=0xc0001297c8 pc=0x12e2c2 github.com/json-iterator/go.(*Stream).WriteVal(0xc0003007e0, {0x315580, 0xc0000728c0}) D:/Golang/pkg/mod/github.com/json-iterator/[email protected]/reflect.go:98 +0x158 fp=0xc000129870 sp=0xc000129800 pc=0x12d5d8 github.com/json-iterator/go.(*frozenConfig).Marshal(0xc00007a0a0, {0x315580, 0xc0000728c0}) D:/Golang/pkg/mod/github.com/json-iterator/[email protected]/config.go:299 +0xc9 fp=0xc000129908 sp=0xc000129870 pc=0x125ca9 github.com/json-iterator/go.Marshal(...) D:/Golang/pkg/mod/github.com/json-iterator/[email protected]/adapter.go:34 github.com/apache/rocketmq-client-go/v2/internal/remote.(*jsonCodec).encodeHeader(0xc0001299b0?, 0x2eebd?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/remote/codec.go:281 +0x33 fp=0xc000129930 sp=0xc000129908 pc=0x2b8513 github.com/apache/rocketmq-client-go/v2/internal/remote.(*RemotingCommand).WriteTo(0xc0000728c0, {0x3db0a0, 0xc00030a080}) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/remote/codec.go:144 +0x85 fp=0xc000129988 sp=0xc000129930 pc=0x2b7fa5 github.com/apache/rocketmq-client-go/v2/internal/remote.(*remotingClient).doRequest(0x0?, 0xc00030a080, 0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/remote/remote_client.go:277 +0xaf fp=0xc000129a08 sp=0xc000129988 pc=0x2bb94f github.com/apache/rocketmq-client-go/v2/internal/remote.(*remotingClient).sendRequest(0xc0001b6b60?, 0x2f0da0?, 0x57cee8?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/remote/remote_client.go:269 +0xdb fp=0xc000129a58 sp=0xc000129a08 pc=0x2bb81b github.com/apache/rocketmq-client-go/v2/internal/remote.(*remotingClient).InvokeSync(0xc0001b6b60, {0x3ddeb8?, 0xc0000742a0}, {0x35ad6b?, 0x0?}, 0xc0000728c0) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/remote/remote_client.go:79 +0x1c7 fp=0xc000129b00 sp=0xc000129a58 pc=0x2ba627 github.com/apache/rocketmq-client-go/v2/internal.(*namesrvs).queryTopicRouteInfoFromServer(0xc000200000, {0x3562c3, 0x4}) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/route.go:355 +0x2a5 fp=0xc000129be0 sp=0xc000129b00 pc=0x2c63a5 github.com/apache/rocketmq-client-go/v2/internal.(*namesrvs).UpdateTopicRouteInfoWithDefault(0xc000200000, {0x3562c3, 0x4}, {0x0?, 0x0}, 0x0) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/route.go:132 +0x13a fp=0xc000129ce0 sp=0xc000129be0 pc=0x2c569a github.com/apache/rocketmq-client-go/v2/internal.(*namesrvs).UpdateTopicRouteInfo(...) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/route.go:116 github.com/apache/rocketmq-client-go/v2/producer.(*defaultProducer).selectMessageQueue(0xc0001dd520, 0xc0001b6c40) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/producer/producer.go:368 +0x95 fp=0xc000129d68 sp=0xc000129ce0 pc=0x2cdbd5 github.com/apache/rocketmq-client-go/v2/producer.(*defaultProducer).sendSync(0xc0001dd520, {0x3dde80, 0xc000020050}, 0xc0001b6c40, 0xc000006268?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/producer/producer.go:188 +0x136 fp=0xc000129e08 sp=0xc000129d68 pc=0x2cd2d6 github.com/apache/rocketmq-client-go/v2/producer.(*defaultProducer).SendSync(0xc0001dd520, {0x3dde80, 0xc000020050}, {0xc000006268, 0x1, 0x1}) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/producer/producer.go:170 +0x2a6 fp=0xc000129e78 sp=0xc000129e08 pc=0x2cd046 main.main() D:/Golang/MAGANG/Container/r2.go:46 +0x368 fp=0xc000129f80 sp=0xc000129e78 pc=0x2cec08 runtime.main() D:/Develop/Go/src/runtime/proc.go:250 +0x1fe fp=0xc000129fe0 sp=0xc000129f80 pc=0x5851e runtime.goexit() D:/Develop/Go/src/runtime/asm_amd64.s:1571 +0x1 fp=0xc000129fe8 sp=0xc000129fe0 pc=0x827e1 goroutine 6 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func1() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:156 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:152 +0x98 goroutine 7 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func2() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:170 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:166 +0x116 goroutine 8 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func3() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:183 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:179 +0x196 goroutine 9 [sleep]: time.Sleep(0xdf8475800) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func4() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:193 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:192 +0x216 goroutine 10 [sleep]: time.Sleep(0x34630b8a000) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func5() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:207 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:206 +0x296 goroutine 11 [sleep]: time.Sleep(0x983fd97a37254) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func6() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:221 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:220 +0x316 goroutine 12 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func1() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:156 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:152 +0x98 goroutine 13 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func2() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:170 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:166 +0x116 goroutine 14 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func3() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:183 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:179 +0x196 goroutine 15 [sleep]: time.Sleep(0xdf8475800) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func4() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:193 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:192 +0x216 goroutine 16 [sleep]: time.Sleep(0x34630b8a000) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func5() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:207 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:206 +0x296 goroutine 18 [sleep]: time.Sleep(0x983fd97a37254) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func6() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:221 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:220 +0x316 goroutine 19 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func1() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:156 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:152 +0x98 goroutine 20 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func2() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:170 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:166 +0x116 goroutine 21 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func3() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:183 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:179 +0x196 goroutine 22 [sleep]: time.Sleep(0xdf8475800) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func4() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:193 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:192 +0x216 goroutine 23 [sleep]: time.Sleep(0x34630b8a000) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func5() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:207 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:206 +0x296 goroutine 24 [sleep]: time.Sleep(0x983fd97a37254) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func6() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:221 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:220 +0x316 goroutine 25 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func1() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:156 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:152 +0x98 goroutine 26 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func2() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:170 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:166 +0x116 goroutine 27 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func3() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:183 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:179 +0x196 goroutine 28 [sleep]: time.Sleep(0xdf8475800) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func4() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:193 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:192 +0x216 goroutine 29 [sleep]: time.Sleep(0x34630b8a000) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func5() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:207 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:206 +0x296 goroutine 30 [sleep]: time.Sleep(0x983fd97a37254) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func6() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:221 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:220 +0x316 goroutine 31 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func1() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:156 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:152 +0x98 goroutine 32 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func2() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:170 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:166 +0x116 goroutine 33 [select]: github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func3() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:183 +0xd1 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:179 +0x196 goroutine 34 [sleep]: time.Sleep(0xdf8475800) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func4() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:193 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:192 +0x216 goroutine 35 [sleep]: time.Sleep(0x34630b8a000) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func5() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:207 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:206 +0x296 goroutine 36 [sleep]: time.Sleep(0x983fd97a37254) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init.func6() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:221 +0x7e github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/consumer.(*statsItemSet).init D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/consumer/statistics.go:220 +0x316 goroutine 37 [sleep]: time.Sleep(0x2540be400) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).Start.func1.1() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:301 +0x52 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).Start.func1 D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:297 +0x1aa goroutine 38 [select]: github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).Start.func1.2() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:331 +0xf3 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).Start.func1 D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:320 +0x225 goroutine 39 [sleep]: time.Sleep(0x3b9aca00) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).Start.func1.3() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:349 +0x65 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).Start.func1 D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:343 +0x2a5 goroutine 40 [sleep]: time.Sleep(0x2540be400) D:/Develop/Go/src/runtime/time.go:194 +0x133 github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).Start.func1.4() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:381 +0x69 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).Start.func1 D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:368 +0x325 goroutine 41 [select]: github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).Start.func1.5() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:403 +0xda github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/internal.(*rmqClient).Start.func1 D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/client.go:399 +0x3a5 goroutine 50 [IO wait]: internal/poll.runtime_pollWait(0x25f54665a98, 0x72) D:/Develop/Go/src/runtime/netpoll.go:302 +0x89 internal/poll.(*pollDesc).wait(0x30000?, 0xc0000b0800?, 0x0) D:/Develop/Go/src/internal/poll/fd_poll_runtime.go:83 +0x32 internal/poll.execIO(0xc00012b698, 0x3871c8) D:/Develop/Go/src/internal/poll/fd_windows.go:175 +0xe5 internal/poll.(*FD).Read(0xc00012b680, {0xc0000a2098, 0x4, 0x4}) D:/Develop/Go/src/internal/poll/fd_windows.go:441 +0x25f net.(*netFD).Read(0xc00012b680, {0xc0000a2098?, 0xc00008c060?, 0x0?}) D:/Develop/Go/src/net/fd_posix.go:55 +0x29 net.(*conn).Read(0xc000306008, {0xc0000a2098?, 0x2b71b5?, 0xc0000a2098?}) D:/Develop/Go/src/net/net.go:183 +0x45 io.ReadAtLeast({0x3db080, 0xc00030a080}, {0xc0000a2098, 0x4, 0x4}, 0x4) D:/Develop/Go/src/io/io.go:331 +0x9a io.ReadFull(...) D:/Develop/Go/src/io/io.go:350 github.com/apache/rocketmq-client-go/v2/internal/remote.(*remotingClient).receiveResponse(0x0?, 0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/remote/remote_client.go:158 +0x113 github.com/apache/rocketmq-client-go/v2/internal/remote.(*remotingClient).connect.func1() D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/remote/remote_client.go:133 +0x25 github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0x0?) D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/primitive/base.go:96 +0x3e created by github.com/apache/rocketmq-client-go/v2/internal/remote.(*remotingClient).connect D:/Golang/pkg/mod/github.com/apache/rocketmq-client-go/[email protected]/internal/remote/remote_client.go:132 +0x265 exit status 2 **FEATURE REQUEST** 1. Please describe the feature you are requesting. 2. Provide any additional detail on your proposed use case for this feature. 2. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue? 4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task: - [sub-task1-issue-number](example_sub_issue1_link_here): sub-task1 description here, - [sub-task2-issue-number](example_sub_issue2_link_here): sub-task2 description here, - ... -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
