cpp/source/client/ClientManagerImpl.cpp (4 lines):
	- line 306: // TODO: Would this leak some memory?
	- line 550: // TODO: handle other cases.
	- line 884: // TODO: NACK it immediately
	- line 1000: // TODO: Use capture by move and pass-by-value paradigm when C++ 14 is available.


cpp/source/client/RpcClientImpl.cpp (2 lines):
	- line 40: // TODO: execute orphan callback in event-loop thread?
	- line 51: // TODO: execute orphan callback in event-loop thread?


cpp/source/rocketmq/ProducerImpl.cpp (2 lines):
	- line 46: // TODO: initialize client_config_ and fault_strategy_
	- line 644: // TODO: propagate error_code to caller


csharp/rocketmq-client-csharp/Endpoints.cs (2 lines):
	- line 79: // TODO: Multiple addresses has not been supported yet.
	- line 137: // TODO: Support multiple addresses.


cpp/source/rocketmq/ClientImpl.cpp (1 line):
	- line 522: // TODO: Use capture by move if C++14 is possible


nodejs/src/client/BaseClient.ts (1 line):
	- line 289: // FIXME: java.lang.IllegalArgumentException: No enum constant org.apache.rocketmq.remoting.protocol.LanguageCode.nodejs


golang/message_id_codec.go (1 line):
	- line 116: // TODO Implement System.nanoTime() in golang, see https://github.com/golang/go/issues/16658


cpp/source/rocketmq/PushConsumerImpl.cpp (1 line):
	- line 331: // TODO: remove it from current assignment such that a second attempt will be made again in the next round.


csharp/rocketmq-client-csharp/PublishingLoadBalancer.cs (1 line):
	- line 56: // TODO: use SipHash24 algorithm


csharp/rocketmq-client-csharp/Session.cs (1 line):
	- line 59: // TODO: Test concurrency.


rust/src/producer.rs (1 line):
	- line 332: // TODO: use a converter trait From or TryFrom


rust/src/session.rs (1 line):
	- line 206: // TODO tls config


cpp/source/client/include/ClientConfig.h (1 line):
	- line 55: // TODO: use std::chrono::milliseconds


rust/src/client.rs (1 line):
	- line 881: // TODO use countdown latch instead sleeping


cpp/source/client/include/TelemetryBidiReactor.h (1 line):
	- line 107: * TODO: move buffered commands to a shared container, which may survive


cpp/source/base/UtilAll.cpp (1 line):
	- line 104: // TODO: running out of memory


golang/conn.go (1 line):
	- line 113: // TODO get requestID in header


php/protocol/apache/rocketmq/v2/definition.proto (1 line):
	- line 181: // TODO: define semantics of invalid-digest-when-broadcasting.


golang/client.go (1 line):
	- line 668: // TODO get stack


cpp/source/client/include/SessionImpl.h (1 line):
	- line 39: // TODO: use unique_ptr


nodejs/src/consumer/Consumer.ts (1 line):
	- line 92: // FIXME: handle fail ack


cpp/source/client/include/ClientManagerImpl.h (1 line):
	- line 47: * TODO: Make it protected such that instantiating it through ClientManagerFactory only, achieving Singleton


cpp/source/base/MixAll.cpp (1 line):
	- line 204: * TODO: std::localtime is not thread-safe, output, as a result, may be less reliable in highly contending


cpp/source/stats/OpencensusExporter.cpp (1 line):
	- line 81: // TODO: Opencensus provides end-timestamp of the statistics conducted whilst OpenTelemetry requires