proto/PulsarApi.proto (2 lines): - line 403: // TODO - Remove original_principal, original_auth_data, original_auth_method - line 431: // TODO - Remove original_principal, original_auth_data, original_auth_method lib/ConsumerImpl.cc (2 lines): - line 1214: // TODO: Need to check if the consumer is ready. Same to all other public methods - line 1436: // TODO Support MAX_REDELIVER_UNACKNOWLEDGED Avoid redelivering too many messages lib/TopicName.cc (2 lines): - line 205: // TODO - for now return empty string if there's any error in format, later think about better error handling - line 248: // TODO: When handling topic name like "xxx-partition-00", it should return -1. lib/ProducerImpl.cc (1 line): - line 792: // TODO maybe we need a loop here to implement CAS for a condition, lib/MessageAndCallbackBatch.cc (1 line): - line 53: // TODO: Store payload as a field and support shrinking lib/ClientConnectionAdaptor.h (1 line): - line 52: // TODO: Implement maxNumberOfRejectedRequestPerConnection like lib/MessageCrypto.cc (1 line): - line 280: // TODO: Replace random with counter and periodic refreshing based on timer/counter value lib/ConsumerImpl.h (1 line): - line 192: // TODO - Convert these functions to lambda when we move to C++11