Path	Lines of Code
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/LedgerOffloader.java	80
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java	3837
pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/OpenIDProviderMetadataCache.java	155
pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java	1759
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerImpl.java	953
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerWrapper.java	110
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/filter/BrokerMaxTopicCountFilter.java	32
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/models/TopKBundles.java	119
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/PulsarResourceDescription.java	80
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/PulsarServiceUnit.java	40
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/SimpleResourceAllocationPolicies.java	87
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/SimpleResourceUnit.java	58
pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java	1456
pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java	699
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java	3094
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscription.java	441
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java	1168
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumersClassic.java	1050
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java	527
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java	1302
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java	3740
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PulsarCompactorSubscription.java	86
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionBuffer.java	33
pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckStore.java	440
pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java	225
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java	338
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicUtils.java	77
pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/impl/AutoFailoverPolicyFactory.java	12
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java	483
pulsar-client-messagecrypto-bc/src/main/java/org/apache/pulsar/client/impl/crypto/MessageCryptoBc.java	427
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java	1176
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java	709
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java	639
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java	2716
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiMessageIdImpl.java	69
pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicListWatcher.java	213
pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/reader/AbstractMultiVersionReader.java	90
pulsar-common/src/main/java/org/apache/pulsar/client/api/MessageIdAdv.java	41
pulsar-common/src/main/java/org/apache/pulsar/common/policies/impl/NamespaceIsolationPolicyImpl.java	132
pulsar-common/src/main/java/org/apache/pulsar/common/tls/InetAddressUtils.java	44
pulsar-common/src/main/java/org/apache/pulsar/common/tls/TlsHostnameVerifier.java	251
pulsar-common/src/main/proto/PulsarApi.proto	928
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/FunctionResultRouter.java	33
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ProducerBuilderFactory.java	146
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/BKStateStoreImpl.java	168
pulsar-functions/instance/src/main/python/contextimpl.py	179
pulsar-functions/instance/src/main/python/python_instance.py	482
pulsar-functions/instance/src/main/python/state_context.py	104
pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java	704
pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeUtils.java	463
pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionCommon.java	354
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionActioner.java	620
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java	773
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/dlog/DLOutputStream.java	41
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java	1601
pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java	260
pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecord.java	57
pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java	126
pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data/TwitterRecord.java	37
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerManagerFactory.java	119
tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexBlockImpl.java	278