consumer/consumer.go (5 lines):
	- line 873: // TODO: 和java对齐
	- line 876: // TODO: add subversion
	- line 886: // TODO: add computPullFromWhichFilterServer
	- line 924: // TODO: add filter message hook
	- line 952: res, err := dc.client.InvokeSync(context.Background(), brokerAddr, cmd, 3*time.Second) // TODO 超时机制有问题


consumer/push_consumer.go (4 lines):
	- line 507: // TODO: optimize
	- line 547: // TODO FQA
	- line 1015: // TODO orderly
	- line 1269: // TODO: add message consumer hook


internal/remote/remote_client.go (2 lines):
	- line 92: // TODO: merge sync and async model. sync should run on async model by blocking on chan
	- line 242: // TODO: optimize with goroutine pool, https://github.com/apache/rocketmq-client-go/v2/issues/307


consumer/option.go (2 lines):
	- line 104: // TODO traceDispatcher
	- line 257: // TODO: use retry middleware instead


producer/producer.go (2 lines):
	- line 639: // TODO: checkLocalTransaction
	- line 661: // TODO: check addr


admin/admin.go (2 lines):
	- line 44: // TODO: move outdated context to ctx
	- line 158: // TODO: another implementation like sarama, without brokerAddr as input


consumer/pull_consumer.go (2 lines):
	- line 431: // TODO: add timeout limit
	- line 432: // TODO: add hook


internal/route.go (1 line):
	- line 50: // TODO optimize


internal/remote/tcp_conn.go (1 line):
	- line 28: // TODO: Adding TCP Connections Pool, https://github.com/apache/rocketmq-client-go/v2/issues/298


internal/client.go (1 line):
	- line 243: // TODO: add namespace support


producer/option.go (1 line):
	- line 94: // TODO: use retry middleware instead