plugin/connector/rocketmq/consumer.go (3 lines):
	- line 106: // TODO support offset update
	- line 168: // TODO support manual offset updating
	- line 214: // TODO support manual offset updating


plugin/protocol/cloudevents/cloudevents.go (2 lines):
	- line 76: //TODO implement me
	- line 81: // TODO add when support tcp procotol


runtime/core/protocol/grpc/producer/producer_processor.go (2 lines):
	- line 69: // TODO no ack check, add rate limiter
	- line 276: // TODO use errorgroup instead


plugin/connector/rocketmq/client/rocketmq_consumer.go (1 line):
	- line 151: // TODO consumeTimeout config, currently rocket mq go client doesn't support


runtime/core/protocol/grpc/consumer/message_request.go (1 line):
	- line 177: // TODO need to clone?


runtime/core/protocol/grpc/consumer/message_handler.go (1 line):
	- line 45: // TODO need goroutine safe in []*Request{}