Investigate RocketMQ Increased goroutine Count

[halspang]

RocketMQ had to be removed from the 1.6 release because importing caused an increase of ~30 goroutines. This was seen as too large an increase and should be investigated before we can include it in the dapr runtime.

[halspang]

@x-shadow-man, I saw you added RocketMQ, would you be a good person to investigate this as well?

[dapr-bot]

This issue has been automatically marked as stale because it has not had activity in the last 60 days. It will be closed in the next 7 days unless it is tagged (pinned, good first issue, help wanted or triaged/resolved) or other activity occurs. Thank you for your contributions.

[dapr-bot]

This issue has been automatically closed because it has not had activity in the last 67 days. If this issue is still valid, please ping a maintainer and ask them to label it as pinned, good first issue, help wanted or triaged/resolved. Thank you for your contributions.

[yaron2]

@shubham1172 did you end up taking a look at this?

[shubham1172]

No @yaron2, but I can track this going forward. Well, this looks like the root cause apache/rocketmq-client-go#678

[shubham1172]

/assign

[shubham1172]

This issue has been fixed with the latest prelease by apache/rocketmq-client-go#678. Here is a small example, the latest version does not cause any jump in go-routines.

Baseline

package main

import (
	"fmt"
	"runtime"
)

func main() {
	fmt.Printf("Number of goroutines: %d", runtime.NumGoroutine())
}

Number of goroutines: 1

RocketMQ v2.1.0

go get github.com/apache/rocketmq-client-go/v2@v2.1.0

package main

import (
	"fmt"
	"runtime"

	mqc "github.com/apache/rocketmq-client-go/v2/consumer"
)

func main() {
	_ = make(map[string]mqc.MessageSelector)
	fmt.Printf("Number of goroutines: %d", runtime.NumGoroutine())
}

Number of goroutines: 31

RocketMQ v2.1.1-rc2

go get github.com/apache/rocketmq-client-go/v2@v2.1.1-rc2

Same code as above.

Number of goroutines: 1

However, the latest version is still a pre-release - v2.1.1-rc2. Given that our Rocket MQ component will be alpha, it might be okay to use this (/cc @halspang). What do the maintainers think?

[yaron2]

Let's bring this back in 1.8.

[yaron2]

Closed via dapr/components-contrib#1740.

[yaron2]

Reopening as not in daprd yet.