qiulin

Results 10 issues of qiulin

When I use context.WithTimeout(ctx, time.Duration) with fsm.Event(ctx, ...) like: ```go Callbacks{ "enter_end": func(ctx context.Context, e *Event) { go func() {

#### Description (what this PR does / why we need it): feat(registry): add registry nacosv2 to support nacos-sdk-go/v2 #### Which issue(s) this PR fixes (resolves / be part of): ####...

size:XL

My use case is reading kafka message using segment-io kafka driver and publishing to watermill using GoChannel. One day I got a kafka topic blocking. After read watermill code, I...

…pt uses should be passed using the KEYS array, and KEYS should not be in expression

Description Reference issue Parttial fixes https://github.com/pion/mediadevices/issues/347, remove inline function in cpp, which will cause compiling problem when debug

错误信息: ``` {"level":"error","ts":"2024-09-20T10:24:28.846+0800","msg":"[kafka] FetchMessage error: EOF","service_id":"adventure-service-c446ff847-w2sgg","service_name":"adventure-service","version":"release-v5.9.4-202409181503","stacktrace":"github.com/go-kratos/kratos/contrib/log/zap/v2.(*Logger).Log\n\t/go/pkg/mod/github.com/go-kratos/kratos/contrib/log/zap/[email protected]/zap.go:61\ngithub.com/go-kratos/kratos/v2/log.Errorf\n\t/go/pkg/mod/github.com/go-kratos/kratos/[email protected]/log/global.go:103\ngithub.com/tx7do/kratos-transport/broker/kafka.(*kafkaBroker).Subscribe.func1\n\t/go/pkg/mod/github.com/tx7do/kratos-transport/broker/[email protected]/kafka.go:612"} ``` 且消费速度变得很慢: ![image](https://github.com/user-attachments/assets/02a8f177-0414-4d6b-b86a-b7b7b5833874) 后面加了机器恢复。 Kafka 服务端版本 阿里云 Kafka 0.10.2