pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java (6 lines): - line 239: // TODO: Add unit tests cover it. - line 1219: // TODO: Add unit tests cover it. - line 1243: // TODO: Add unit tests cover it. - line 1258: // TODO: Add unit tests cover it. - line 1268: // TODO: Add unit tests cover it. - line 1277: // TODO: Add unit tests cover it. tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexBlockImpl.java (5 lines): - line 293: // TODO Auto-generated method stub - line 299: // TODO Auto-generated method stub - line 305: // TODO Auto-generated method stub - line 316: // TODO Auto-generated method stub - line 322: // TODO Auto-generated method stub pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java (4 lines): - line 251: // TODO: Create compaction strategy from topic policy when exposing strategic compaction to users. - line 2018: // TODO regarding the topic level policies, it will be deleted at a seperate PR. - line 3239: * TODO Create a seperated PR to fix it. - line 3597: // TODO: support this method with a customized managed ledger implementation pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerImpl.java (3 lines): - line 427: // TODO: update broker load metrics using getLocalData - line 438: // TODO: consider excluding the bundles that are in the process of split. - line 631: // TODO: We may need to revisit this error case. pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/SimpleResourceUnit.java (3 lines): - line 50: // TODO Auto-generated method stub - line 56: // TODO Auto-generated method stub - line 62: // TODO Auto-generated method stub pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/PulsarResourceDescription.java (3 lines): - line 74: // TODO Auto-generated method stub - line 80: // TODO Auto-generated method stub - line 86: // TODO Auto-generated method stub pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java (3 lines): - line 1521: // TODO: Refactor code to support other than default bookkeeper based storage class - line 1945: // TODO figure out how to handle errors from function worker service - line 1962: // TODO: using provider to initialize the packages management service. pulsar-common/src/main/proto/PulsarApi.proto (2 lines): - line 410: // TODO - Remove original_principal, original_auth_data, original_auth_method - line 439: // TODO - Remove original_principal, original_auth_data, original_auth_method pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java (2 lines): - line 561: // TODO: correctly implement function version and id - line 675: // TODO: correctly implement function version and id pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeUtils.java (2 lines): - line 443: // TODO:- Find a platform independent way of controlling memory for a python application - line 458: // TODO: for now only Java function context exposed pulsar admin, so python/go no need to pass this argument pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/PulsarServiceUnit.java (2 lines): - line 42: // TODO add JSON parser here to get the following information - line 64: // TODO Auto-generated method stub pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java (2 lines): - line 746: // TODO: this should become BookKeeper URL and it should be fetched from Pulsar client. - line 1269: // TODO depecreate getstatus pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java (2 lines): - line 1738: //TODO add topicName in properties? - line 2592: // replication-cluster and still own the bundle. That can cause data-loss for TODO: git-issue pulsar-functions/instance/src/main/python/state_context.py (2 lines): - line 117: # TODO: make number of table ranges configurable - line 123: # TODO: make number of table ranges configurable pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/impl/AutoFailoverPolicyFactory.java (1 line): - line 31: // TODO: Add more policy types when needed pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckStore.java (1 line): - line 148: //TODO can control the number of entry to read pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java (1 line): - line 220: // TODO refactor the code for externally managed. pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java (1 line): - line 96: // TODO depecreate getstatus pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data/TwitterRecord.java (1 line): - line 41: // TODO: Could use user or tweet ID as key here pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java (1 line): - line 129: // TODO: redeliver epoch link https://github.com/apache/pulsar/issues/13690 pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionBuffer.java (1 line): - line 139: * TODO: To avoid broker oom, we will load the aborted txn from snapshot on demand. pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicUtils.java (1 line): - line 59: // TODO: redeliver epoch link https://github.com/apache/pulsar/issues/13690 pulsar-common/src/main/java/org/apache/pulsar/client/api/MessageIdAdv.java (1 line): - line 117: // TODO: Correct the following compare logics, see https://github.com/apache/pulsar/pull/18981 pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionCommon.java (1 line): - line 81: // TODO:- Fix this. pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java (1 line): - line 106: // TODO:- Figure out the metrics story for connectors pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionActioner.java (1 line): - line 216: // TODO: set correct function id and version when features implemented pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PulsarCompactorSubscription.java (1 line): - line 97: // TODO: cut consumer connection on markDeleteFailed pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java (1 line): - line 305: // TODO: should flush for each batch. not wait for a time for acked all. pulsar-common/src/main/java/org/apache/pulsar/common/tls/InetAddressUtils.java (1 line): - line 48: private static final Pattern IPV4_MAPPED_IPV6_PATTERN = // TODO does not allow for redundant leading zeros pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/reader/AbstractMultiVersionReader.java (1 line): - line 114: * TODO: think about how to make this async. pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ProducerBuilderFactory.java (1 line): - line 93: // TODO: address this inconsistency. pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/filter/BrokerMaxTopicCountFilter.java (1 line): - line 51: // TODO: The broker load data might be delayed, so the max topic check might not accurate. pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/FunctionResultRouter.java (1 line): - line 60: // TODO: the message key routing is problematic at this moment. pulsar-client-messagecrypto-bc/src/main/java/org/apache/pulsar/client/impl/crypto/MessageCryptoBc.java (1 line): - line 448: // TODO: Replace random with counter and periodic refreshing based on timer/counter value pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiMessageIdImpl.java (1 line): - line 41: // TODO: Add support for Serialization and Deserialization managed-ledger/src/main/java/org/apache/bookkeeper/mledger/LedgerOffloader.java (1 line): - line 90: // TODO: improve the user metadata in subsequent changes pulsar-functions/instance/src/main/python/contextimpl.py (1 line): - line 229: # TODO: Make it thread safe pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecord.java (1 line): - line 62: // TODO: support decoding KMS data here... should be fairly simple pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/models/TopKBundles.java (1 line): - line 81: // TODO: do not filter system topic while shedding pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicListWatcher.java (1 line): - line 52: // TODO maintain the value based on updates from broker and warn the user if inconsistent with hash from polling pulsar-functions/instance/src/main/python/python_instance.py (1 line): - line 542: # TODO: support other schemas: PROTOBUF, PROTOBUF_NATIVE, and KeyValue pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java (1 line): - line 276: // TODO: Check message backlog and fail if backlog too large. pulsar-common/src/main/java/org/apache/pulsar/common/tls/TlsHostnameVerifier.java (1 line): - line 289: // TODO ASN.1 DER encoded form pulsar-common/src/main/java/org/apache/pulsar/common/policies/impl/NamespaceIsolationPolicyImpl.java (1 line): - line 107: // TODO Auto-generated method stub pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/OpenIDProviderMetadataCache.java (1 line): - line 108: // TODO URI's normalization likely follows RFC2396 (library doesn't say so explicitly), whereas the spec pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/SimpleResourceAllocationPolicies.java (1 line): - line 43: // TODO: need to apply the policies to the assignment and decide whether it can be assigned or not pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscription.java (1 line): - line 261: return CompletableFuture.completedFuture(null); // TODO: throw exception pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java (1 line): - line 296: // TODO: There are problems with this solution since AsyncHttpClient already contains logic to retry requests. managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java (1 line): - line 2078: // TODO: improve this to load ledger offloader by driver name recorded in metadata pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java (1 line): - line 506: // TODO: cut consumer connection on markDeleteFailed pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java (1 line): - line 97: // TODO deprecate getstatus pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerWrapper.java (1 line): - line 104: // TODO: Add namespace bundle affinity support. pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java (1 line): - line 160: // TODO message validation pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumersClassic.java (1 line): - line 1001: // TODO: We want to pass a sticky key hash as a third argument to guarantee the order of the messages pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java (1 line): - line 814: // TODO could be a race condition here if functionMetaDataTailer pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/dlog/DLOutputStream.java (1 line): - line 50: // TODO: avoid array copy by using the new bytebuf api pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java (1 line): - line 1152: // TODO: We want to pass a sticky key hash as a third argument to guarantee the order of the messages pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java (1 line): - line 1854: //TODO: check parent consumer here pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/BKStateStoreImpl.java (1 line): - line 87: // TODO: this can be optimized with a batch operation. pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerManagerFactory.java (1 line): - line 103: // TODO: format pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java (1 line): - line 140: // TODO: Add some way to prevent changes in between the time the consumer is added and the