You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/03/24 09:42:21 UTC
[GitHub] [rocketmq-client-go] kylebjcn opened a new issue #794: [BUG] Run the example 'producer'
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/reflect2@v0.0.0-20180701023420-4b7aa43c6742/unsafe_map.go:112
github.com/json-iterator/go.(*mapEncoder).Encode(0xc000314780, 0xc0000728e0, 0xc0003007e0)
D:/Golang/pkg/mod/github.com/json-iterator/go@v1.1.9/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/go@v1.1.9/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/go@v1.1.9/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/go@v1.1.9/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/go@v1.1.9/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/go@v1.1.9/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/go@v1.1.9/config.go:299 +0xc9 fp=0xc000129908 sp=0xc000129870 pc=0x125ca9
github.com/json-iterator/go.Marshal(...)
D:/Golang/pkg/mod/github.com/json-iterator/go@v1.1.9/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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/v2@v2.1.0/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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org