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


consumer/push_consumer.go (4 lines):
	- line 509: // TODO: optimize
	- line 549: // TODO FQA
	- line 1020: // TODO orderly
	- line 1278: // TODO: add message consumer hook


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


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


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


producer/producer.go (2 lines):
	- line 642: // TODO: checkLocalTransaction
	- line 664: // TODO: check addr


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


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


internal/remote/tcp_conn.go (1 line):
	- line 29: // 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