apache / pulsar
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 2,759 files with 313,980 lines of code.
    • 33 files changed more than 100 times (68,380 lines of code)
    • 59 files changed 51-100 times (37,414 lines of code)
    • 186 files changed 21-50 times (58,511 lines of code)
    • 721 files changed 6-20 times (88,823 lines of code)
    • 1,760 files changed 1-5 times (60,852 lines of code)
21% | 11% | 18% | 28% | 19%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 2,759 files with 313,980 lines of code.
    • 84 files changed by more than 25 contributors (97,431 lines of code)
    • 296 files changed by 11-25 contributors (82,692 lines of code)
    • 480 files changed by 6-10 contributors (56,897 lines of code)
    • 1,576 files changed by 2-5 contributors (64,698 lines of code)
    • 323 files changed by 1 contributor (12,262 lines of code)
31% | 26% | 18% | 20% | 3%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, xml, yaml, md, py, sh, txt, go, proto, json, gitignore, tf, cmd, properties, ini, mod, html, cfg, patch, groovy, js, tfvars, svg, avsc, rdf, lua
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java22% | 12% | 18% | 27% | 18%
proto51% | 12% | 6% | 14% | 15%
py0% | 24% | 21% | 27% | 27%
go0% | 0% | 12% | 54% | 33%
xml0% | 0% | 13% | 53% | 32%
yaml0% | 0% | 0% | 49% | 50%
tf0% | 0% | 0% | 0% | 100%
lua0% | 0% | 0% | 0% | 100%
tfvars0% | 0% | 0% | 0% | 100%
rdf0% | 0% | 0% | 0% | 100%
cfg0% | 0% | 0% | 0% | 100%
js0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
pulsar-broker35% | 14% | 16% | 18% | 14%
pulsar-client30% | 6% | 24% | 24% | 15%
managed-ledger45% | 10% | 10% | 21% | 10%
pulsar-client-tools39% | 10% | 24% | 16% | 9%
pulsar-broker-common32% | 6% | 15% | 32% | 13%
pulsar-client-admin24% | 23% | 18% | 32% | 1%
pulsar-functions4% | 25% | 26% | 28% | 14%
pulsar-common4% | 7% | 12% | 39% | 35%
pulsar-proxy0% | 56% | 25% | 10% | 8%
pulsar-testclient0% | 25% | 31% | 34% | 8%
pulsar-websocket0% | 12% | 50% | 14% | 22%
pulsar-client-api0% | 2% | 25% | 44% | 27%
pulsar-metadata0% | 0% | 12% | 68% | 18%
pulsar-io0% | 0% | 6% | 47% | 46%
pulsar-client-admin-api0% | 0% | 19% | 21% | 58%
testmocks0% | 0% | 42% | 43% | 13%
tiered-storage0% | 0% | 21% | 56% | 22%
pulsar-transaction0% | 0% | 36% | 38% | 25%
pulsar-function-go0% | 0% | 12% | 54% | 33%
src0% | 0% | 60% | 24% | 15%
pulsar-client-auth-athenz0% | 0% | 86% | 0% | 13%
distribution0% | 0% | 22% | 39% | 37%
pulsar-package-management0% | 0% | 0% | 47% | 52%
pulsar-client-messagecrypto-bc0% | 0% | 0% | 99% | <1%
pulsar-broker-auth-sasl0% | 0% | 0% | 70% | 29%
pulsar-broker-auth-oidc0% | 0% | 0% | 40% | 59%
pulsar-client-auth-sasl0% | 0% | 0% | 72% | 27%
pulsar-opentelemetry0% | 0% | 0% | 93% | 6%
docker0% | 0% | 0% | 71% | 28%
deployment0% | 0% | 0% | 33% | 66%
pulsar-broker-auth-athenz0% | 0% | 0% | 99% | <1%
conf0% | 0% | 0% | 42% | 57%
buildtools0% | 0% | 0% | 100% | 0%
pulsar-config-validation0% | 0% | 0% | 0% | 100%
structured-event-log0% | 0% | 0% | 0% | 100%
pulsar-cli-utils0% | 0% | 0% | 0% | 100%
microbench0% | 0% | 0% | 0% | 100%
pulsar-client-tools-api0% | 0% | 0% | 0% | 100%
bouncy-castle0% | 0% | 0% | 0% | 100%
wireshark0% | 0% | 0% | 0% | 100%
jclouds-shaded0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
PersistentTopic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
 3740 188 2017-06-23 2025-05-03 436 110 mmerli@apache.org lhotari@users.noreply.githu...
ServiceConfiguration.java
in pulsar-broker-common/src/main/java/org/apache/pulsar/broker
 3475 24 2017-06-23 2025-05-06 384 111 mmerli@apache.org daojun@apache.org
BrokerService.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 3094 156 2017-06-23 2025-05-06 360 104 mmerli@apache.org daojun@apache.org
PersistentTopicsBase.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl
 4990 160 2018-02-13 2025-05-03 333 101 cckellogg@gmail.com lhotari@users.noreply.githu...
ServerCnx.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 3241 128 2017-06-23 2025-03-14 312 94 mmerli@apache.org baodi@apache.org
PulsarService.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker
 1759 96 2017-06-23 2025-04-24 288 80 mmerli@apache.org lhotari@users.noreply.githu...
ConsumerImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 2716 123 2017-06-23 2025-04-14 274 95 mmerli@apache.org lhotari@users.noreply.githu...
ManagedLedgerImpl.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl
 3837 218 2016-10-06 2025-05-03 273 82 siddharth.boobna@gmail.com lhotari@users.noreply.githu...
ManagedCursorImpl.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl
 3144 166 2016-09-26 2025-05-07 220 64 rajan.sjsu@gmail.com lhotari@users.noreply.githu...
NamespacesBase.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl
 2569 121 2018-02-13 2025-05-03 214 81 cckellogg@gmail.com lhotari@users.noreply.githu...
PersistentTopics.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2
 4831 143 2018-02-13 2025-02-06 197 76 cckellogg@gmail.com zike@apache.org
ProducerImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 2134 122 2017-06-23 2025-05-07 182 67 mmerli@apache.org yubiao.feng@streamnative.io
PersistentSubscription.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
 1302 79 2017-06-23 2025-03-24 175 55 mmerli@apache.org baodi@apache.org
NonPersistentTopic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent
 1024 70 2017-07-28 2025-03-17 174 77 rdhabalia@apache.org 36988878+3pacccccc@users.no...
NamespaceService.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace
 1456 68 2017-06-23 2025-05-03 156 58 mmerli@apache.org lhotari@users.noreply.githu...
AdminResource.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin
 837 67 2017-06-23 2025-04-25 155 62 mmerli@apache.org yubiao.feng@streamnative.io
PersistentDispatcherMultipleConsumers.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
 1168 89 2017-06-23 2025-03-28 154 46 mmerli@apache.org 36988878+3pacccccc@users.no...
PulsarClientImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 1119 69 2017-06-23 2025-05-03 150 60 mmerli@apache.org lhotari@users.noreply.githu...
CmdTopics.java
in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli
 2527 138 2018-04-27 2025-02-25 148 60 mmerli@apache.org rdhabalia@apache.org
MultiTopicsConsumerImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 1405 69 2018-04-04 2025-05-03 145 64 zhaijia03@gmail.com lhotari@users.noreply.githu...
AbstractTopic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 1176 103 2019-06-02 2025-05-07 144 61 ke.like@outlook.com yubiao.feng@streamnative.io
CmdFunctions.java
in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli
 1176 47 2018-03-06 2025-01-24 141 33 guosijie@gmail.com scjiangpengcheng@gmail.com
JavaInstanceRunnable.java
in pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance
 963 30 2018-02-26 2025-04-14 139 37 sanjeevrk@gmail.com scjiangpengcheng@gmail.com
Consumer.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 1024 72 2017-06-23 2025-04-14 135 61 mmerli@apache.org lhotari@users.noreply.githu...
Namespaces.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2
 2968 149 2018-02-13 2025-02-06 132 63 cckellogg@gmail.com zike@apache.org
CmdNamespaces.java
in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli
 2346 144 2017-06-23 2024-10-08 126 58 mmerli@apache.org lhotari@users.noreply.githu...
ClientCnx.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 1279 83 2017-06-23 2025-04-17 125 44 mmerli@apache.org yubiao.feng@streamnative.io
TopicsImpl.java
in pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal
 2397 310 2018-04-27 2024-08-07 118 52 mmerli@apache.org lhotari@users.noreply.githu...
proto
PulsarApi.proto
in pulsar-common/src/main/proto
 928 - 2016-10-11 2025-02-21 117 47 rajan.sjsu@gmail.com yubiao.feng@streamnative.io
PulsarWebResource.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/web
 1107 73 2017-06-23 2025-05-03 110 50 mmerli@apache.org lhotari@users.noreply.githu...
ConsumerBase.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 1092 101 2017-06-23 2025-02-18 109 53 mmerli@apache.org 52550727+thetumbled@users.n...
FunctionsImpl.java
in pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api
 654 11 2018-03-05 2024-03-04 105 24 guosijie@gmail.com lhotari@users.noreply.githu...
ModularLoadManagerImpl.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl
 902 41 2017-06-23 2025-02-17 105 44 mmerli@apache.org lhotari@users.noreply.githu...
FunctionRuntimeManager.java
in pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker
 773 37 2018-01-09 2024-03-04 98 25 guosijie@gmail.com lhotari@users.noreply.githu...
Commands.java
in pulsar-common/src/main/java/org/apache/pulsar/common/protocol
 1733 157 2019-06-06 2025-04-09 95 45 kim.christian.gaarder@gmail... yubiao.feng@streamnative.io
Topic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 181 25 2017-06-23 2025-02-21 91 48 mmerli@apache.org yubiao.feng@streamnative.io
PersistentDispatcherSingleActiveConsumer.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
 501 30 2017-06-23 2025-02-25 91 42 mmerli@apache.org lhotari@users.noreply.githu...
NamespacesImpl.java
in pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal
 1689 308 2017-06-23 2024-10-10 91 38 mmerli@apache.org technoboy@apache.org
CmdSinks.java
in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli
 709 26 2018-05-08 2024-05-08 87 28 lucperkins@gmail.com nodeces@gmail.com
PersistentTopics.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1
 1063 39 2018-02-13 2023-11-30 86 47 cckellogg@gmail.com crossoverjie@gmail.com
Namespaces.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1
 1651 81 2018-02-13 2023-10-26 84 40 cckellogg@gmail.com 95091480+vraulji567@users.n...
Producer.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 740 75 2017-06-23 2025-04-14 83 39 mmerli@apache.org lhotari@users.noreply.githu...
PersistentStickyKeyDispatcherMultipleConsumers.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
 527 28 2019-04-22 2025-02-11 82 27 penghui@apache.org 48884472+guan46@users.norep...
ConsumerBuilderImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 539 64 2018-02-17 2025-03-21 80 42 mmerli@apache.org baodi@apache.org
ProxyConfiguration.java
in pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server
 879 15 2017-07-11 2025-02-14 80 38 mmerli@apache.org rdhabalia@apache.org
FunctionConfigUtils.java
in pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils
 977 16 2018-02-26 2025-04-14 78 29 sanjeevrk@gmail.com scjiangpengcheng@gmail.com
CmdSources.java
in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli
 639 28 2018-05-08 2024-05-08 77 25 lucperkins@gmail.com nodeces@gmail.com
PerformanceProducer.java
in pulsar-testclient/src/main/java/org/apache/pulsar/testclient
 659 9 2017-06-23 2024-05-02 77 41 mmerli@apache.org crossoverjie@gmail.com
MessageImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 673 68 2017-06-23 2025-02-17 77 38 mmerli@apache.org 55571188+liangyepianzhou@us...
ManagedLedgerFactoryImpl.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl
 1272 48 2017-03-24 2025-01-29 77 36 mmerli@apache.org lhotari@users.noreply.githu...
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
ServiceConfiguration.java
in pulsar-broker-common/src/main/java/org/apache/pulsar/broker
 3475 24 2017-06-23 2025-05-06 384 111 mmerli@apache.org daojun@apache.org
PersistentTopic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
 3740 188 2017-06-23 2025-05-03 436 110 mmerli@apache.org lhotari@users.noreply.githu...
BrokerService.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 3094 156 2017-06-23 2025-05-06 360 104 mmerli@apache.org daojun@apache.org
PersistentTopicsBase.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl
 4990 160 2018-02-13 2025-05-03 333 101 cckellogg@gmail.com lhotari@users.noreply.githu...
ConsumerImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 2716 123 2017-06-23 2025-04-14 274 95 mmerli@apache.org lhotari@users.noreply.githu...
ServerCnx.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 3241 128 2017-06-23 2025-03-14 312 94 mmerli@apache.org baodi@apache.org
ManagedLedgerImpl.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl
 3837 218 2016-10-06 2025-05-03 273 82 siddharth.boobna@gmail.com lhotari@users.noreply.githu...
NamespacesBase.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl
 2569 121 2018-02-13 2025-05-03 214 81 cckellogg@gmail.com lhotari@users.noreply.githu...
PulsarService.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker
 1759 96 2017-06-23 2025-04-24 288 80 mmerli@apache.org lhotari@users.noreply.githu...
NonPersistentTopic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent
 1024 70 2017-07-28 2025-03-17 174 77 rdhabalia@apache.org 36988878+3pacccccc@users.no...
PersistentTopics.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2
 4831 143 2018-02-13 2025-02-06 197 76 cckellogg@gmail.com zike@apache.org
ProducerImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 2134 122 2017-06-23 2025-05-07 182 67 mmerli@apache.org yubiao.feng@streamnative.io
ManagedCursorImpl.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl
 3144 166 2016-09-26 2025-05-07 220 64 rajan.sjsu@gmail.com lhotari@users.noreply.githu...
MultiTopicsConsumerImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 1405 69 2018-04-04 2025-05-03 145 64 zhaijia03@gmail.com lhotari@users.noreply.githu...
Namespaces.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2
 2968 149 2018-02-13 2025-02-06 132 63 cckellogg@gmail.com zike@apache.org
AdminResource.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin
 837 67 2017-06-23 2025-04-25 155 62 mmerli@apache.org yubiao.feng@streamnative.io
AbstractTopic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 1176 103 2019-06-02 2025-05-07 144 61 ke.like@outlook.com yubiao.feng@streamnative.io
Consumer.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 1024 72 2017-06-23 2025-04-14 135 61 mmerli@apache.org lhotari@users.noreply.githu...
PulsarClientImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 1119 69 2017-06-23 2025-05-03 150 60 mmerli@apache.org lhotari@users.noreply.githu...
CmdTopics.java
in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli
 2527 138 2018-04-27 2025-02-25 148 60 mmerli@apache.org rdhabalia@apache.org
NamespaceService.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace
 1456 68 2017-06-23 2025-05-03 156 58 mmerli@apache.org lhotari@users.noreply.githu...
CmdNamespaces.java
in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli
 2346 144 2017-06-23 2024-10-08 126 58 mmerli@apache.org lhotari@users.noreply.githu...
PersistentSubscription.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
 1302 79 2017-06-23 2025-03-24 175 55 mmerli@apache.org baodi@apache.org
ConsumerBase.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 1092 101 2017-06-23 2025-02-18 109 53 mmerli@apache.org 52550727+thetumbled@users.n...
TopicsImpl.java
in pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal
 2397 310 2018-04-27 2024-08-07 118 52 mmerli@apache.org lhotari@users.noreply.githu...
PulsarWebResource.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/web
 1107 73 2017-06-23 2025-05-03 110 50 mmerli@apache.org lhotari@users.noreply.githu...
Topic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 181 25 2017-06-23 2025-02-21 91 48 mmerli@apache.org yubiao.feng@streamnative.io
proto
PulsarApi.proto
in pulsar-common/src/main/proto
 928 - 2016-10-11 2025-02-21 117 47 rajan.sjsu@gmail.com yubiao.feng@streamnative.io
PersistentTopics.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1
 1063 39 2018-02-13 2023-11-30 86 47 cckellogg@gmail.com crossoverjie@gmail.com
PersistentDispatcherMultipleConsumers.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
 1168 89 2017-06-23 2025-03-28 154 46 mmerli@apache.org 36988878+3pacccccc@users.no...
Commands.java
in pulsar-common/src/main/java/org/apache/pulsar/common/protocol
 1733 157 2019-06-06 2025-04-09 95 45 kim.christian.gaarder@gmail... yubiao.feng@streamnative.io
ClientCnx.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 1279 83 2017-06-23 2025-04-17 125 44 mmerli@apache.org yubiao.feng@streamnative.io
ModularLoadManagerImpl.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl
 902 41 2017-06-23 2025-02-17 105 44 mmerli@apache.org lhotari@users.noreply.githu...
PersistentDispatcherSingleActiveConsumer.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
 501 30 2017-06-23 2025-02-25 91 42 mmerli@apache.org lhotari@users.noreply.githu...
ConsumerBuilderImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 539 64 2018-02-17 2025-03-21 80 42 mmerli@apache.org baodi@apache.org
PerformanceProducer.java
in pulsar-testclient/src/main/java/org/apache/pulsar/testclient
 659 9 2017-06-23 2024-05-02 77 41 mmerli@apache.org crossoverjie@gmail.com
NonPersistentTopics.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2
 599 13 2018-02-13 2024-09-21 61 41 cckellogg@gmail.com xyzinfernity@163.com
Namespaces.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1
 1651 81 2018-02-13 2023-10-26 84 40 cckellogg@gmail.com 95091480+vraulji567@users.n...
ConsumerBuilder.java
in pulsar-client-api/src/main/java/org/apache/pulsar/client/api
 77 - 2019-01-09 2025-04-24 54 40 mmerli@apache.org xyzinfernity@163.com
Producer.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 740 75 2017-06-23 2025-04-14 83 39 mmerli@apache.org lhotari@users.noreply.githu...
NamespaceStatsAggregator.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus
 510 17 2017-06-23 2025-03-24 68 39 mmerli@apache.org baodi@apache.org
NamespacesImpl.java
in pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal
 1689 308 2017-06-23 2024-10-10 91 38 mmerli@apache.org technoboy@apache.org
ProxyConfiguration.java
in pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server
 879 15 2017-07-11 2025-02-14 80 38 mmerli@apache.org rdhabalia@apache.org
MessageImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 673 68 2017-06-23 2025-02-17 77 38 mmerli@apache.org 55571188+liangyepianzhou@us...
PerformanceConsumer.java
in pulsar-testclient/src/main/java/org/apache/pulsar/testclient
 473 5 2017-06-23 2024-05-02 73 38 mmerli@apache.org crossoverjie@gmail.com
ClientConfigurationData.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf
 395 10 2018-02-24 2024-10-10 57 38 mmerli@apache.org lhotari@users.noreply.githu...
JavaInstanceRunnable.java
in pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance
 963 30 2018-02-26 2025-04-14 139 37 sanjeevrk@gmail.com scjiangpengcheng@gmail.com
ManagedLedgerFactoryImpl.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl
 1272 48 2017-03-24 2025-01-29 77 36 mmerli@apache.org lhotari@users.noreply.githu...
PersistentReplicator.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
 575 39 2017-06-23 2025-03-19 71 36 mmerli@apache.org zhenjiang427@gmail.com
BrokersBase.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl
 478 22 2018-02-13 2025-04-24 63 36 cckellogg@gmail.com lhotari@users.noreply.githu...
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
ProtectedObjectMapper.java
in pulsar-common/src/main/java/org/apache/pulsar/common/util
 349 76 2023-01-13 2023-01-13 1 1 lhotari@users.noreply.githu... lhotari@users.noreply.githu...
OpenTelemetryTopicStats.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/stats
 343 3 2024-05-01 2024-06-27 3 1 dragosvictor@users.noreply.... dragosvictor@users.noreply....
DrainingHashesTracker.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 296 20 2024-10-08 2025-01-16 3 1 lhotari@users.noreply.githu... lhotari@users.noreply.githu...
MetadataStoreTableViewImpl.java
in pulsar-metadata/src/main/java/org/apache/pulsar/metadata/tableview/impl
 283 22 2024-09-20 2025-04-18 2 1 103456639+heesung-sn@users.... 103456639+heesung-sn@users....
DefaultPulsarSslFactory.java
in pulsar-common/src/main/java/org/apache/pulsar/common/util
 276 13 2024-08-20 2024-08-20 1 1 apurvatelang15@gmail.com apurvatelang15@gmail.com
HealthChecker.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 257 12 2025-04-24 2025-04-25 2 1 lhotari@users.noreply.githu... lhotari@users.noreply.githu...
AvgShedder.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl
 250 7 2024-07-11 2024-07-11 1 1 52550727+thetumbled@users.n... 52550727+thetumbled@users.n...
PendingAcksMap.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 249 12 2024-10-08 2024-10-08 1 1 lhotari@users.noreply.githu... lhotari@users.noreply.githu...
ServiceUnitStateTableViewSyncer.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel
 219 12 2024-09-20 2024-09-20 1 1 103456639+heesung-sn@users.... 103456639+heesung-sn@users....
JsonConverter.java
in pulsar-io/http/src/main/java/org/apache/pulsar/io/http
 206 6 2022-10-27 2022-10-27 1 1 cbornet@hotmail.com cbornet@hotmail.com
GeoReplicationProducerImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 189 9 2025-02-21 2025-05-07 2 1 yubiao.feng@streamnative.io yubiao.feng@streamnative.io
Log4j2Event.java
in structured-event-log/src/main/java/org/apache/pulsar/structuredeventlog/log4j2
 165 19 2023-03-09 2023-03-09 1 1 mmerli@apache.org mmerli@apache.org
ConsumerHashAssignmentsSnapshot.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 161 8 2024-10-08 2025-05-03 3 1 lhotari@users.noreply.githu... lhotari@users.noreply.githu...
PatternConsumerUpdateQueue.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
 160 8 2024-07-09 2024-07-09 1 1 yubiao.feng@streamnative.io yubiao.feng@streamnative.io
SplitScheduler.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/scheduler
 144 6 2023-03-14 2023-03-29 2 1 103456639+heesung-sn@users.... 103456639+heesung-sn@users....
KubernetesServiceAccountTokenAuthProvider.java
in pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth
 143 10 2023-04-06 2023-04-06 1 1 mmarshall@apache.org mmarshall@apache.org
FunctionFilePackage.java
in pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils
 141 11 2024-02-26 2024-02-26 1 1 lhotari@users.noreply.githu... lhotari@users.noreply.githu...
OpenTelemetryAttributes.java
in pulsar-opentelemetry/src/main/java/org/apache/pulsar/opentelemetry
 138 - 2024-02-09 2024-07-23 13 1 dragosvictor@users.noreply.... dragosvictor@users.noreply....
FunctionRuntimeCommon.java
in pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils
 136 2 2024-02-26 2024-02-26 1 1 lhotari@users.noreply.githu... lhotari@users.noreply.githu...
DispatchRateLimiterClassicImpl.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
 135 13 2025-02-25 2025-02-25 1 1 lhotari@users.noreply.githu... lhotari@users.noreply.githu...
Bucket.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket
 125 9 2022-11-05 2023-04-21 9 1 zhaocong@apache.org zhaocong@apache.org
PulsarSslConfiguration.java
in pulsar-common/src/main/java/org/apache/pulsar/common/util
 122 1 2024-08-20 2024-08-20 1 1 apurvatelang15@gmail.com apurvatelang15@gmail.com
AsyncTokenBucket.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/qos
 122 12 2023-12-15 2025-02-25 3 1 lhotari@users.noreply.githu... lhotari@users.noreply.githu...
DispatchRateLimiterAsyncTokenBucketImpl.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
 122 13 2025-02-25 2025-02-25 1 1 lhotari@users.noreply.githu... lhotari@users.noreply.githu...
ServiceUnitStateMetadataStoreTableViewImpl.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel
 118 10 2024-09-20 2024-09-20 1 1 103456639+heesung-sn@users.... 103456639+heesung-sn@users....
OpenTelemetryReplicatorStats.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/stats
 116 3 2024-06-25 2024-06-25 1 1 dragosvictor@users.noreply.... dragosvictor@users.noreply....
ProducerCache.java
in pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance
 114 6 2024-06-25 2024-12-17 2 1 lhotari@users.noreply.githu... lhotari@users.noreply.githu...
OpenTelemetryManagedLedgerCacheStats.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger
 113 3 2024-06-26 2024-06-26 1 1 dragosvictor@users.noreply.... dragosvictor@users.noreply....
BucketDelayedMessageIndexStats.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket
 104 9 2023-03-30 2023-03-30 1 1 zhaocong@apache.org zhaocong@apache.org
EntryCountEstimator.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl
 103 3 2025-03-20 2025-03-26 2 1 lhotari@users.noreply.githu... lhotari@users.noreply.githu...
OpenTelemetryConsumerStats.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/stats
 97 3 2024-05-10 2024-06-04 2 1 dragosvictor@users.noreply.... dragosvictor@users.noreply....
PulsarPerfTestTool.java
in pulsar-testclient/src/main/java/org/apache/pulsar/testclient
 96 6 2024-05-02 2024-05-02 1 1 crossoverjie@gmail.com crossoverjie@gmail.com
BrokerVersionFilter.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/filter
 96 2 2023-02-04 2023-07-24 5 1 kwang@apache.org kwang@apache.org
RedirectManager.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/manager
 95 2 2023-04-12 2023-05-22 2 1 kwang@apache.org kwang@apache.org
LoadBalanceResources.java
in pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources
 89 17 2023-10-08 2023-12-05 3 1 houxiaoyu@apache.org houxiaoyu@apache.org
HttpSink.java
in pulsar-io/http/src/main/java/org/apache/pulsar/io/http
 88 4 2022-10-27 2022-10-27 1 1 cbornet@hotmail.com cbornet@hotmail.com
SplitManager.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/manager
 88 5 2023-03-14 2024-05-21 2 1 103456639+heesung-sn@users.... 103456639+heesung-sn@users....
PulsarCompactorSubscription.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
 86 3 2023-06-30 2023-12-29 2 1 zhaocong@apache.org zhaocong@apache.org
MultiTopicConsumerHandler.java
in pulsar-websocket/src/main/java/org/apache/pulsar/websocket
 84 4 2023-11-06 2023-11-06 1 1 technoboy@apache.org technoboy@apache.org
CombinedSegmentDelayedIndexQueue.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket
 79 8 2023-01-17 2023-04-21 3 1 zhaocong@apache.org zhaocong@apache.org
AuthenticationMetricsToken.java
in pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/metrics
 78 4 2024-08-29 2024-08-29 1 1 dragosvictor@users.noreply.... dragosvictor@users.noreply....
ConfigUtils.java
in pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc
 78 6 2023-04-10 2023-04-10 1 1 mmarshall@apache.org mmarshall@apache.org
PersistentTopicAttributes.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 74 1 2024-06-07 2024-06-27 2 1 dragosvictor@users.noreply.... dragosvictor@users.noreply....
RescheduleReadHandler.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
 73 1 2024-10-08 2024-10-10 2 1 lhotari@users.noreply.githu... lhotari@users.noreply.githu...
SplitCounter.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/models
 73 5 2023-02-11 2023-03-14 2 1 103456639+heesung-sn@users.... 103456639+heesung-sn@users....
topicName.go
in pulsar-function-go/pf
 72 3 2020-12-03 2020-12-03 1 1 rxl@apache.org rxl@apache.org
ExtPersistentTopics.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2
 71 1 2022-12-27 2022-12-27 1 1 wander4096@gmail.com wander4096@gmail.com
PackageUrlValidator.java
in pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker
 68 7 2024-03-04 2024-03-04 1 1 lhotari@users.noreply.githu... lhotari@users.noreply.githu...
TopicEventsDispatcher.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
 68 7 2023-02-02 2023-02-02 1 1 8622884+dlg99@users.noreply... 8622884+dlg99@users.noreply...
ExtNonPersistentTopics.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2
 67 1 2022-12-27 2022-12-27 1 1 wander4096@gmail.com wander4096@gmail.com
Correlations

File Size vs. Number of Changes: 2759 points

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java x: 1176 lines of code y: 144 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyHierarchyValue.java x: 54 lines of code y: 5 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java x: 3144 lines of code y: 220 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java x: 260 lines of code y: 16 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/GeoReplicationProducerImpl.java x: 189 lines of code y: 2 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/HandlerState.java x: 70 lines of code y: 9 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java x: 2134 lines of code y: 182 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImplementationBindingImpl.java x: 267 lines of code y: 9 # changes pulsar-common/src/main/java/org/apache/pulsar/client/impl/schema/SchemaInfoImpl.java x: 70 lines of code y: 5 # changes pulsar-common/src/main/java/org/apache/pulsar/client/impl/schema/SchemaUtils.java x: 272 lines of code y: 11 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java x: 3094 lines of code y: 360 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/ObserverGauge.java x: 79 lines of code y: 5 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java x: 3475 lines of code y: 384 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java x: 143 lines of code y: 35 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/NonPersistentTopicStatsImpl.java x: 142 lines of code y: 9 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/AckSetState.java x: 9 lines of code y: 3 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java x: 3837 lines of code y: 273 # changes pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/OpenIDProviderMetadataCache.java x: 155 lines of code y: 4 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java x: 2569 lines of code y: 214 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java x: 4990 lines of code y: 333 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v3/Transactions.java x: 452 lines of code y: 23 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java x: 244 lines of code y: 11 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceEphemeralData.java x: 42 lines of code y: 9 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java x: 1456 lines of code y: 156 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractBaseDispatcher.java x: 403 lines of code y: 67 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsumerHashAssignmentsSnapshot.java x: 161 lines of code y: 3 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/EntryAndMetadata.java x: 92 lines of code y: 5 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java x: 641 lines of code y: 62 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java x: 223 lines of code y: 28 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java x: 3740 lines of code y: 436 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/SystemTopic.java x: 81 lines of code y: 21 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorage.java x: 654 lines of code y: 47 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorageFactory.java x: 12 lines of code y: 7 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java x: 603 lines of code y: 48 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaStorageFactory.java x: 8 lines of code y: 6 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java x: 1107 lines of code y: 110 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java x: 338 lines of code y: 44 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicUtils.java x: 77 lines of code y: 9 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactionServiceFactory.java x: 12 lines of code y: 3 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/PulsarCompactionServiceFactory.java x: 58 lines of code y: 4 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/PulsarTopicCompactionService.java x: 102 lines of code y: 7 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/TopicCompactionService.java x: 18 lines of code y: 4 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ControlledClusterFailover.java x: 210 lines of code y: 10 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java x: 1405 lines of code y: 145 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java x: 596 lines of code y: 42 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java x: 1119 lines of code y: 150 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/FutureUtil.java x: 236 lines of code y: 25 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/URIPreconditions.java x: 41 lines of code y: 3 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/GrowableArrayBlockingQueue.java x: 364 lines of code y: 9 # changes pulsar-io/azure-data-explorer/src/main/java/org/apache/pulsar/io/azuredataexplorer/ADXSink.java x: 246 lines of code y: 2 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSource.java x: 249 lines of code y: 18 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java x: 736 lines of code y: 33 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java x: 699 lines of code y: 14 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedger.java x: 123 lines of code y: 46 # changes managed-ledger/src/main/proto/MLDataFormats.proto x: 134 lines of code y: 20 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageFinder.java x: 124 lines of code y: 13 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HealthChecker.java x: 257 lines of code y: 2 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TenantsBase.java x: 317 lines of code y: 33 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java x: 837 lines of code y: 155 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/BacklogQuota.java x: 32 lines of code y: 7 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java x: 1699 lines of code y: 57 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java x: 1759 lines of code y: 288 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java x: 478 lines of code y: 63 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java x: 77 lines of code y: 54 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ConsumerConfigurationData.java x: 377 lines of code y: 53 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java x: 223 lines of code y: 13 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java x: 539 lines of code y: 16 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/Backoff.java x: 88 lines of code y: 3 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataCacheConfig.java x: 30 lines of code y: 5 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/tableview/impl/MetadataStoreTableViewImpl.java x: 283 lines of code y: 2 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/validator/StructSchemaDataValidator.java x: 65 lines of code y: 6 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericSchemaImpl.java x: 44 lines of code y: 11 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java x: 1279 lines of code y: 125 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java x: 379 lines of code y: 35 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness/IsolatedBookieEnsemblePlacementPolicy.java x: 240 lines of code y: 16 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/MessagePayloadProcessorConfig.java x: 16 lines of code y: 1 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java x: 963 lines of code y: 139 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java x: 164 lines of code y: 56 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSourceConsumerConfig.java x: 20 lines of code y: 5 # changes pulsar-functions/proto/src/main/proto/Function.proto x: 227 lines of code y: 60 # changes pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java x: 977 lines of code y: 78 # changes pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/MessagePayloadProcessorUtils.java x: 65 lines of code y: 1 # changes pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java x: 674 lines of code y: 61 # changes pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/ValidatorUtils.java x: 155 lines of code y: 13 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java x: 1024 lines of code y: 135 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java x: 740 lines of code y: 83 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java x: 2716 lines of code y: 274 # changes pulsar-common/src/main/java/org/apache/pulsar/common/naming/Metadata.java x: 21 lines of code y: 6 # changes testmocks/src/main/java/org/apache/zookeeper/MockZooKeeper.java x: 1034 lines of code y: 22 # changes testmocks/src/main/java/org/apache/zookeeper/MockZooKeeperSession.java x: 334 lines of code y: 8 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/scheduler/TransferShedder.java x: 665 lines of code y: 15 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java x: 52 lines of code y: 27 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java x: 299 lines of code y: 37 # changes pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java x: 1733 lines of code y: 95 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java x: 418 lines of code y: 51 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyClientCnx.java x: 69 lines of code y: 14 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java x: 693 lines of code y: 63 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java x: 506 lines of code y: 32 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscription.java x: 441 lines of code y: 60 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java x: 1168 lines of code y: 154 # changes pulsar-function-go/pf/instance.go x: 622 lines of code y: 28 # changes pulsar-function-go/pf/context.go x: 129 lines of code y: 11 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/Utils.java x: 217 lines of code y: 12 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/json/JsonConverter.java x: 194 lines of code y: 4 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/oxia/OxiaMetadataStore.java x: 273 lines of code y: 9 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryCountEstimator.java x: 103 lines of code y: 2 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSink.java x: 435 lines of code y: 18 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java x: 95 lines of code y: 15 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaBytesSource.java x: 178 lines of code y: 11 # changes pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataTeardown.java x: 228 lines of code y: 16 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/ClientCredentialsFlow.java x: 113 lines of code y: 9 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/PatternMultiTopicsConsumerImpl.java x: 323 lines of code y: 24 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Dispatcher.java x: 99 lines of code y: 32 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java x: 1302 lines of code y: 175 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/AggregatedNamespaceStats.java x: 188 lines of code y: 32 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/AggregatedSubscriptionStats.java x: 41 lines of code y: 16 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/NamespaceStatsAggregator.java x: 510 lines of code y: 68 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TopicStats.java x: 519 lines of code y: 51 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/SubscriptionStats.java x: 52 lines of code y: 18 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java x: 178 lines of code y: 27 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java x: 539 lines of code y: 80 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java x: 575 lines of code y: 71 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java x: 558 lines of code y: 44 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarMetadataEventSynchronizer.java x: 281 lines of code y: 5 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java x: 494 lines of code y: 39 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnedBundle.java x: 89 lines of code y: 17 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java x: 1024 lines of code y: 174 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java x: 294 lines of code y: 36 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageKeyBasedContainer.java x: 98 lines of code y: 16 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java x: 299 lines of code y: 20 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactionRecord.java x: 95 lines of code y: 6 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java x: 3241 lines of code y: 312 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicListService.java x: 202 lines of code y: 9 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ThresholdShedder.java x: 189 lines of code y: 23 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/BatchingConfig.java x: 21 lines of code y: 1 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ProducerBuilderFactory.java x: 146 lines of code y: 2 # changes pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/BatchingUtils.java x: 57 lines of code y: 1 # changes pulsar-common/src/main/java/org/apache/pulsar/common/api/raw/RawMessageImpl.java x: 177 lines of code y: 14 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/DeadLetterPolicy.java x: 23 lines of code y: 10 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/DeadLetterProducerBuilderContext.java x: 7 lines of code y: 1 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/stats/prometheus/PrometheusMetricsServlet.java x: 146 lines of code y: 7 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/PulsarPrometheusMetricsServlet.java x: 153 lines of code y: 6 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsMetricsResource.java x: 66 lines of code y: 8 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/TypedMessageBuilderImpl.java x: 262 lines of code y: 36 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java x: 171 lines of code y: 23 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/GeoPersistentReplicator.java x: 182 lines of code y: 12 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ShadowReplicator.java x: 89 lines of code y: 9 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryImpl.java x: 243 lines of code y: 11 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/LedgerOffloaderFactory.java x: 57 lines of code y: 10 # changes tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/JCloudLedgerOffloaderFactory.java x: 47 lines of code y: 11 # changes tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreManagedLedgerOffloader.java x: 636 lines of code y: 31 # changes microbench/src/main/java/org/apache/pulsar/broker/qos/AsyncTokenBucketBenchmark.java x: 55 lines of code y: 3 # changes microbench/src/main/java/org/apache/pulsar/broker/qos/DefaultMonotonicClockBenchmark.java x: 42 lines of code y: 1 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/qos/AsyncTokenBucket.java x: 122 lines of code y: 3 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/qos/AsyncTokenBucketBuilder.java x: 19 lines of code y: 3 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroup.java x: 499 lines of code y: 16 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiterImpl.java x: 126 lines of code y: 9 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherMultipleConsumers.java x: 187 lines of code y: 35 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherSingleActiveConsumer.java x: 82 lines of code y: 29 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiter.java x: 122 lines of code y: 44 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiterAsyncTokenBucketImpl.java x: 122 lines of code y: 1 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiterClassicImpl.java x: 135 lines of code y: 1 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumersClassic.java x: 1050 lines of code y: 4 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java x: 501 lines of code y: 91 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/SubscribeRateLimiter.java x: 151 lines of code y: 20 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/RateLimiter.java x: 164 lines of code y: 19 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPersistentTopics.java x: 559 lines of code y: 45 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java x: 2527 lines of code y: 148 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java x: 629 lines of code y: 24 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java x: 397 lines of code y: 36 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Topic.java x: 181 lines of code y: 91 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TransportCnx.java x: 42 lines of code y: 13 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ProducerConfigurationData.java x: 220 lines of code y: 33 # changes pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Markers.java x: 225 lines of code y: 15 # changes pulsar-common/src/main/proto/PulsarApi.proto x: 928 lines of code y: 117 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java x: 1092 lines of code y: 109 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java x: 565 lines of code y: 34 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LoadManagerShared.java x: 593 lines of code y: 41 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java x: 902 lines of code y: 105 # changes pulsar-broker/src/main/java/org/apache/pulsar/common/naming/NamespaceBundles.java x: 155 lines of code y: 15 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ShadowManagedLedgerImpl.java x: 321 lines of code y: 13 # changes pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawBatchMessageContainerImpl.java x: 131 lines of code y: 5 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java x: 673 lines of code y: 77 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarRegistrationClient.java x: 281 lines of code y: 11 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConfiguration.java x: 879 lines of code y: 80 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/WebServer.java x: 373 lines of code y: 38 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/TypedMessageBuilder.java x: 35 lines of code y: 9 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/MetaStoreImpl.java x: 467 lines of code y: 24 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java x: 527 lines of code y: 82 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/RangeCache.java x: 321 lines of code y: 19 # changes pulsar-client-auth-athenz/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationAthenz.java x: 219 lines of code y: 22 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerServiceException.java x: 231 lines of code y: 32 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java x: 2968 lines of code y: 132 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java x: 4831 lines of code y: 197 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TopicTransactionBuffer.java x: 662 lines of code y: 55 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java x: 388 lines of code y: 42 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/SameAuthParamsLookupAutoClusterFailover.java x: 302 lines of code y: 2 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerFactoryConfig.java x: 37 lines of code y: 21 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryImpl.java x: 1272 lines of code y: 77 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java x: 191 lines of code y: 36 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaExecutionResult.java x: 8 lines of code y: 7 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstance.java x: 175 lines of code y: 32 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/ComponentStatsManager.java x: 103 lines of code y: 15 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/FunctionStatsManager.java x: 351 lines of code y: 16 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/SinkStatsManager.java x: 266 lines of code y: 16 # changes pulsar-functions/instance/src/main/resources/findbugsExclude.xml x: 543 lines of code y: 6 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/ObjectMapperFactory.java x: 226 lines of code y: 15 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java x: 1176 lines of code y: 141 # changes pulsar-broker/src/main/java/org/apache/pulsar/utils/ConcurrentBitmapSortedLongPairSet.java x: 140 lines of code y: 6 # changes testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockBookKeeper.java x: 395 lines of code y: 16 # changes testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockReadHandle.java x: 102 lines of code y: 4 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerConfig.java x: 364 lines of code y: 55 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/RangeSetWrapper.java x: 154 lines of code y: 11 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionHandler.java x: 201 lines of code y: 31 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractDispatcherMultipleConsumers.java x: 116 lines of code y: 19 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/DrainingHashesTracker.java x: 296 lines of code y: 3 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationService.java x: 187 lines of code y: 21 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ReplicatedSubscriptionsController.java x: 264 lines of code y: 25 # changes pulsar-client/src/main/resources/findbugsExclude.xml x: 1006 lines of code y: 10 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedCursor.java x: 162 lines of code y: 48 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java x: 326 lines of code y: 49 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/TransactionBufferSnapshotBaseSystemTopicClient.java x: 169 lines of code y: 5 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java x: 605 lines of code y: 13 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TableView.java x: 70 lines of code y: 2 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/TopicPoliciesSystemTopicClient.java x: 174 lines of code y: 13 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumersClassic.java x: 469 lines of code y: 3 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java x: 483 lines of code y: 33 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java x: 251 lines of code y: 29 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java x: 476 lines of code y: 29 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdRead.java x: 254 lines of code y: 5 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/AdminProxyHandler.java x: 356 lines of code y: 27 # changes pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/PerformanceClient.java x: 366 lines of code y: 28 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderList.java x: 301 lines of code y: 13 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/KeySharedPolicy.java x: 81 lines of code y: 8 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ReaderConfigurationData.java x: 152 lines of code y: 22 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSinkConfig.java x: 111 lines of code y: 17 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SubscriptionOption.java x: 41 lines of code y: 5 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/LocalPolicies.java x: 32 lines of code y: 12 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ProducerCache.java x: 114 lines of code y: 2 # changes pulsar-common/src/main/java/org/apache/pulsar/common/naming/TopicName.java x: 276 lines of code y: 32 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java x: 169 lines of code y: 33 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/UniformLoadShedder.java x: 151 lines of code y: 13 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/BaseResources.java x: 196 lines of code y: 16 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ClientBuilder.java x: 76 lines of code y: 31 # changes pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/AuthenticationProviderOpenID.java x: 358 lines of code y: 8 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/protocol/TokenClient.java x: 94 lines of code y: 10 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java x: 295 lines of code y: 19 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopicPolicies.java x: 1606 lines of code y: 34 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptorWithClassLoader.java x: 262 lines of code y: 14 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/web/WebService.java x: 409 lines of code y: 54 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationProvider.java x: 162 lines of code y: 35 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java x: 636 lines of code y: 46 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java x: 744 lines of code y: 64 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/ClustersBase.java x: 997 lines of code y: 41 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyName.java x: 37 lines of code y: 14 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/BrokersImpl.java x: 187 lines of code y: 27 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/PrometheusMetricsGenerator.java x: 448 lines of code y: 41 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java x: 316 lines of code y: 32 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnershipCache.java x: 204 lines of code y: 37 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/KeyManagerProxy.java x: 115 lines of code y: 5 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/InMemoryRedeliveryTracker.java x: 86 lines of code y: 11 # changes pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/WindowContext.java x: 22 lines of code y: 8 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowContextImpl.java x: 131 lines of code y: 8 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/models/TopKBundles.java x: 119 lines of code y: 6 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractDispatcherSingleActiveConsumer.java x: 236 lines of code y: 34 # changes tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/FileSystemManagedLedgerOffloader.java x: 354 lines of code y: 15 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionPool.java x: 394 lines of code y: 49 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java x: 458 lines of code y: 67 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdClusters.java x: 386 lines of code y: 30 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerImpl.java x: 953 lines of code y: 55 # changes pulsar-broker/src/main/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsemble.java x: 482 lines of code y: 7 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractSubscription.java x: 51 lines of code y: 3 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/BinaryProtoLookupService.java x: 410 lines of code y: 43 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsistentHashingStickyKeyConsumerSelector.java x: 222 lines of code y: 16 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/NamespaceEventsSystemTopicFactory.java x: 45 lines of code y: 8 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorTool.java x: 149 lines of code y: 34 # changes deployment/terraform-ansible/deploy-pulsar.yaml x: 163 lines of code y: 13 # changes distribution/io/src/assemble/io.xml x: 59 lines of code y: 32 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/offload/OffloaderUtils.java x: 114 lines of code y: 12 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptorUtils.java x: 105 lines of code y: 9 # changes pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java x: 704 lines of code y: 44 # changes pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/io/ConnectorUtils.java x: 135 lines of code y: 18 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/extensions/ProxyExtensionsUtils.java x: 104 lines of code y: 6 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Namespaces.java x: 411 lines of code y: 30 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/NamespacesImpl.java x: 1689 lines of code y: 91 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigurationData.java x: 395 lines of code y: 57 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/RescheduleReadHandler.java x: 73 lines of code y: 2 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/ConsumerStatsImpl.java x: 87 lines of code y: 15 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/AbstractDelayedDeliveryTracker.java x: 93 lines of code y: 3 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/DelayedDeliveryTrackerFactory.java x: 10 lines of code y: 6 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTrackerFactory.java x: 51 lines of code y: 10 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/AbstractPersistentDispatcherMultipleConsumers.java x: 32 lines of code y: 1 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageRedeliveryController.java x: 143 lines of code y: 12 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeAutoSplitStickyKeyConsumerSelector.java x: 144 lines of code y: 16 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeExclusiveStickyKeyConsumerSelector.java x: 142 lines of code y: 14 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/StickyKeyConsumerSelector.java x: 24 lines of code y: 14 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PendingAcksMap.java x: 249 lines of code y: 1 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentStickyKeyDispatcherMultipleConsumers.java x: 164 lines of code y: 22 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/TransactionMetadataStoreService.java x: 438 lines of code y: 46 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/metrics/AbstractMetrics.java x: 145 lines of code y: 14 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckStoreProvider.java x: 202 lines of code y: 13 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java x: 2346 lines of code y: 126 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderBuilderImpl.java x: 226 lines of code y: 30 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SchemasResourceBase.java x: 212 lines of code y: 22 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/SchemasResource.java x: 326 lines of code y: 32 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SchemasImpl.java x: 310 lines of code y: 22 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentOpenLongPairRangeSet.java x: 345 lines of code y: 20 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/LongPairRangeSet.java x: 186 lines of code y: 13 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/OpenLongPairRangeSet.java x: 347 lines of code y: 4 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/TableViewImpl.java x: 340 lines of code y: 22 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/SecurityUtility.java x: 466 lines of code y: 34 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerWrapper.java x: 110 lines of code y: 8 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/store/TableViewLoadDataStoreImpl.java x: 223 lines of code y: 9 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/AbstractCmdConsume.java x: 227 lines of code y: 4 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/ClusterReplicationMetrics.java x: 54 lines of code y: 6 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBase.java x: 130 lines of code y: 27 # changes pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketService.java x: 264 lines of code y: 43 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ReplicatedSubscriptionsSnapshotBuilder.java x: 95 lines of code y: 11 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/NonPersistentTopics.java x: 599 lines of code y: 61 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarStats.java x: 212 lines of code y: 30 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateTableViewSyncer.java x: 219 lines of code y: 1 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicPoliciesService.java x: 49 lines of code y: 19 # changes pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchConfig.java x: 326 lines of code y: 23 # changes pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/client/opensearch/OpenSearchHighLevelRestClient.java x: 300 lines of code y: 8 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaceIsolationPolicy.java x: 192 lines of code y: 14 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerFactory.java x: 50 lines of code y: 22 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpFindNewest.java x: 117 lines of code y: 13 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/ManagedLedgerInterceptorImpl.java x: 142 lines of code y: 13 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java x: 216 lines of code y: 38 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SingleSnapshotAbortedTxnProcessorImpl.java x: 137 lines of code y: 8 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/PendingAckHandleImpl.java x: 942 lines of code y: 43 # changes pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawBatchConverter.java x: 172 lines of code y: 23 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/AbstractTwoPhaseCompactor.java x: 373 lines of code y: 2 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/EventTimeOrderCompactor.java x: 127 lines of code y: 2 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/PulsarServerException.java x: 36 lines of code y: 6 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/LedgerOffloader.java x: 80 lines of code y: 15 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/NonAppendableLedgerOffloader.java x: 46 lines of code y: 1 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicListWatcher.java x: 213 lines of code y: 12 # changes pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataSetup.java x: 409 lines of code y: 55 # changes pulsar-broker/src/main/java/org/apache/pulsar/PulsarTransactionCoordinatorMetadataSetup.java x: 80 lines of code y: 11 # changes pulsar-client-messagecrypto-bc/src/main/java/org/apache/pulsar/client/impl/crypto/MessageCryptoBc.java x: 427 lines of code y: 14 # changes pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/JwksCache.java x: 189 lines of code y: 4 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderBasic.java x: 166 lines of code y: 11 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderToken.java x: 344 lines of code y: 30 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/metrics/AuthenticationMetricsToken.java x: 78 lines of code y: 1 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionBuffer.java x: 33 lines of code y: 25 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/SimpleLoadManagerImpl.java x: 1163 lines of code y: 47 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/LinuxInfoUtils.java x: 256 lines of code y: 14 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/StrategicTwoPhaseCompactor.java x: 386 lines of code y: 7 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentReplicator.java x: 194 lines of code y: 26 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarChannelInitializer.java x: 109 lines of code y: 31 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/ClusterData.java x: 61 lines of code y: 8 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/PulsarAdminBuilderImpl.java x: 226 lines of code y: 21 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/PulsarAdminTool.java x: 253 lines of code y: 57 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/PulsarClientTool.java x: 202 lines of code y: 34 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/ClusterDataImpl.java x: 385 lines of code y: 12 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/DefaultPulsarSslFactory.java x: 276 lines of code y: 1 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/WorkerServer.java x: 280 lines of code y: 39 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ServiceChannelInitializer.java x: 94 lines of code y: 26 # changes pulsar-websocket/src/main/java/org/apache/pulsar/websocket/service/ProxyServer.java x: 230 lines of code y: 28 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyServiceStarter.java x: 386 lines of code y: 55 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/HttpLookupService.java x: 206 lines of code y: 39 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/LookupService.java x: 32 lines of code y: 20 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionCoordinatorClientImpl.java x: 226 lines of code y: 19 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/FunctionsImpl.java x: 644 lines of code y: 56 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/PulsarAdminImpl.java x: 264 lines of code y: 13 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SourcesImpl.java x: 312 lines of code y: 15 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/BaseResource.java x: 309 lines of code y: 28 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/BookiesImpl.java x: 65 lines of code y: 11 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/ClustersImpl.java x: 263 lines of code y: 21 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/ComponentResource.java x: 51 lines of code y: 8 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/ResourceGroupsImpl.java x: 61 lines of code y: 6 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java x: 2397 lines of code y: 118 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TransactionsImpl.java x: 245 lines of code y: 20 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/WorkerImpl.java x: 81 lines of code y: 13 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdBase.java x: 83 lines of code y: 18 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/PulsarZooKeeperClient.java x: 1253 lines of code y: 9 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/DelayedDeliveryTracker.java x: 53 lines of code y: 13 # changes pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java x: 252 lines of code y: 10 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/PatternConsumerUpdateQueue.java x: 160 lines of code y: 1 # changes pulsar-opentelemetry/src/main/java/org/apache/pulsar/opentelemetry/OpenTelemetryService.java x: 86 lines of code y: 7 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopicMetrics.java x: 31 lines of code y: 2 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/OpenTelemetryTopicStats.java x: 343 lines of code y: 3 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TransactionBufferClientStatsImpl.java x: 141 lines of code y: 3 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/PendingAckHandle.java x: 32 lines of code y: 22 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/PendingAckHandleDisabled.java x: 77 lines of code y: 18 # changes pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/TransactionMetadataStore.java x: 33 lines of code y: 15 # changes pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/InMemTransactionMetadataStore.java x: 146 lines of code y: 17 # changes pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStore.java x: 513 lines of code y: 35 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/OpenTelemetryManagedLedgerCacheStats.java x: 113 lines of code y: 1 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/LocalMemoryMetadataStore.java x: 212 lines of code y: 23 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/RocksdbMetadataStore.java x: 521 lines of code y: 18 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Replicator.java x: 25 lines of code y: 12 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/NonPersistentReplicatorStats.java x: 5 lines of code y: 4 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java x: 627 lines of code y: 75 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java x: 290 lines of code y: 55 # changes pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfigUtils.java x: 456 lines of code y: 57 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/OverloadShedder.java x: 82 lines of code y: 20 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionImpl.java x: 212 lines of code y: 27 # changes pulsar-testclient/src/main/java/org/apache/pulsar/testclient/BrokerMonitor.java x: 420 lines of code y: 15 # changes pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeUtils.java x: 463 lines of code y: 55 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryImpl.java x: 168 lines of code y: 18 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorImpl.java x: 97 lines of code y: 24 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TransactionsBase.java x: 522 lines of code y: 23 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Subscription.java x: 74 lines of code y: 35 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckReplyCallBack.java x: 95 lines of code y: 7 # changes pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionLogImpl.java x: 333 lines of code y: 28 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/EtcdMetadataStore.java x: 439 lines of code y: 8 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/TopicStatsImpl.java x: 228 lines of code y: 23 # changes pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java x: 388 lines of code y: 61 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/BKCluster.java x: 303 lines of code y: 12 # changes pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandaloneStarter.java x: 142 lines of code y: 45 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/data/BrokerLoadData.java x: 190 lines of code y: 8 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/manager/UnloadManager.java x: 183 lines of code y: 8 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java x: 203 lines of code y: 51 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness/BookieRackAffinityMapping.java x: 237 lines of code y: 14 # changes pulsar-testclient/src/main/java/org/apache/pulsar/testclient/LoadSimulationClient.java x: 254 lines of code y: 18 # changes pulsar-broker/src/main/java/org/apache/pulsar/utils/auth/tokens/TokensCliUtils.java x: 267 lines of code y: 18 # changes pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/LocalBrokerData.java x: 384 lines of code y: 27 # changes pulsar-common/src/main/java/org/apache/pulsar/common/nar/NarClassLoader.java x: 152 lines of code y: 18 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Topics.java x: 680 lines of code y: 50 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/FunctionsBase.java x: 744 lines of code y: 63 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinksBase.java x: 539 lines of code y: 21 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourcesBase.java x: 491 lines of code y: 23 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v3/Packages.java x: 214 lines of code y: 4 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Bookies.java x: 169 lines of code y: 15 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarKafkaSinkTaskContext.java x: 201 lines of code y: 8 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/AvroSchemaBasedCompatibilityCheck.java x: 72 lines of code y: 13 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/NamespaceResources.java x: 307 lines of code y: 31 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/TopicResources.java x: 100 lines of code y: 12 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataStore.java x: 57 lines of code y: 11 # changes pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarDecoder.java x: 587 lines of code y: 21 # changes pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarHandler.java x: 116 lines of code y: 14 # changes tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBackedReadHandleImpl.java x: 255 lines of code y: 23 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java x: 709 lines of code y: 87 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java x: 639 lines of code y: 77 # changes pulsar-broker/src/main/java/org/apache/pulsar/common/naming/NamespaceBundleFactory.java x: 330 lines of code y: 34 # changes pulsar-client/src/main/java/org/apache/pulsar/client/util/RetryUtil.java x: 43 lines of code y: 6 # changes pulsar-testclient/src/main/java/org/apache/pulsar/testclient/CmdGenerateDocumentation.java x: 88 lines of code y: 13 # changes pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java x: 473 lines of code y: 73 # changes pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java x: 659 lines of code y: 77 # changes pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java x: 184 lines of code y: 43 # changes pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTransaction.java x: 556 lines of code y: 22 # changes pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PulsarPerfTestTool.java x: 96 lines of code y: 1 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/web/JettyRequestLogFactory.java x: 168 lines of code y: 3 # changes pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java x: 867 lines of code y: 52 # changes tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBackedReadHandleImplV2.java x: 295 lines of code y: 10 # changes pulsar-broker/src/main/java/org/apache/pulsar/PulsarBrokerStarter.java x: 308 lines of code y: 52 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionWorkerStarter.java x: 57 lines of code y: 18 # changes conf/log4j2.yaml x: 108 lines of code y: 19 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/UnAckedMessageTracker.java x: 252 lines of code y: 27 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentBitSet.java x: 371 lines of code y: 7 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroupService.java x: 585 lines of code y: 22 # changes pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/JavaInstanceStarter.java x: 409 lines of code y: 24 # changes pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java x: 225 lines of code y: 45 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CliCommand.java x: 122 lines of code y: 26 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdBrokers.java x: 140 lines of code y: 18 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdGenerateDocument.java x: 105 lines of code y: 13 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/PulsarAdminSupplier.java x: 88 lines of code y: 4 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/shell/ConfigShell.java x: 389 lines of code y: 7 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/shell/PulsarShell.java x: 514 lines of code y: 9 # changes pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ProducerHandler.java x: 435 lines of code y: 32 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/AutoClusterFailover.java x: 314 lines of code y: 9 # changes buildtools/src/main/resources/log4j2.xml x: 18 lines of code y: 9 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionActioner.java x: 620 lines of code y: 75 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java x: 773 lines of code y: 98 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java x: 544 lines of code y: 32 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java x: 1601 lines of code y: 77 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.java x: 654 lines of code y: 105 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SinksImpl.java x: 660 lines of code y: 38 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SourcesImpl.java x: 606 lines of code y: 37 # changes tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/FileStoreBackedReadHandleImpl.java x: 186 lines of code y: 10 # changes pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntime.java x: 274 lines of code y: 23 # changes pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionFilePackage.java x: 141 lines of code y: 1 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarCommandSenderImpl.java x: 311 lines of code y: 26 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/BitSetRecyclable.java x: 524 lines of code y: 5 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/PulsarResourceDescription.java x: 80 lines of code y: 6 # changes docker/pulsar/scripts/apply-config-from-env.py x: 56 lines of code y: 15 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/BKStateStoreImpl.java x: 168 lines of code y: 6 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/PulsarMetadataStateStoreImpl.java x: 112 lines of code y: 6 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/HierarchyTopicPolicies.java x: 73 lines of code y: 27 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/NoopLoadManager.java x: 112 lines of code y: 18 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerWrapper.java x: 99 lines of code y: 20 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Consumer.java x: 65 lines of code y: 30 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/TopicPolicies.java x: 238 lines of code y: 9 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicPoliciesImpl.java x: 1074 lines of code y: 12 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/scheduler/UnloadScheduler.java x: 190 lines of code y: 6 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/models/UnloadCounter.java x: 122 lines of code y: 4 # changes src/owasp-dependency-check-false-positives.xml x: 171 lines of code y: 16 # changes src/owasp-dependency-check-suppressions.xml x: 429 lines of code y: 25 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiter.java x: 8 lines of code y: 12 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/LeaderService.java x: 127 lines of code y: 10 # changes pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalAbstractSource.java x: 134 lines of code y: 6 # changes pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfig.java x: 180 lines of code y: 6 # changes pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcAbstractSink.java x: 320 lines of code y: 12 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSinkConfig.java x: 99 lines of code y: 13 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java x: 133 lines of code y: 15 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/BKStateStoreProviderImpl.java x: 177 lines of code y: 9 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java x: 1063 lines of code y: 86 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/keystoretls/KeyStoreSSLContext.java x: 287 lines of code y: 16 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/NonPersistentTopics.java x: 264 lines of code y: 41 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicMessageImpl.java x: 156 lines of code y: 27 # changes pulsar-client-auth-sasl/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationSasl.java x: 269 lines of code y: 11 # changes pulsar-websocket/src/main/java/org/apache/pulsar/websocket/AbstractWebSocketHandler.java x: 244 lines of code y: 23 # changes pulsar-websocket/src/main/java/org/apache/pulsar/websocket/MultiTopicConsumerHandler.java x: 84 lines of code y: 1 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/MultiRolesTokenAuthorizationProvider.java x: 250 lines of code y: 15 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java x: 1651 lines of code y: 84 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/AuthenticationDataProvider.java x: 57 lines of code y: 13 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationDataTls.java x: 121 lines of code y: 12 # changes pulsar-functions/instance/src/main/python/python_instance_main.py x: 233 lines of code y: 39 # changes pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchClient.java x: 282 lines of code y: 14 # changes pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java x: 379 lines of code y: 22 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerUnderreplicationManager.java x: 917 lines of code y: 7 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongHashMap.java x: 472 lines of code y: 14 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongLongPairHashMap.java x: 510 lines of code y: 5 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongPairSet.java x: 525 lines of code y: 15 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsReaderImpl.java x: 200 lines of code y: 18 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java x: 213 lines of code y: 43 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java x: 127 lines of code y: 25 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSourceConfig.java x: 157 lines of code y: 8 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarRegistrationManager.java x: 331 lines of code y: 6 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/stats/ProxyStats.java x: 123 lines of code y: 7 # changes pulsar-functions/instance/src/main/python/python_instance.py x: 482 lines of code y: 55 # changes pulsar-io/core/src/main/java/org/apache/pulsar/io/core/PushSource.java x: 12 lines of code y: 12 # changes pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRuntime.java x: 984 lines of code y: 41 # changes pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRuntimeFactory.java x: 488 lines of code y: 26 # changes tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlockAwareSegmentInputStreamImpl.java x: 253 lines of code y: 10 # changes pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntimeFactory.java x: 204 lines of code y: 24 # changes pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ReaderHandler.java x: 286 lines of code y: 27 # changes pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesSecretsTokenAuthProvider.java x: 330 lines of code y: 20 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceConfig.java x: 34 lines of code y: 17 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageIdImpl.java x: 139 lines of code y: 24 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/strategy/DefaultNamespaceBundleSplitStrategyImpl.java x: 246 lines of code y: 5 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImplV2.java x: 207 lines of code y: 16 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/WorkerImpl.java x: 275 lines of code y: 25 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionsApiV2Resource.java x: 284 lines of code y: 8 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionsApiV3Resource.java x: 377 lines of code y: 18 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/SourcesApiV3Resource.java x: 257 lines of code y: 11 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/AcknowledgmentsGroupingTracker.java x: 16 lines of code y: 13 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageIdImpl.java x: 84 lines of code y: 22 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ZeroQueueConsumerImpl.java x: 164 lines of code y: 32 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedMessageIndexStats.java x: 104 lines of code y: 1 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema/PulsarSchemaToKafkaSchema.java x: 217 lines of code y: 7 # changes pulsar-function-go/pb/Function.pb.go x: 2010 lines of code y: 7 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema/KafkaConnectData.java x: 333 lines of code y: 8 # changes pulsar-functions/instance/src/main/python/contextimpl.py x: 179 lines of code y: 34 # changes structured-event-log/src/main/java/org/apache/pulsar/structuredeventlog/log4j2/Log4j2Event.java x: 165 lines of code y: 1 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AutoConsumeSchema.java x: 305 lines of code y: 32 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/LedgerOffloaderStatsImpl.java x: 297 lines of code y: 5 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSourceConfig.java x: 18 lines of code y: 17 # changes pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/client/RestClient.java x: 214 lines of code y: 7 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerUtils.java x: 367 lines of code y: 27 # changes pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/TxnLogBufferedWriter.java x: 410 lines of code y: 11 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/Worker.java x: 93 lines of code y: 51 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java x: 278 lines of code y: 21 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/ProtectedObjectMapper.java x: 349 lines of code y: 1 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java x: 690 lines of code y: 49 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarCommandSender.java x: 51 lines of code y: 17 # changes pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcUtils.java x: 173 lines of code y: 8 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Schema.java x: 149 lines of code y: 26 # changes pulsar-io/http/src/main/java/org/apache/pulsar/io/http/JsonConverter.java x: 206 lines of code y: 1 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerException.java x: 156 lines of code y: 21 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroupNamespaceConfigListener.java x: 136 lines of code y: 4 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/DefaultImplementation.java x: 18 lines of code y: 24 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationTls.java x: 100 lines of code y: 18 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/StructSchema.java x: 21 lines of code y: 18 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/Reflections.java x: 242 lines of code y: 6 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/GrowablePriorityLongPairQueue.java x: 254 lines of code y: 7 # changes pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Context.java x: 35 lines of code y: 38 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceUtils.java x: 178 lines of code y: 19 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/SinkRecord.java x: 68 lines of code y: 16 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarRecord.java x: 95 lines of code y: 18 # changes pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/process/ProcessRuntime.java x: 354 lines of code y: 16 # changes pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/process/ProcessRuntimeFactory.java x: 205 lines of code y: 12 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionAssignmentTailer.java x: 130 lines of code y: 21 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionMetaDataManager.java x: 336 lines of code y: 30 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionMetaDataTopicTailer.java x: 106 lines of code y: 17 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/MembershipManager.java x: 180 lines of code y: 29 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerService.java x: 32 lines of code y: 50 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/Resources.java x: 46 lines of code y: 14 # changes pulsar-io/core/src/main/java/org/apache/pulsar/io/core/SourceContext.java x: 18 lines of code y: 14 # changes pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileListingThread.java x: 147 lines of code y: 4 # changes pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java x: 126 lines of code y: 17 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerIdGenerator.java x: 221 lines of code y: 6 # changes pulsar-package-management/bookkeeper-storage/src/main/java/org/apache/pulsar/packages/management/storage/bookkeeper/BookKeeperPackagesStorage.java x: 165 lines of code y: 8 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/BrokerDiscoveryProvider.java x: 61 lines of code y: 24 # changes pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStoreProvider.java x: 60 lines of code y: 17 # changes structured-event-log/src/main/java/org/apache/pulsar/structuredeventlog/slf4j/Slf4jEvent.java x: 202 lines of code y: 4 # changes tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexBlockImpl.java x: 278 lines of code y: 13 # changes tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/provider/JCloudBlobStoreProvider.java x: 349 lines of code y: 15 # changes pulsar-functions/instance/src/main/python/function_stats.py x: 150 lines of code y: 12 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/Application.java x: 190 lines of code y: 3 # changes pulsar-function-go/pb/InstanceCommunication.pb.go x: 1022 lines of code y: 4 # changes pulsar-functions/proto/src/main/proto/InstanceCommunication.proto x: 111 lines of code y: 22 # changes
436.0
# changes
  min: 1.0
  average: 10.23
  25th percentile: 2.0
  median: 4.0
  75th percentile: 9.0
  max: 436.0
0 4990.0
lines of code
min: 1.0 | average: 113.8 | 25th percentile: 10.0 | median: 36.0 | 75th percentile: 97.0 | max: 4990.0

Number of Contributors vs. Number of Changes: 2759 points

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java x: 61 # contributors y: 144 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyHierarchyValue.java x: 4 # contributors y: 5 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java x: 64 # contributors y: 220 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java x: 11 # contributors y: 16 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/GeoReplicationProducerImpl.java x: 1 # contributors y: 2 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/HandlerState.java x: 9 # contributors y: 9 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java x: 67 # contributors y: 182 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImplementationBindingImpl.java x: 6 # contributors y: 9 # changes pulsar-common/src/main/java/org/apache/pulsar/client/impl/schema/SchemaInfoImpl.java x: 5 # contributors y: 5 # changes pulsar-common/src/main/java/org/apache/pulsar/client/impl/schema/SchemaUtils.java x: 11 # contributors y: 11 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java x: 104 # contributors y: 360 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java x: 111 # contributors y: 384 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java x: 20 # contributors y: 35 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/NonPersistentTopicStatsImpl.java x: 7 # contributors y: 9 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/AckSetState.java x: 2 # contributors y: 3 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java x: 82 # contributors y: 273 # changes pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/OpenIDProviderMetadataCache.java x: 3 # contributors y: 4 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java x: 81 # contributors y: 214 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java x: 101 # contributors y: 333 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v3/Transactions.java x: 11 # contributors y: 23 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java x: 5 # contributors y: 11 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java x: 58 # contributors y: 156 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractBaseDispatcher.java x: 31 # contributors y: 67 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java x: 31 # contributors y: 62 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java x: 20 # contributors y: 28 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java x: 110 # contributors y: 436 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/SystemTopic.java x: 14 # contributors y: 21 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorage.java x: 28 # contributors y: 47 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorageFactory.java x: 5 # contributors y: 7 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java x: 29 # contributors y: 48 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaStorageFactory.java x: 5 # contributors y: 6 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java x: 50 # contributors y: 110 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java x: 17 # contributors y: 44 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicUtils.java x: 3 # contributors y: 9 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/PulsarTopicCompactionService.java x: 2 # contributors y: 7 # changes pulsar-broker/src/main/java/org/apache/pulsar/compaction/TopicCompactionService.java x: 2 # contributors y: 4 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java x: 64 # contributors y: 145 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java x: 23 # contributors y: 42 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java x: 60 # contributors y: 150 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/FutureUtil.java x: 14 # contributors y: 25 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/URIPreconditions.java x: 3 # contributors y: 3 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSource.java x: 11 # contributors y: 18 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java x: 16 # contributors y: 33 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java x: 11 # contributors y: 14 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedger.java x: 33 # contributors y: 46 # changes managed-ledger/src/main/proto/MLDataFormats.proto x: 13 # contributors y: 20 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageFinder.java x: 11 # contributors y: 13 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TenantsBase.java x: 24 # contributors y: 33 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java x: 62 # contributors y: 155 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/BacklogQuota.java x: 6 # contributors y: 7 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java x: 6 # contributors y: 57 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java x: 80 # contributors y: 288 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java x: 36 # contributors y: 63 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java x: 40 # contributors y: 54 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ConsumerConfigurationData.java x: 36 # contributors y: 53 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java x: 9 # contributors y: 13 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/validator/StructSchemaDataValidator.java x: 6 # contributors y: 6 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericSchemaImpl.java x: 9 # contributors y: 11 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java x: 44 # contributors y: 125 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness/IsolatedBookieEnsemblePlacementPolicy.java x: 12 # contributors y: 16 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/MessagePayloadProcessorConfig.java x: 1 # contributors y: 1 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java x: 37 # contributors y: 139 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java x: 20 # contributors y: 56 # changes pulsar-functions/proto/src/main/proto/Function.proto x: 17 # contributors y: 60 # changes pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java x: 29 # contributors y: 78 # changes pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java x: 25 # contributors y: 61 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java x: 61 # contributors y: 135 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java x: 39 # contributors y: 83 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java x: 95 # contributors y: 274 # changes testmocks/src/main/java/org/apache/zookeeper/MockZooKeeper.java x: 15 # contributors y: 22 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/scheduler/TransferShedder.java x: 3 # contributors y: 15 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java x: 20 # contributors y: 27 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java x: 24 # contributors y: 37 # changes pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java x: 45 # contributors y: 95 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java x: 25 # contributors y: 51 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyClientCnx.java x: 13 # contributors y: 14 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java x: 26 # contributors y: 63 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java x: 20 # contributors y: 32 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscription.java x: 29 # contributors y: 60 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java x: 46 # contributors y: 154 # changes pulsar-function-go/pf/instance.go x: 13 # contributors y: 28 # changes pulsar-function-go/pf/context.go x: 7 # contributors y: 11 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSink.java x: 9 # contributors y: 18 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java x: 10 # contributors y: 15 # changes pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataTeardown.java x: 10 # contributors y: 16 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/PatternMultiTopicsConsumerImpl.java x: 17 # contributors y: 24 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Dispatcher.java x: 17 # contributors y: 32 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java x: 55 # contributors y: 175 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/AggregatedNamespaceStats.java x: 21 # contributors y: 32 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/AggregatedSubscriptionStats.java x: 13 # contributors y: 16 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/NamespaceStatsAggregator.java x: 39 # contributors y: 68 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TopicStats.java x: 33 # contributors y: 51 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/SubscriptionStats.java x: 13 # contributors y: 18 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java x: 19 # contributors y: 27 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java x: 42 # contributors y: 80 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java x: 36 # contributors y: 71 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java x: 25 # contributors y: 44 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java x: 17 # contributors y: 39 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java x: 77 # contributors y: 174 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerBase.java x: 7 # contributors y: 8 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java x: 22 # contributors y: 36 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java x: 14 # contributors y: 20 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java x: 94 # contributors y: 312 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ThresholdShedder.java x: 18 # contributors y: 23 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/DeadLetterPolicy.java x: 8 # contributors y: 10 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/PulsarPrometheusMetricsServlet.java x: 4 # contributors y: 6 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsMetricsResource.java x: 8 # contributors y: 8 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java x: 13 # contributors y: 23 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/GeoPersistentReplicator.java x: 8 # contributors y: 12 # changes tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/JCloudLedgerOffloaderFactory.java x: 10 # contributors y: 11 # changes tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreManagedLedgerOffloader.java x: 19 # contributors y: 31 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroup.java x: 8 # contributors y: 16 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiterImpl.java x: 5 # contributors y: 9 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherMultipleConsumers.java x: 21 # contributors y: 35 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherSingleActiveConsumer.java x: 22 # contributors y: 29 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiter.java x: 21 # contributors y: 44 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java x: 42 # contributors y: 91 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/SubscribeRateLimiter.java x: 12 # contributors y: 20 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPersistentTopics.java x: 23 # contributors y: 45 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java x: 60 # contributors y: 148 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java x: 5 # contributors y: 24 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java x: 18 # contributors y: 36 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Topic.java x: 48 # contributors y: 91 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TransportCnx.java x: 14 # contributors y: 13 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ProducerConfigurationData.java x: 23 # contributors y: 33 # changes pulsar-common/src/main/proto/PulsarApi.proto x: 47 # contributors y: 117 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java x: 53 # contributors y: 109 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java x: 18 # contributors y: 34 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LoadManagerShared.java x: 21 # contributors y: 41 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java x: 44 # contributors y: 105 # changes pulsar-broker/src/main/java/org/apache/pulsar/common/naming/NamespaceBundles.java x: 12 # contributors y: 15 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ShadowManagedLedgerImpl.java x: 7 # contributors y: 13 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java x: 38 # contributors y: 77 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConfiguration.java x: 38 # contributors y: 80 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/WebServer.java x: 22 # contributors y: 38 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java x: 27 # contributors y: 82 # changes pulsar-client-auth-athenz/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationAthenz.java x: 12 # contributors y: 22 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java x: 63 # contributors y: 132 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java x: 76 # contributors y: 197 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TopicTransactionBuffer.java x: 15 # contributors y: 55 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java x: 27 # contributors y: 42 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryImpl.java x: 36 # contributors y: 77 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java x: 23 # contributors y: 36 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstance.java x: 16 # contributors y: 32 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/ObjectMapperFactory.java x: 9 # contributors y: 15 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java x: 33 # contributors y: 141 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerConfig.java x: 24 # contributors y: 55 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationService.java x: 17 # contributors y: 21 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ReplicatedSubscriptionsController.java x: 16 # contributors y: 25 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedCursor.java x: 26 # contributors y: 48 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java x: 26 # contributors y: 49 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java x: 8 # contributors y: 13 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/TopicPoliciesSystemTopicClient.java x: 10 # contributors y: 13 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java x: 22 # contributors y: 33 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java x: 18 # contributors y: 29 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java x: 21 # contributors y: 29 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/HttpClient.java x: 17 # contributors y: 29 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarChannelInitializer.java x: 16 # contributors y: 23 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/AdminProxyHandler.java x: 17 # contributors y: 27 # changes pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/PerformanceClient.java x: 19 # contributors y: 28 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderList.java x: 12 # contributors y: 13 # changes pulsar-common/src/main/java/org/apache/pulsar/common/naming/TopicName.java x: 22 # contributors y: 32 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java x: 21 # contributors y: 33 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ClientBuilder.java x: 24 # contributors y: 31 # changes pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/AuthenticationProviderOpenID.java x: 4 # contributors y: 8 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java x: 18 # contributors y: 19 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/web/WebService.java x: 27 # contributors y: 54 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationProvider.java x: 16 # contributors y: 35 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java x: 21 # contributors y: 46 # changes pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java x: 31 # contributors y: 64 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/ClustersBase.java x: 22 # contributors y: 41 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/PrometheusMetricsGenerator.java x: 25 # contributors y: 41 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java x: 25 # contributors y: 32 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnershipCache.java x: 25 # contributors y: 37 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/models/TopKBundles.java x: 3 # contributors y: 6 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFunctionExecutor.java x: 9 # contributors y: 16 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractDispatcherSingleActiveConsumer.java x: 20 # contributors y: 34 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionPool.java x: 23 # contributors y: 49 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java x: 30 # contributors y: 67 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedProducerImpl.java x: 29 # contributors y: 50 # changes pulsar-package-management/bookkeeper-storage/src/main/java/org/apache/pulsar/packages/management/storage/bookkeeper/DLOutputStream.java x: 6 # contributors y: 5 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdClusters.java x: 14 # contributors y: 30 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerImpl.java x: 8 # contributors y: 55 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/offload/OffloaderUtils.java x: 12 # contributors y: 12 # changes pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java x: 19 # contributors y: 44 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/BucketDelayedDeliveryTrackerFactory.java x: 4 # contributors y: 9 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/ImmutableBucket.java x: 3 # contributors y: 11 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Namespaces.java x: 18 # contributors y: 30 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/NamespacesImpl.java x: 38 # contributors y: 91 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigurationData.java x: 38 # contributors y: 57 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeExclusiveStickyKeyConsumerSelector.java x: 8 # contributors y: 14 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/TransactionMetadataStoreService.java x: 18 # contributors y: 46 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckStoreProvider.java x: 6 # contributors y: 13 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java x: 58 # contributors y: 126 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderBuilderImpl.java x: 19 # contributors y: 30 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSchemas.java x: 16 # contributors y: 21 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Brokers.java x: 10 # contributors y: 10 # changes pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentOpenLongPairRangeSet.java x: 17 # contributors y: 20 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/TableViewImpl.java x: 11 # contributors y: 22 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerWrapper.java x: 3 # contributors y: 8 # changes pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketService.java x: 23 # contributors y: 43 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/NonPersistentTopics.java x: 41 # contributors y: 61 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitState.java x: 1 # contributors y: 5 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannel.java x: 4 # contributors y: 12 # changes pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchConfig.java x: 14 # contributors y: 23 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java x: 28 # contributors y: 38 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckStore.java x: 10 # contributors y: 18 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/PendingAckHandleImpl.java x: 16 # contributors y: 43 # changes pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataSetup.java x: 28 # contributors y: 55 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionBuffer.java x: 12 # contributors y: 25 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/SimpleLoadManagerImpl.java x: 25 # contributors y: 47 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentReplicator.java x: 16 # contributors y: 26 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/PulsarAdminTool.java x: 32 # contributors y: 57 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/WorkerServer.java x: 19 # contributors y: 39 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ServiceChannelInitializer.java x: 18 # contributors y: 26 # changes pulsar-websocket/src/main/java/org/apache/pulsar/websocket/service/ProxyServer.java x: 16 # contributors y: 28 # changes pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyServiceStarter.java x: 34 # contributors y: 55 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/HttpLookupService.java x: 23 # contributors y: 39 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/LookupService.java x: 11 # contributors y: 20 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/FunctionsImpl.java x: 17 # contributors y: 56 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/PackagesImpl.java x: 7 # contributors y: 14 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/LeaderElectionImpl.java x: 10 # contributors y: 20 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/ClustersImpl.java x: 10 # contributors y: 21 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java x: 52 # contributors y: 118 # changes pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TransactionsImpl.java x: 8 # contributors y: 20 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdBase.java x: 15 # contributors y: 18 # changes pulsar-opentelemetry/src/main/java/org/apache/pulsar/opentelemetry/OpenTelemetryAttributes.java x: 1 # contributors y: 13 # changes pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ConsumerHandler.java x: 26 # contributors y: 51 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/PendingAckHandle.java x: 9 # contributors y: 22 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/PendingAckHandleDisabled.java x: 6 # contributors y: 18 # changes pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStore.java x: 13 # contributors y: 35 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/LocalMemoryMetadataStore.java x: 15 # contributors y: 23 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java x: 27 # contributors y: 75 # changes pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java x: 25 # contributors y: 55 # changes pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfigUtils.java x: 18 # contributors y: 57 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionImpl.java x: 9 # contributors y: 27 # changes pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeUtils.java x: 22 # contributors y: 55 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryImpl.java x: 12 # contributors y: 18 # changes managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorContainer.java x: 15 # contributors y: 19 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TransactionsBase.java x: 10 # contributors y: 23 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Subscription.java x: 19 # contributors y: 35 # changes pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionLogImpl.java x: 11 # contributors y: 28 # changes pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java x: 34 # contributors y: 61 # changes pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandaloneStarter.java x: 20 # contributors y: 45 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java x: 22 # contributors y: 51 # changes pulsar-broker/src/main/java/org/apache/pulsar/utils/auth/tokens/TokensCliUtils.java x: 14 # contributors y: 18 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/FunctionsBase.java x: 21 # contributors y: 63 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataStore.java x: 6 # contributors y: 11 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java x: 28 # contributors y: 87 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java x: 25 # contributors y: 77 # changes pulsar-websocket/src/main/java/org/apache/pulsar/websocket/service/WebSocketProxyConfiguration.java x: 24 # contributors y: 38 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/LockManagerImpl.java x: 5 # contributors y: 16 # changes pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/ResourceLockImpl.java x: 6 # contributors y: 16 # changes pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java x: 38 # contributors y: 73 # changes pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java x: 41 # contributors y: 77 # changes pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java x: 27 # contributors y: 43 # changes pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java x: 31 # contributors y: 52 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java x: 18 # contributors y: 25 # changes pulsar-broker/src/main/java/org/apache/pulsar/PulsarBrokerStarter.java x: 26 # contributors y: 52 # changes pulsar-websocket/src/main/java/org/apache/pulsar/websocket/service/WebSocketServiceStarter.java x: 14 # contributors y: 17 # changes pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java x: 27 # contributors y: 45 # changes pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdBrokers.java x: 16 # contributors y: 18 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionActioner.java x: 19 # contributors y: 75 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java x: 25 # contributors y: 98 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.java x: 24 # contributors y: 105 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SourcesImpl.java x: 19 # contributors y: 37 # changes pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionCommon.java x: 13 # contributors y: 27 # changes distribution/server/src/assemble/bin.xml x: 9 # contributors y: 19 # changes pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/HierarchyTopicPolicies.java x: 10 # contributors y: 27 # changes pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Transactions.java x: 5 # contributors y: 15 # changes pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Consumer.java x: 20 # contributors y: 30 # changes src/owasp-dependency-check-false-positives.xml x: 4 # contributors y: 16 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TransactionBufferHandlerImpl.java x: 14 # contributors y: 28 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java x: 14 # contributors y: 15 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java x: 47 # contributors y: 86 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/NonPersistentTopics.java x: 29 # contributors y: 41 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java x: 40 # contributors y: 84 # changes pulsar-functions/instance/src/main/python/python_instance_main.py x: 11 # contributors y: 39 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java x: 28 # contributors y: 43 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java x: 15 # contributors y: 25 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/filter/BrokerFilter.java x: 1 # contributors y: 7 # changes pulsar-functions/instance/src/main/python/python_instance.py x: 11 # contributors y: 55 # changes buildtools/src/main/resources/pulsar/suppressions.xml x: 7 # contributors y: 16 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/MutableBucket.java x: 2 # contributors y: 9 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/Bucket.java x: 1 # contributors y: 9 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/WorkerImpl.java x: 13 # contributors y: 25 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ZeroQueueConsumerImpl.java x: 18 # contributors y: 32 # changes pulsar-functions/instance/src/main/python/contextimpl.py x: 12 # contributors y: 34 # changes pulsar-functions/instance/src/main/python/util.py x: 6 # contributors y: 14 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/Worker.java x: 17 # contributors y: 51 # changes pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/JsonSchemaCompatibilityCheck.java x: 13 # contributors y: 13 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java x: 18 # contributors y: 21 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java x: 15 # contributors y: 49 # changes pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AvroSchema.java x: 15 # contributors y: 27 # changes pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawMessageImpl.java x: 5 # contributors y: 13 # changes pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Context.java x: 15 # contributors y: 38 # changes pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeSpawner.java x: 10 # contributors y: 31 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionAssignmentTailer.java x: 8 # contributors y: 21 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionMetaDataManager.java x: 11 # contributors y: 30 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/MembershipManager.java x: 8 # contributors y: 29 # changes pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerService.java x: 16 # contributors y: 50 # changes pulsar-functions/proto/src/main/proto/InstanceCommunication.proto x: 4 # contributors y: 22 # changes
436.0
# changes
  min: 1.0
  average: 10.23
  25th percentile: 2.0
  median: 4.0
  75th percentile: 9.0
  max: 436.0
0 111.0
# contributors
min: 1.0 | average: 6.23 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 7.0 | max: 111.0

Number of Contributors vs. File Size: 2759 points

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java x: 61 # contributors y: 1176 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyHierarchyValue.java x: 4 # contributors y: 54 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java x: 64 # contributors y: 3144 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java x: 11 # contributors y: 260 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/GeoReplicationProducerImpl.java x: 1 # contributors y: 189 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/HandlerState.java x: 9 # contributors y: 70 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java x: 67 # contributors y: 2134 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImplementationBindingImpl.java x: 6 # contributors y: 267 lines of code pulsar-common/src/main/java/org/apache/pulsar/client/impl/schema/SchemaInfoImpl.java x: 5 # contributors y: 70 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java x: 104 # contributors y: 3094 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/ObserverGauge.java x: 5 # contributors y: 79 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java x: 111 # contributors y: 3475 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java x: 20 # contributors y: 143 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/NonPersistentTopicStatsImpl.java x: 7 # contributors y: 142 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/AckSetState.java x: 2 # contributors y: 9 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java x: 82 # contributors y: 3837 lines of code pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/OpenIDProviderMetadataCache.java x: 3 # contributors y: 155 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java x: 81 # contributors y: 2569 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java x: 101 # contributors y: 4990 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v3/Transactions.java x: 11 # contributors y: 452 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java x: 5 # contributors y: 244 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceEphemeralData.java x: 6 # contributors y: 42 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java x: 58 # contributors y: 1456 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractBaseDispatcher.java x: 31 # contributors y: 403 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsumerHashAssignmentsSnapshot.java x: 1 # contributors y: 161 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/EntryAndMetadata.java x: 4 # contributors y: 92 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java x: 31 # contributors y: 641 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java x: 20 # contributors y: 223 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java x: 110 # contributors y: 3740 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/SystemTopic.java x: 14 # contributors y: 81 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorage.java x: 28 # contributors y: 654 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorageFactory.java x: 5 # contributors y: 12 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java x: 29 # contributors y: 603 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java x: 50 # contributors y: 1107 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java x: 17 # contributors y: 338 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicUtils.java x: 3 # contributors y: 77 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/PulsarCompactionServiceFactory.java x: 3 # contributors y: 58 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/PulsarTopicCompactionService.java x: 2 # contributors y: 102 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ControlledClusterFailover.java x: 6 # contributors y: 210 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java x: 64 # contributors y: 1405 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java x: 23 # contributors y: 596 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java x: 60 # contributors y: 1119 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/FutureUtil.java x: 14 # contributors y: 236 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/GrowableArrayBlockingQueue.java x: 6 # contributors y: 364 lines of code pulsar-io/azure-data-explorer/src/main/java/org/apache/pulsar/io/azuredataexplorer/ADXSink.java x: 2 # contributors y: 246 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSource.java x: 11 # contributors y: 249 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java x: 16 # contributors y: 736 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java x: 11 # contributors y: 699 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedger.java x: 33 # contributors y: 123 lines of code managed-ledger/src/main/proto/MLDataFormats.proto x: 13 # contributors y: 134 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageFinder.java x: 11 # contributors y: 124 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HealthChecker.java x: 1 # contributors y: 257 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TenantsBase.java x: 24 # contributors y: 317 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java x: 62 # contributors y: 837 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/BacklogQuota.java x: 6 # contributors y: 32 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java x: 6 # contributors y: 1699 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java x: 80 # contributors y: 1759 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java x: 36 # contributors y: 478 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java x: 40 # contributors y: 77 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ConsumerConfigurationData.java x: 36 # contributors y: 377 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java x: 9 # contributors y: 223 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java x: 11 # contributors y: 539 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/Backoff.java x: 3 # contributors y: 88 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataCacheConfig.java x: 4 # contributors y: 30 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/tableview/impl/MetadataStoreTableViewImpl.java x: 1 # contributors y: 283 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/validator/SchemaDataValidator.java x: 5 # contributors y: 58 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/validator/StructSchemaDataValidator.java x: 6 # contributors y: 65 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericSchemaImpl.java x: 9 # contributors y: 44 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java x: 44 # contributors y: 1279 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java x: 20 # contributors y: 379 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness/IsolatedBookieEnsemblePlacementPolicy.java x: 12 # contributors y: 240 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/MessagePayloadProcessorConfig.java x: 1 # contributors y: 16 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java x: 37 # contributors y: 963 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java x: 20 # contributors y: 164 lines of code pulsar-functions/proto/src/main/proto/Function.proto x: 17 # contributors y: 227 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java x: 29 # contributors y: 977 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/MessagePayloadProcessorUtils.java x: 1 # contributors y: 65 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java x: 25 # contributors y: 674 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/ValidatorUtils.java x: 9 # contributors y: 155 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java x: 61 # contributors y: 1024 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java x: 39 # contributors y: 740 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java x: 95 # contributors y: 2716 lines of code testmocks/src/main/java/org/apache/zookeeper/MockZooKeeper.java x: 15 # contributors y: 1034 lines of code testmocks/src/main/java/org/apache/zookeeper/MockZooKeeperSession.java x: 5 # contributors y: 334 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/scheduler/TransferShedder.java x: 3 # contributors y: 665 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java x: 20 # contributors y: 52 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java x: 24 # contributors y: 299 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java x: 45 # contributors y: 1733 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java x: 25 # contributors y: 418 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyClientCnx.java x: 13 # contributors y: 69 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java x: 26 # contributors y: 693 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java x: 20 # contributors y: 506 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscription.java x: 29 # contributors y: 441 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java x: 46 # contributors y: 1168 lines of code pulsar-function-go/pf/instance.go x: 13 # contributors y: 622 lines of code pulsar-function-go/pf/context.go x: 7 # contributors y: 129 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/Utils.java x: 7 # contributors y: 217 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/json/JsonConverter.java x: 3 # contributors y: 194 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryCountEstimator.java x: 1 # contributors y: 103 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSink.java x: 9 # contributors y: 435 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java x: 10 # contributors y: 95 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaBytesSource.java x: 9 # contributors y: 178 lines of code pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataTeardown.java x: 10 # contributors y: 228 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/ClientCredentialsFlow.java x: 9 # contributors y: 113 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PatternMultiTopicsConsumerImpl.java x: 17 # contributors y: 323 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Dispatcher.java x: 17 # contributors y: 99 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java x: 55 # contributors y: 1302 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/AggregatedNamespaceStats.java x: 21 # contributors y: 188 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/AggregatedSubscriptionStats.java x: 13 # contributors y: 41 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/NamespaceStatsAggregator.java x: 39 # contributors y: 510 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TopicStats.java x: 33 # contributors y: 519 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java x: 19 # contributors y: 178 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java x: 42 # contributors y: 539 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java x: 36 # contributors y: 575 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java x: 25 # contributors y: 558 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/util/RetryMessageUtil.java x: 5 # contributors y: 20 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarMetadataEventSynchronizer.java x: 4 # contributors y: 281 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java x: 17 # contributors y: 494 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnedBundle.java x: 11 # contributors y: 89 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java x: 77 # contributors y: 1024 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerBase.java x: 7 # contributors y: 16 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java x: 22 # contributors y: 294 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java x: 14 # contributors y: 299 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java x: 94 # contributors y: 3241 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicListService.java x: 7 # contributors y: 202 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ThresholdShedder.java x: 18 # contributors y: 189 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/BatchingConfig.java x: 1 # contributors y: 21 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/ProducerConfig.java x: 3 # contributors y: 21 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ProducerBuilderFactory.java x: 2 # contributors y: 146 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/BatchingUtils.java x: 1 # contributors y: 57 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/api/raw/RawMessageImpl.java x: 11 # contributors y: 177 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/DeadLetterPolicy.java x: 8 # contributors y: 23 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/stats/prometheus/PrometheusMetricsServlet.java x: 5 # contributors y: 146 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/PulsarPrometheusMetricsServlet.java x: 4 # contributors y: 153 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsMetricsResource.java x: 8 # contributors y: 66 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TypedMessageBuilderImpl.java x: 20 # contributors y: 262 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java x: 13 # contributors y: 171 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/GeoPersistentReplicator.java x: 8 # contributors y: 182 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ShadowReplicator.java x: 8 # contributors y: 89 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryImpl.java x: 7 # contributors y: 243 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/OffloadPolicies.java x: 4 # contributors y: 69 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/JCloudLedgerOffloaderFactory.java x: 10 # contributors y: 47 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreManagedLedgerOffloader.java x: 19 # contributors y: 636 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/qos/AsyncTokenBucket.java x: 1 # contributors y: 122 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroup.java x: 8 # contributors y: 499 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiterImpl.java x: 5 # contributors y: 126 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherSingleActiveConsumer.java x: 22 # contributors y: 82 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiter.java x: 21 # contributors y: 122 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumersClassic.java x: 2 # contributors y: 1050 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java x: 42 # contributors y: 501 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/SubscribeRateLimiter.java x: 12 # contributors y: 151 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/RateLimitFunction.java x: 3 # contributors y: 4 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPersistentTopics.java x: 23 # contributors y: 559 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java x: 60 # contributors y: 2527 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java x: 5 # contributors y: 629 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java x: 18 # contributors y: 397 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Topic.java x: 48 # contributors y: 181 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TransportCnx.java x: 14 # contributors y: 42 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ProducerConfigurationData.java x: 23 # contributors y: 220 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Markers.java x: 11 # contributors y: 225 lines of code pulsar-common/src/main/proto/PulsarApi.proto x: 47 # contributors y: 928 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java x: 53 # contributors y: 1092 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java x: 18 # contributors y: 565 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LoadManagerShared.java x: 21 # contributors y: 593 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java x: 44 # contributors y: 902 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ShadowManagedLedgerImpl.java x: 7 # contributors y: 321 lines of code pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawBatchMessageContainerImpl.java x: 3 # contributors y: 131 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java x: 38 # contributors y: 673 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarRegistrationClient.java x: 8 # contributors y: 281 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConfiguration.java x: 38 # contributors y: 879 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/WebServer.java x: 22 # contributors y: 373 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/MetaStoreImpl.java x: 18 # contributors y: 467 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java x: 27 # contributors y: 527 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/RangeCache.java x: 14 # contributors y: 321 lines of code pulsar-client-auth-athenz/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationAthenz.java x: 12 # contributors y: 219 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java x: 63 # contributors y: 2968 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java x: 76 # contributors y: 4831 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TopicTransactionBuffer.java x: 15 # contributors y: 662 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java x: 27 # contributors y: 388 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/SameAuthParamsLookupAutoClusterFailover.java x: 2 # contributors y: 302 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerFactoryConfig.java x: 15 # contributors y: 37 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryImpl.java x: 36 # contributors y: 1272 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java x: 23 # contributors y: 191 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaExecutionResult.java x: 6 # contributors y: 8 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstance.java x: 16 # contributors y: 175 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/ComponentStatsManager.java x: 10 # contributors y: 103 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/FunctionStatsManager.java x: 10 # contributors y: 351 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/SinkStatsManager.java x: 10 # contributors y: 266 lines of code pulsar-functions/instance/src/main/resources/findbugsExclude.xml x: 5 # contributors y: 543 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java x: 33 # contributors y: 1176 lines of code testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockBookKeeper.java x: 11 # contributors y: 395 lines of code testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockLedgerHandle.java x: 8 # contributors y: 225 lines of code testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockReadHandle.java x: 4 # contributors y: 102 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerConfig.java x: 24 # contributors y: 364 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/RangeSetWrapper.java x: 10 # contributors y: 154 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionHandler.java x: 19 # contributors y: 201 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractDispatcherMultipleConsumers.java x: 14 # contributors y: 116 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/DrainingHashesTracker.java x: 1 # contributors y: 296 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationService.java x: 17 # contributors y: 187 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ReplicatedSubscriptionsController.java x: 16 # contributors y: 264 lines of code pulsar-client/src/main/resources/findbugsExclude.xml x: 8 # contributors y: 1006 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedCursor.java x: 26 # contributors y: 162 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java x: 26 # contributors y: 326 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/TransactionBufferSnapshotBaseSystemTopicClient.java x: 4 # contributors y: 169 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java x: 8 # contributors y: 605 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TableView.java x: 2 # contributors y: 70 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/TopicPoliciesSystemTopicClient.java x: 10 # contributors y: 174 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumersClassic.java x: 2 # contributors y: 469 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/NegativeAcksTracker.java x: 13 # contributors y: 147 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java x: 22 # contributors y: 483 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Authentication.java x: 7 # contributors y: 36 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java x: 18 # contributors y: 251 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java x: 21 # contributors y: 476 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdRead.java x: 3 # contributors y: 254 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarChannelInitializer.java x: 16 # contributors y: 188 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/AdminProxyHandler.java x: 17 # contributors y: 356 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/PerformanceClient.java x: 19 # contributors y: 366 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderList.java x: 12 # contributors y: 301 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/KeySharedPolicy.java x: 7 # contributors y: 81 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Range.java x: 7 # contributors y: 73 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ReaderConfigurationData.java x: 17 # contributors y: 152 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSink.java x: 17 # contributors y: 252 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSinkConfig.java x: 13 # contributors y: 111 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java x: 21 # contributors y: 169 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/BaseResources.java x: 10 # contributors y: 196 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ClientBuilder.java x: 24 # contributors y: 76 lines of code pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/AuthenticationProviderOpenID.java x: 4 # contributors y: 358 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/protocol/TokenClient.java x: 9 # contributors y: 94 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java x: 18 # contributors y: 295 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopicPolicies.java x: 18 # contributors y: 1606 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptorWithClassLoader.java x: 12 # contributors y: 262 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/web/WebService.java x: 27 # contributors y: 409 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java x: 21 # contributors y: 636 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java x: 31 # contributors y: 744 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/ClustersBase.java x: 22 # contributors y: 997 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyName.java x: 10 # contributors y: 37 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessagesImpl.java x: 7 # contributors y: 58 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/PrometheusMetricsGenerator.java x: 25 # contributors y: 448 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java x: 25 # contributors y: 316 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnershipCache.java x: 25 # contributors y: 204 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/KeyManagerProxy.java x: 5 # contributors y: 115 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerfClientUtils.java x: 13 # contributors y: 92 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowContextImpl.java x: 6 # contributors y: 131 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFunctionExecutor.java x: 9 # contributors y: 268 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractDispatcherSingleActiveConsumer.java x: 20 # contributors y: 236 lines of code tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/FileSystemManagedLedgerOffloader.java x: 13 # contributors y: 354 lines of code testmocks/src/main/java/org/apache/bookkeeper/client/BookKeeperTestClient.java x: 6 # contributors y: 99 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionPool.java x: 23 # contributors y: 394 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java x: 30 # contributors y: 458 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedProducerImpl.java x: 29 # contributors y: 422 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdClusters.java x: 14 # contributors y: 386 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ReaderBuilder.java x: 13 # contributors y: 39 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerImpl.java x: 8 # contributors y: 953 lines of code pulsar-broker/src/main/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsemble.java x: 5 # contributors y: 482 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/BinaryProtoLookupService.java x: 25 # contributors y: 410 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorTool.java x: 18 # contributors y: 149 lines of code deployment/terraform-ansible/deploy-pulsar.yaml x: 11 # contributors y: 163 lines of code distribution/io/src/assemble/io.xml x: 20 # contributors y: 59 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/offload/OffloaderUtils.java x: 12 # contributors y: 114 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/web/plugin/servlet/AdditionalServletUtils.java x: 7 # contributors y: 105 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/plugin/EntryFilterProvider.java x: 8 # contributors y: 208 lines of code pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java x: 19 # contributors y: 704 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/io/ConnectorUtils.java x: 9 # contributors y: 135 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/service/WorkerServiceLoader.java x: 8 # contributors y: 107 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/NamespacesImpl.java x: 38 # contributors y: 1689 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigurationData.java x: 38 # contributors y: 395 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/ConsumerStats.java x: 9 # contributors y: 34 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/ConsumerStatsImpl.java x: 12 # contributors y: 87 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/AbstractDelayedDeliveryTracker.java x: 2 # contributors y: 93 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeAutoSplitStickyKeyConsumerSelector.java x: 11 # contributors y: 144 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeExclusiveStickyKeyConsumerSelector.java x: 8 # contributors y: 142 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PendingAcksMap.java x: 1 # contributors y: 249 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentStickyKeyDispatcherMultipleConsumers.java x: 14 # contributors y: 164 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/TransactionMetadataStoreService.java x: 18 # contributors y: 438 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java x: 58 # contributors y: 2346 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderBuilderImpl.java x: 19 # contributors y: 226 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SchemasResourceBase.java x: 14 # contributors y: 212 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/SchemasResource.java x: 16 # contributors y: 326 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SchemasImpl.java x: 15 # contributors y: 310 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/OpenLongPairRangeSet.java x: 3 # contributors y: 347 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TableViewImpl.java x: 11 # contributors y: 340 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/SecurityUtility.java x: 20 # contributors y: 466 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerWrapper.java x: 3 # contributors y: 110 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/store/TableViewLoadDataStoreImpl.java x: 3 # contributors y: 223 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/AbstractCmdConsume.java x: 4 # contributors y: 227 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBase.java x: 17 # contributors y: 130 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketService.java x: 23 # contributors y: 264 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/NonPersistentTopics.java x: 41 # contributors y: 599 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TransactionAggregator.java x: 9 # contributors y: 243 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateTableViewSyncer.java x: 1 # contributors y: 219 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/store/LoadDataStore.java x: 2 # contributors y: 24 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/LoadManager.java x: 17 # contributors y: 77 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/client/opensearch/OpenSearchHighLevelRestClient.java x: 4 # contributors y: 300 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerInterceptor.java x: 8 # contributors y: 19 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerFactory.java x: 16 # contributors y: 50 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerOfflineBacklog.java x: 11 # contributors y: 77 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpFindNewest.java x: 11 # contributors y: 117 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ReadOnlyCursorImpl.java x: 8 # contributors y: 50 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java x: 28 # contributors y: 216 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckStore.java x: 10 # contributors y: 440 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/PendingAckHandleImpl.java x: 16 # contributors y: 942 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/AbstractTwoPhaseCompactor.java x: 2 # contributors y: 373 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/EventTimeOrderCompactor.java x: 2 # contributors y: 127 lines of code pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataSetup.java x: 28 # contributors y: 409 lines of code pulsar-client-messagecrypto-bc/src/main/java/org/apache/pulsar/client/impl/crypto/MessageCryptoBc.java x: 12 # contributors y: 427 lines of code pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/JwksCache.java x: 2 # contributors y: 189 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderBasic.java x: 9 # contributors y: 166 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderToken.java x: 19 # contributors y: 344 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionBuffer.java x: 12 # contributors y: 33 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/SimpleLoadManagerImpl.java x: 25 # contributors y: 1163 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/StrategicTwoPhaseCompactor.java x: 3 # contributors y: 386 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarChannelInitializer.java x: 21 # contributors y: 109 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/PulsarAdminTool.java x: 32 # contributors y: 253 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/PulsarClientTool.java x: 23 # contributors y: 202 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/ClusterDataImpl.java x: 10 # contributors y: 385 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/WorkerServer.java x: 19 # contributors y: 280 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ServiceChannelInitializer.java x: 18 # contributors y: 94 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/service/ProxyServer.java x: 16 # contributors y: 230 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyServiceStarter.java x: 34 # contributors y: 386 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/LookupService.java x: 11 # contributors y: 32 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionCoordinatorClientImpl.java x: 14 # contributors y: 226 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/FunctionsImpl.java x: 17 # contributors y: 644 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/PackagesImpl.java x: 7 # contributors y: 172 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SinksImpl.java x: 12 # contributors y: 390 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SourcesImpl.java x: 11 # contributors y: 312 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/LeaderElectionImpl.java x: 10 # contributors y: 294 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/BaseResource.java x: 16 # contributors y: 309 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/BookiesImpl.java x: 10 # contributors y: 65 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java x: 52 # contributors y: 2397 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TransactionsImpl.java x: 8 # contributors y: 245 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdBase.java x: 15 # contributors y: 83 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/PulsarZooKeeperClient.java x: 8 # contributors y: 1253 lines of code pulsar-opentelemetry/src/main/java/org/apache/pulsar/opentelemetry/OpenTelemetryAttributes.java x: 1 # contributors y: 138 lines of code pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java x: 6 # contributors y: 252 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ConsumerHandler.java x: 26 # contributors y: 422 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/OpenTelemetryTopicStats.java x: 1 # contributors y: 343 lines of code pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStore.java x: 13 # contributors y: 513 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/LocalMemoryMetadataStore.java x: 15 # contributors y: 212 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/RocksdbMetadataStore.java x: 15 # contributors y: 521 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java x: 27 # contributors y: 627 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java x: 25 # contributors y: 290 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionImpl.java x: 9 # contributors y: 212 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/BrokerMonitor.java x: 13 # contributors y: 420 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeUtils.java x: 22 # contributors y: 463 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryImpl.java x: 12 # contributors y: 168 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorContainer.java x: 15 # contributors y: 292 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TransactionsBase.java x: 10 # contributors y: 522 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Subscription.java x: 19 # contributors y: 74 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/PendingAckStore.java x: 4 # contributors y: 17 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckReplyCallBack.java x: 6 # contributors y: 95 lines of code pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionLogImpl.java x: 11 # contributors y: 333 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/EtcdMetadataStore.java x: 8 # contributors y: 439 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/BKCluster.java x: 8 # contributors y: 303 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/data/BrokerLoadData.java x: 4 # contributors y: 190 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/manager/UnloadManager.java x: 5 # contributors y: 183 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java x: 22 # contributors y: 203 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/OpenTelemetryConsumerStats.java x: 1 # contributors y: 97 lines of code pulsar-broker/src/main/java/org/apache/pulsar/utils/auth/tokens/TokensCliUtils.java x: 14 # contributors y: 267 lines of code pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/LocalBrokerData.java x: 18 # contributors y: 384 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/nar/NarClassLoader.java x: 15 # contributors y: 152 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Topics.java x: 26 # contributors y: 680 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/FunctionsBase.java x: 21 # contributors y: 744 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinksBase.java x: 16 # contributors y: 539 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourcesBase.java x: 17 # contributors y: 491 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/ResourceQuotas.java x: 8 # contributors y: 137 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v3/Packages.java x: 4 # contributors y: 214 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/AvroSchemaBasedCompatibilityCheck.java x: 12 # contributors y: 72 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/NamespaceResources.java x: 20 # contributors y: 307 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarDecoder.java x: 16 # contributors y: 587 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java x: 28 # contributors y: 709 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java x: 25 # contributors y: 639 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/service/WebSocketProxyConfiguration.java x: 24 # contributors y: 201 lines of code pulsar-broker/src/main/java/org/apache/pulsar/common/naming/NamespaceBundleFactory.java x: 18 # contributors y: 330 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/LoadSimulationController.java x: 12 # contributors y: 532 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java x: 38 # contributors y: 473 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java x: 41 # contributors y: 659 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java x: 27 # contributors y: 184 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTopicListArguments.java x: 2 # contributors y: 43 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTransaction.java x: 12 # contributors y: 556 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/web/JettyRequestLogFactory.java x: 3 # contributors y: 168 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java x: 31 # contributors y: 867 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBackedReadHandleImplV2.java x: 10 # contributors y: 295 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java x: 18 # contributors y: 270 lines of code pulsar-broker/src/main/java/org/apache/pulsar/PulsarBrokerStarter.java x: 26 # contributors y: 308 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentBitSet.java x: 7 # contributors y: 371 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroupConfigListener.java x: 6 # contributors y: 143 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroupService.java x: 10 # contributors y: 585 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/JavaInstanceStarter.java x: 16 # contributors y: 409 lines of code pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java x: 27 # contributors y: 225 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CliCommand.java x: 16 # contributors y: 122 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdBrokers.java x: 16 # contributors y: 140 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/shell/PulsarShell.java x: 3 # contributors y: 514 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ProducerHandler.java x: 19 # contributors y: 435 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/AutoClusterFailover.java x: 6 # contributors y: 314 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionActioner.java x: 19 # contributors y: 620 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java x: 25 # contributors y: 773 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java x: 19 # contributors y: 544 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java x: 25 # contributors y: 1601 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.java x: 24 # contributors y: 654 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SinksImpl.java x: 19 # contributors y: 660 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SourcesImpl.java x: 19 # contributors y: 606 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntime.java x: 15 # contributors y: 274 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/BitSetRecyclable.java x: 5 # contributors y: 524 lines of code pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/LoadReport.java x: 7 # contributors y: 380 lines of code docker/pulsar/scripts/apply-config-from-env.py x: 12 # contributors y: 56 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/BKStateStoreImpl.java x: 6 # contributors y: 168 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicPoliciesImpl.java x: 11 # contributors y: 1074 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptors.java x: 13 # contributors y: 230 lines of code pulsar-io/alluxio/src/main/java/org/apache/pulsar/io/alluxio/sink/AlluxioSink.java x: 3 # contributors y: 280 lines of code pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfig.java x: 6 # contributors y: 180 lines of code pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcAbstractSink.java x: 6 # contributors y: 320 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java x: 14 # contributors y: 133 lines of code pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoSink.java x: 8 # contributors y: 161 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java x: 47 # contributors y: 1063 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/keystoretls/KeyStoreSSLContext.java x: 9 # contributors y: 287 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/NonPersistentTopics.java x: 29 # contributors y: 264 lines of code pulsar-client-auth-sasl/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationSasl.java x: 8 # contributors y: 269 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/MultiRolesTokenAuthorizationProvider.java x: 13 # contributors y: 250 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java x: 40 # contributors y: 1651 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/ClusterResources.java x: 7 # contributors y: 191 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationDataTls.java x: 10 # contributors y: 121 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerManager.java x: 5 # contributors y: 383 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java x: 16 # contributors y: 379 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerUnderreplicationManager.java x: 6 # contributors y: 917 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongHashMap.java x: 10 # contributors y: 472 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongLongPairHashMap.java x: 4 # contributors y: 510 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongPairSet.java x: 11 # contributors y: 525 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java x: 15 # contributors y: 127 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/LongHierarchicalLedgerRangeIterator.java x: 4 # contributors y: 122 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarRegistrationManager.java x: 5 # contributors y: 331 lines of code pulsar-functions/instance/src/main/python/python_instance.py x: 11 # contributors y: 482 lines of code pulsar-io/core/src/main/java/org/apache/pulsar/io/core/PushSource.java x: 10 # contributors y: 12 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PackagesBase.java x: 5 # contributors y: 169 lines of code pulsar-package-management/core/src/main/java/org/apache/pulsar/packages/management/core/impl/PackagesManagementImpl.java x: 5 # contributors y: 221 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlockAwareSegmentInputStreamImpl.java x: 10 # contributors y: 253 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ReaderHandler.java x: 16 # contributors y: 286 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesSecretsTokenAuthProvider.java x: 13 # contributors y: 330 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/MutableBucket.java x: 2 # contributors y: 175 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageIdImpl.java x: 14 # contributors y: 139 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Functions.java x: 12 # contributors y: 287 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/WorkerImpl.java x: 13 # contributors y: 275 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionsApiV2Resource.java x: 7 # contributors y: 284 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionsApiV3Resource.java x: 13 # contributors y: 377 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ZeroQueueConsumerImpl.java x: 18 # contributors y: 164 lines of code pulsar-function-go/pb/Function.pb.go x: 7 # contributors y: 2010 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema/KafkaConnectData.java x: 4 # contributors y: 333 lines of code pulsar-functions/instance/src/main/python/contextimpl.py x: 12 # contributors y: 179 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AutoConsumeSchema.java x: 17 # contributors y: 305 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSourceConfig.java x: 9 # contributors y: 18 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/BasicKubernetesManifestCustomizer.java x: 10 # contributors y: 214 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/client/RestClient.java x: 3 # contributors y: 214 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerUtils.java x: 16 # contributors y: 367 lines of code pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/TxnLogBufferedWriter.java x: 5 # contributors y: 410 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/Worker.java x: 17 # contributors y: 93 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java x: 18 # contributors y: 278 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java x: 15 # contributors y: 690 lines of code pulsar-io/http/src/main/java/org/apache/pulsar/io/http/JsonConverter.java x: 1 # contributors y: 206 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/DefaultImplementation.java x: 18 # contributors y: 18 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/batch/BatchSourceExecutor.java x: 5 # contributors y: 269 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/process/ProcessRuntime.java x: 12 # contributors y: 354 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerService.java x: 16 # contributors y: 32 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/JsonConverter.java x: 5 # contributors y: 206 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexBlockImpl.java x: 11 # contributors y: 278 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexBlockV2Impl.java x: 3 # contributors y: 295 lines of code pulsar-function-go/pf/stats.go x: 7 # contributors y: 300 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java x: 3 # contributors y: 471 lines of code pulsar-function-go/pb/InstanceCommunication.pb.go x: 4 # contributors y: 1022 lines of code
4990.0
lines of code
  min: 1.0
  average: 113.8
  25th percentile: 10.0
  median: 36.0
  75th percentile: 97.0
  max: 4990.0
0 111.0
# contributors
min: 1.0 | average: 6.23 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 7.0 | max: 111.0