apache / kafka
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 3,535 files with 397,157 lines of code.
    • 47 files changed more than 100 times (55,865 lines of code)
    • 75 files changed 51-100 times (40,487 lines of code)
    • 245 files changed 21-50 times (64,321 lines of code)
    • 967 files changed 6-20 times (125,301 lines of code)
    • 2,201 files changed 1-5 times (111,183 lines of code)
14% | 10% | 16% | 31% | 27%
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 3,535 files with 397,157 lines of code.
    • 119 files changed by more than 25 contributors (90,321 lines of code)
    • 367 files changed by 11-25 contributors (91,327 lines of code)
    • 611 files changed by 6-10 contributors (76,691 lines of code)
    • 1,638 files changed by 2-5 contributors (113,652 lines of code)
    • 800 files changed by 1 contributor (25,166 lines of code)
22% | 22% | 19% | 28% | 6%
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, scala, json, py, yaml, html, sh, properties, bat, xml, md, gitignore, txt, gradle, cfg, svg, js, xsl, in, rdf, pub
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java11% | 9% | 16% | 32% | 29%
scala48% | 18% | 15% | 14% | 3%
xml0% | 91% | 0% | 0% | 8%
py0% | 0% | 0% | 16% | 83%
yaml0% | 0% | 0% | 0% | 100%
xsl0% | 0% | 0% | 0% | 100%
rdf0% | 0% | 0% | 0% | 100%
html0% | 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
streams18% | 10% | 21% | 33% | 16%
clients13% | 11% | 16% | 29% | 28%
core42% | 24% | 16% | 12% | 4%
group-coordinator26% | 12% | 15% | 21% | 24%
raft24% | 0% | 19% | 35% | 20%
connect5% | 13% | 22% | 38% | 20%
metadata7% | 12% | 12% | 39% | 27%
gradle0% | 66% | 0% | 0% | 33%
jmh-benchmarks0% | 5% | 13% | 27% | 53%
server-common0% | 2% | 0% | 38% | 59%
storage0% | 0% | 11% | 38% | 50%
generator0% | 0% | 30% | 36% | 32%
tools0% | 0% | 10% | 49% | 40%
server0% | 0% | 0% | 41% | 58%
share-coordinator0% | 0% | 0% | 75% | 24%
coordinator-common0% | 0% | 0% | 53% | 46%
shell0% | 0% | 0% | 27% | 72%
trogdor0% | 0% | 0% | 4% | 95%
release0% | 0% | 0% | 38% | 61%
committer-tools0% | 0% | 0% | 0% | 100%
transaction-coordinator0% | 0% | 0% | 0% | 100%
docker0% | 0% | 0% | 0% | 100%
config0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
test-common0% | 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
KafkaApis.scala
in core/src/main/scala/kafka/server
 3343 94 2012-01-13 2025-05-01 615 148 nehanarkhede@apache.org cwadhwa@confluent.io
KafkaConfig.scala
in core/src/main/scala/kafka/server
 607 24 2011-08-10 2025-04-30 466 172 hsaputra@apache.org payang@apache.org
ReplicaManager.scala
in core/src/main/scala/kafka/server
 2203 86 2012-03-23 2025-04-29 444 123 nehanarkhede@apache.org o.g.h.ibrahim@gmail.com
StreamThread.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1511 68 2015-09-26 2025-04-30 352 77 wangguoz@gmail.com bbejeck@apache.org
KafkaConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 290 57 2014-05-20 2025-05-04 298 130 neha.narkhede@gmail.com s7133700@gmail.com
Partition.scala
in core/src/main/scala/kafka/cluster
 1320 75 2011-08-10 2025-05-01 292 92 hsaputra@apache.org 79797958+mirai1129@users.no...
KafkaAdminClient.java
in clients/src/main/java/org/apache/kafka/clients/admin
 4131 156 2017-05-01 2025-05-07 252 103 cmccabe@confluent.io yunchipang@gmail.com
KafkaProducer.java
in clients/src/main/java/org/apache/kafka/clients/producer
 831 47 2014-02-07 2025-04-24 242 118 junrao@gmail.com 98577846+rreddy-22@users.no...
StreamsConfig.java
in streams/src/main/java/org/apache/kafka/streams
 1371 49 2016-01-22 2025-04-09 239 90 wangguoz@gmail.com cadonna@apache.org
StreamTask.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1027 69 2015-09-26 2025-04-25 233 58 wangguoz@gmail.com 107070585+aliehsaeedii@user...
LogManager.scala
in core/src/main/scala/kafka/log
 1098 58 2011-08-10 2025-04-27 232 87 hsaputra@apache.org payang@apache.org
KafkaStreams.java
in streams/src/main/java/org/apache/kafka/streams
 1397 81 2016-01-22 2025-04-25 227 77 wangguoz@gmail.com lbrutschy@confluent.io
SocketServer.scala
in core/src/main/scala/kafka/network
 1249 87 2011-08-10 2025-04-30 200 84 hsaputra@apache.org payang@apache.org
TaskManager.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1727 116 2017-08-11 2025-04-25 199 36 damian.guy@gmail.com 107070585+aliehsaeedii@user...
Fetcher.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 118 10 2015-03-10 2025-04-29 196 65 wangguoz@gmail.com matthias@confluent.io
BrokerServer.scala
in core/src/main/scala/kafka/server
 642 9 2021-01-16 2025-05-06 196 66 jason@confluent.io jsancio@users.noreply.githu...
ConsumerCoordinator.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1203 56 2015-10-21 2025-04-27 173 57 jason@confluent.io david.jacot@gmail.com
ReplicaFetcherThread.scala
in core/src/main/scala/kafka/server
 120 11 2012-06-01 2025-04-01 164 72 nehanarkhede@apache.org ismael@juma.me.uk
RequestChannel.scala
in core/src/main/scala/kafka/network
 372 15 2012-01-13 2025-04-12 158 60 nehanarkhede@apache.org parkerhiphop027@gmail.com
AbstractFetcherThread.scala
in core/src/main/scala/kafka/server
 680 37 2012-06-23 2025-05-01 157 70 junrao@apache.org 79797958+mirai1129@users.no...
KStreamImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1118 80 2015-09-26 2025-02-24 154 49 wangguoz@gmail.com sebastien.viale@michelin.com
AbstractCoordinator.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1170 83 2015-10-21 2025-04-06 154 55 jason@confluent.io kitingiao@gmail.com
Sender.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 796 41 2014-02-07 2025-04-29 151 54 jay.kreps@gmail.com o.g.h.ibrahim@gmail.com
Utils.java
in clients/src/main/java/org/apache/kafka/common/utils
 924 89 2014-02-07 2025-04-29 149 90 junrao@gmail.com o.g.h.ibrahim@gmail.com
NetworkClient.java
in clients/src/main/java/org/apache/kafka/clients
 1124 87 2014-06-11 2025-01-16 141 60 jay.kreps@gmail.com s7133700@gmail.com
ProducerConfig.java
in clients/src/main/java/org/apache/kafka/clients/producer
 528 11 2014-02-07 2025-04-24 137 73 junrao@gmail.com 98577846+rreddy-22@users.no...
ApiKeys.java
in clients/src/main/java/org/apache/kafka/common/protocol
 284 26 2014-02-07 2025-03-31 136 50 junrao@gmail.com ismael@juma.me.uk
KTableImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1174 68 2015-12-04 2025-03-04 136 38 yasuhiro@confluent.io lbrutschy@confluent.io
KStream.java
in streams/src/main/java/org/apache/kafka/streams/kstream
 183 - 2015-09-26 2025-02-14 134 49 wangguoz@gmail.com matthias@confluent.io
RocksDBStore.java
in streams/src/main/java/org/apache/kafka/streams/state/internals
 793 58 2016-01-21 2024-12-20 130 43 wangguoz@gmail.com matthias@confluent.io
Errors.java
in clients/src/main/java/org/apache/kafka/common/protocol
 492 12 2014-02-07 2025-05-06 129 61 junrao@gmail.com aschofield@confluent.io
DistributedHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed
 2304 127 2015-11-09 2025-04-14 128 56 me@ewencp.org mimaison@users.noreply.gith...
QuorumController.java
in metadata/src/main/java/org/apache/kafka/controller
 1654 110 2021-02-20 2025-05-01 127 40 cmccabe@confluent.io 79797958+mirai1129@users.no...
TopologyTestDriver.java
in streams/test-utils/src/main/java/org/apache/kafka/streams
 858 72 2018-01-30 2025-04-25 126 37 mjsax@apache.org 107070585+aliehsaeedii@user...
DumpLogSegments.scala
in core/src/main/scala/kafka/tools
 566 26 2011-08-23 2025-03-13 121 55 nehanarkhede@apache.org mimaison@users.noreply.gith...
ConsumerConfig.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 574 13 2014-05-20 2025-04-17 119 71 neha.narkhede@gmail.com loganzhu96@outlook.com
ProcessorStateManager.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 592 46 2015-09-26 2024-12-20 118 35 wangguoz@gmail.com matthias@confluent.io
KafkaRaftClient.java
in raft/src/main/java/org/apache/kafka/raft
 3122 152 2020-09-22 2025-05-06 118 47 jason@confluent.io jsancio@users.noreply.githu...
DynamicBrokerConfig.scala
in core/src/main/scala/kafka/server
 851 62 2018-01-23 2025-05-06 115 46 rajinisivaram@googlemail.com jsancio@users.noreply.githu...
StreamsPartitionAssignor.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1257 48 2018-02-26 2025-02-26 115 35 wangguoz@gmail.com ableegoldman@gmail.com
RecordAccumulator.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 731 53 2014-02-07 2025-04-11 114 55 junrao@gmail.com jhenyunghsu@gmail.com
ConfigCommand.scala
in core/src/main/scala/kafka/admin
 582 18 2015-08-04 2025-04-20 113 57 aauradkar@linkedin.com gongxuanzhangmelt@gmail.com
AbstractResponse.java
in clients/src/main/java/org/apache/kafka/common/requests
 262 14 2016-11-15 2025-04-24 112 43 jason@confluent.io vikas@confluent.io
ControllerServer.scala
in core/src/main/scala/kafka/server
 379 4 2021-01-16 2025-04-30 112 34 jason@confluent.io payang@apache.org
InternalTopologyBuilder.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1852 162 2017-07-24 2025-02-24 112 47 matthias@confluent.io sebastien.viale@michelin.com
GroupMetadataManager.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group
 5425 228 2023-05-31 2025-05-02 112 26 djacot@confluent.io smahajan@confluent.io
Selector.java
in clients/src/main/java/org/apache/kafka/common/network
 1030 80 2014-02-07 2024-11-06 107 55 junrao@gmail.com yungyung7654321@gmail.com
TransactionManager.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 1385 130 2017-04-27 2025-04-24 100 33 apurva@confluent.io 98577846+rreddy-22@users.no...
SubscriptionState.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 954 143 2015-01-11 2025-02-04 98 42 jay.kreps@gmail.com squah@confluent.io
Worker.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1718 94 2015-11-09 2025-04-24 98 46 me@ewencp.org snehashisp1995@gmail.com
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
KafkaConfig.scala
in core/src/main/scala/kafka/server
 607 24 2011-08-10 2025-04-30 466 172 hsaputra@apache.org payang@apache.org
KafkaApis.scala
in core/src/main/scala/kafka/server
 3343 94 2012-01-13 2025-05-01 615 148 nehanarkhede@apache.org cwadhwa@confluent.io
KafkaConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 290 57 2014-05-20 2025-05-04 298 130 neha.narkhede@gmail.com s7133700@gmail.com
ReplicaManager.scala
in core/src/main/scala/kafka/server
 2203 86 2012-03-23 2025-04-29 444 123 nehanarkhede@apache.org o.g.h.ibrahim@gmail.com
KafkaProducer.java
in clients/src/main/java/org/apache/kafka/clients/producer
 831 47 2014-02-07 2025-04-24 242 118 junrao@gmail.com 98577846+rreddy-22@users.no...
KafkaAdminClient.java
in clients/src/main/java/org/apache/kafka/clients/admin
 4131 156 2017-05-01 2025-05-07 252 103 cmccabe@confluent.io yunchipang@gmail.com
Partition.scala
in core/src/main/scala/kafka/cluster
 1320 75 2011-08-10 2025-05-01 292 92 hsaputra@apache.org 79797958+mirai1129@users.no...
StreamsConfig.java
in streams/src/main/java/org/apache/kafka/streams
 1371 49 2016-01-22 2025-04-09 239 90 wangguoz@gmail.com cadonna@apache.org
Utils.java
in clients/src/main/java/org/apache/kafka/common/utils
 924 89 2014-02-07 2025-04-29 149 90 junrao@gmail.com o.g.h.ibrahim@gmail.com
LogManager.scala
in core/src/main/scala/kafka/log
 1098 58 2011-08-10 2025-04-27 232 87 hsaputra@apache.org payang@apache.org
SocketServer.scala
in core/src/main/scala/kafka/network
 1249 87 2011-08-10 2025-04-30 200 84 hsaputra@apache.org payang@apache.org
StreamThread.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1511 68 2015-09-26 2025-04-30 352 77 wangguoz@gmail.com bbejeck@apache.org
KafkaStreams.java
in streams/src/main/java/org/apache/kafka/streams
 1397 81 2016-01-22 2025-04-25 227 77 wangguoz@gmail.com lbrutschy@confluent.io
ProducerConfig.java
in clients/src/main/java/org/apache/kafka/clients/producer
 528 11 2014-02-07 2025-04-24 137 73 junrao@gmail.com 98577846+rreddy-22@users.no...
ReplicaFetcherThread.scala
in core/src/main/scala/kafka/server
 120 11 2012-06-01 2025-04-01 164 72 nehanarkhede@apache.org ismael@juma.me.uk
ConsumerConfig.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 574 13 2014-05-20 2025-04-17 119 71 neha.narkhede@gmail.com loganzhu96@outlook.com
AbstractFetcherThread.scala
in core/src/main/scala/kafka/server
 680 37 2012-06-23 2025-05-01 157 70 junrao@apache.org 79797958+mirai1129@users.no...
BrokerServer.scala
in core/src/main/scala/kafka/server
 642 9 2021-01-16 2025-05-06 196 66 jason@confluent.io jsancio@users.noreply.githu...
Fetcher.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 118 10 2015-03-10 2025-04-29 196 65 wangguoz@gmail.com matthias@confluent.io
Errors.java
in clients/src/main/java/org/apache/kafka/common/protocol
 492 12 2014-02-07 2025-05-06 129 61 junrao@gmail.com aschofield@confluent.io
RequestChannel.scala
in core/src/main/scala/kafka/network
 372 15 2012-01-13 2025-04-12 158 60 nehanarkhede@apache.org parkerhiphop027@gmail.com
NetworkClient.java
in clients/src/main/java/org/apache/kafka/clients
 1124 87 2014-06-11 2025-01-16 141 60 jay.kreps@gmail.com s7133700@gmail.com
StreamTask.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1027 69 2015-09-26 2025-04-25 233 58 wangguoz@gmail.com 107070585+aliehsaeedii@user...
ConsumerCoordinator.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1203 56 2015-10-21 2025-04-27 173 57 jason@confluent.io david.jacot@gmail.com
ConfigCommand.scala
in core/src/main/scala/kafka/admin
 582 18 2015-08-04 2025-04-20 113 57 aauradkar@linkedin.com gongxuanzhangmelt@gmail.com
DistributedHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed
 2304 127 2015-11-09 2025-04-14 128 56 me@ewencp.org mimaison@users.noreply.gith...
AbstractCoordinator.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1170 83 2015-10-21 2025-04-06 154 55 jason@confluent.io kitingiao@gmail.com
DumpLogSegments.scala
in core/src/main/scala/kafka/tools
 566 26 2011-08-23 2025-03-13 121 55 nehanarkhede@apache.org mimaison@users.noreply.gith...
RecordAccumulator.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 731 53 2014-02-07 2025-04-11 114 55 junrao@gmail.com jhenyunghsu@gmail.com
Selector.java
in clients/src/main/java/org/apache/kafka/common/network
 1030 80 2014-02-07 2024-11-06 107 55 junrao@gmail.com yungyung7654321@gmail.com
Sender.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 796 41 2014-02-07 2025-04-29 151 54 jay.kreps@gmail.com o.g.h.ibrahim@gmail.com
ConfigDef.java
in clients/src/main/java/org/apache/kafka/common/config
 1043 104 2014-02-07 2024-11-22 80 53 junrao@gmail.com mimaison@users.noreply.gith...
ApiKeys.java
in clients/src/main/java/org/apache/kafka/common/protocol
 284 26 2014-02-07 2025-03-31 136 50 junrao@gmail.com ismael@juma.me.uk
Admin.java
in clients/src/main/java/org/apache/kafka/clients/admin
 351 70 2019-07-22 2025-04-25 66 50 8012398+big-andy-coates@use... 122860692+chirag-wadhwa5@us...
KStreamImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1118 80 2015-09-26 2025-02-24 154 49 wangguoz@gmail.com sebastien.viale@michelin.com
KStream.java
in streams/src/main/java/org/apache/kafka/streams/kstream
 183 - 2015-09-26 2025-02-14 134 49 wangguoz@gmail.com matthias@confluent.io
KafkaRaftClient.java
in raft/src/main/java/org/apache/kafka/raft
 3122 152 2020-09-22 2025-05-06 118 47 jason@confluent.io jsancio@users.noreply.githu...
InternalTopologyBuilder.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1852 162 2017-07-24 2025-02-24 112 47 matthias@confluent.io sebastien.viale@michelin.com
MockConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 557 77 2014-05-20 2025-05-03 87 47 neha.narkhede@gmail.com matthias@confluent.io
DynamicBrokerConfig.scala
in core/src/main/scala/kafka/server
 851 62 2018-01-23 2025-05-06 115 46 rajinisivaram@googlemail.com jsancio@users.noreply.githu...
Worker.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1718 94 2015-11-09 2025-04-24 98 46 me@ewencp.org snehashisp1995@gmail.com
AbstractConfig.java
in clients/src/main/java/org/apache/kafka/common/config
 420 46 2014-02-07 2025-03-23 69 45 junrao@gmail.com tjwu1217@gmail.com
WorkerSinkTask.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 754 58 2015-11-09 2025-04-24 84 44 me@ewencp.org snehashisp1995@gmail.com
CommonClientConfigs.java
in clients/src/main/java/org/apache/kafka/clients
 242 7 2015-01-11 2025-04-30 58 44 jay.kreps@gmail.com 98415067+lianetm@users.nore...
RocksDBStore.java
in streams/src/main/java/org/apache/kafka/streams/state/internals
 793 58 2016-01-21 2024-12-20 130 43 wangguoz@gmail.com matthias@confluent.io
AbstractResponse.java
in clients/src/main/java/org/apache/kafka/common/requests
 262 14 2016-11-15 2025-04-24 112 43 jason@confluent.io vikas@confluent.io
SubscriptionState.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 954 143 2015-01-11 2025-02-04 98 42 jay.kreps@gmail.com squah@confluent.io
AbstractRequest.java
in clients/src/main/java/org/apache/kafka/common/requests
 285 21 2015-03-28 2025-03-26 88 41 cshapi@gmail.com vikas@confluent.io
MockProducer.java
in clients/src/main/java/org/apache/kafka/clients/producer
 431 43 2014-02-07 2025-04-24 57 41 junrao@gmail.com 98577846+rreddy-22@users.no...
QuorumController.java
in metadata/src/main/java/org/apache/kafka/controller
 1654 110 2021-02-20 2025-05-01 127 40 cmccabe@confluent.io 79797958+mirai1129@users.no...
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
VerifiableShareConsumer.java
in tools/src/main/java/org/apache/kafka/tools
 514 43 2025-01-17 2025-03-06 2 1 122860692+chirag-wadhwa5@us... 122860692+chirag-wadhwa5@us...
LogCleanerManager.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 502 29 2025-03-27 2025-04-11 2 1 grimekillah@gmail.com grimekillah@gmail.com
Cleaner.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 462 13 2025-04-11 2025-04-11 1 1 grimekillah@gmail.com grimekillah@gmail.com
ShareConsumeBenchWorker.java
in trogdor/src/main/java/org/apache/kafka/trogdor/workload
 406 31 2024-12-05 2024-12-05 1 1 shr@confluent.io shr@confluent.io
RoundTripWorkerBase.java
in trogdor/src/main/java/org/apache/kafka/trogdor/workload
 370 17 2024-11-07 2024-11-07 1 1 shr@confluent.io shr@confluent.io
Murmur3.java
in streams/src/main/java/org/apache/kafka/streams/state/internals
 367 21 2019-09-19 2019-09-19 1 1 wangguoz@gmail.com wangguoz@gmail.com
StreamsGroupCommand.java
in tools/src/main/java/org/apache/kafka/tools/streams
 331 25 2025-04-09 2025-04-28 3 1 107070585+aliehsaeedii@user... 107070585+aliehsaeedii@user...
StreamsGroupMemberDescription.java
in clients/src/main/java/org/apache/kafka/clients/admin
 252 32 2025-03-07 2025-03-07 1 1 lbrutschy@confluent.io lbrutschy@confluent.io
CoordinatorRecordTypeGenerator.java
in generator/src/main/java/org/apache/kafka/message
 220 15 2024-12-20 2025-01-10 2 1 david.jacot@gmail.com david.jacot@gmail.com
AsyncConsumerMetrics.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics
 219 12 2024-12-13 2024-12-13 1 1 payang@apache.org payang@apache.org
TargetAssignmentBuilder.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams
 187 12 2025-02-03 2025-02-03 1 1 lbrutschy@confluent.io lbrutschy@confluent.io
CoordinatorRecordJsonConvertersGenerator.java
in generator/src/main/java/org/apache/kafka/message
 173 8 2025-01-10 2025-01-10 1 1 david.jacot@gmail.com david.jacot@gmail.com
Acknowledgements.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 167 18 2024-07-16 2025-02-06 2 1 aschofield@confluent.io aschofield@confluent.io
LineMessageReader.java
in tools/src/main/java/org/apache/kafka/tools
 161 7 2024-10-07 2024-10-07 1 1 grimekillah@gmail.com grimekillah@gmail.com
ShareFetchBuffer.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 157 13 2024-07-16 2024-07-16 1 1 aschofield@confluent.io aschofield@confluent.io
xsl
rat-output-to-html.xsl
in gradle/resources
 153 - 2015-07-06 2015-07-06 1 1 me@ewencp.org me@ewencp.org
EventAccumulator.java
in coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime
 149 11 2024-08-18 2024-08-18 1 1 sushant.mahajan88@gmail.com sushant.mahajan88@gmail.com
DelayedRemoteListOffsets.java
in storage/src/main/java/org/apache/kafka/server/purgatory
 146 5 2025-04-05 2025-04-05 1 1 mimaison@users.noreply.gith... mimaison@users.noreply.gith...
GlobComponent.java
in shell/src/main/java/org/apache/kafka/shell/glob
 135 7 2023-05-05 2023-05-05 1 1 cmccabe@apache.org cmccabe@apache.org
MetadataCache.java
in metadata/src/main/java/org/apache/kafka/metadata
 135 4 2025-03-17 2025-03-17 1 1 payang@apache.org payang@apache.org
RPCProducerIdManager.java
in transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction
 135 6 2024-10-30 2024-10-30 1 1 s7133700@gmail.com s7133700@gmail.com
ProspectiveState.java
in raft/src/main/java/org/apache/kafka/raft
 135 16 2025-01-17 2025-01-17 1 1 ahuang@confluent.io ahuang@confluent.io
MirrorSourceMetrics.java
in connect/mirror/src/main/java/org/apache/kafka/connect/mirror
 133 6 2022-11-30 2024-10-01 3 1 mimaison@users.noreply.gith... mimaison@users.noreply.gith...
ShareConsumeBenchSpec.java
in trogdor/src/main/java/org/apache/kafka/trogdor/workload
 130 16 2024-12-05 2025-02-11 2 1 shr@confluent.io shr@confluent.io
ShareFetchCollector.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 129 5 2024-07-16 2024-07-16 1 1 aschofield@confluent.io aschofield@confluent.io
StreamsGroupSubtopologyDescription.java
in clients/src/main/java/org/apache/kafka/clients/admin
 126 16 2025-03-07 2025-03-07 1 1 lbrutschy@confluent.io lbrutschy@confluent.io
AlterShareGroupOffsetsHandler.java
in clients/src/main/java/org/apache/kafka/clients/admin/internals
 126 4 2025-02-14 2025-02-14 1 1 48462172+jimmywang6@users.n... 48462172+jimmywang6@users.n...
ProducerStateEntry.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 124 25 2023-02-08 2023-02-08 1 1 satishd@apache.org satishd@apache.org
BufferValue.java
in streams/src/main/java/org/apache/kafka/streams/state/internals
 120 8 2019-05-30 2020-06-27 4 1 vvcephei@users.noreply.gith... vvcephei@users.noreply.gith...
TimeOrderedKeyValueBufferChangelogDeserializationHelper.java
in streams/src/main/java/org/apache/kafka/streams/state/internals
 118 10 2020-06-27 2020-06-27 1 1 vvcephei@users.noreply.gith... vvcephei@users.noreply.gith...
StreamsGroupDescription.java
in clients/src/main/java/org/apache/kafka/clients/admin
 116 13 2025-03-07 2025-03-07 1 1 lbrutschy@confluent.io lbrutschy@confluent.io
RepartitionTopics.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics
 110 5 2025-01-09 2025-01-21 2 1 lbrutschy@confluent.io lbrutschy@confluent.io
EpochElection.java
in raft/src/main/java/org/apache/kafka/raft/internals
 110 20 2025-01-17 2025-01-17 1 1 ahuang@confluent.io ahuang@confluent.io
EventPerformanceMonitor.java
in metadata/src/main/java/org/apache/kafka/controller
 109 12 2025-01-06 2025-01-06 1 1 mumrah@gmail.com mumrah@gmail.com
DeleteGroupsHandler.java
in clients/src/main/java/org/apache/kafka/clients/admin/internals
 106 5 2025-02-22 2025-02-22 1 1 smahajan@confluent.io smahajan@confluent.io
ProcessState.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor
 104 15 2025-02-03 2025-02-03 1 1 107070585+aliehsaeedii@user... 107070585+aliehsaeedii@user...
ReplicationQuotaManager.java
in core/src/main/java/kafka/server
 103 11 2024-10-30 2024-10-30 1 1 payang@apache.org payang@apache.org
ServerConfigs.java
in server-common/src/main/java/org/apache/kafka/server/config
 102 - 2025-04-11 2025-04-11 1 1 grimekillah@gmail.com grimekillah@gmail.com
OffsetResultHolder.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 102 19 2024-12-20 2024-12-20 1 1 s7133700@gmail.com s7133700@gmail.com
PartitionMetadataFile.java
in storage/src/main/java/org/apache/kafka/storage/internals/checkpoint
 101 11 2023-11-01 2024-04-13 2 1 athatikunta@confluent.io athatikunta@confluent.io
CoordinatorResult.java
in coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime
 100 14 2024-08-18 2024-08-18 1 1 sushant.mahajan88@gmail.com sushant.mahajan88@gmail.com
KafkaProducerMetrics.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 100 12 2021-08-30 2022-03-24 3 1 desai.p.rohan@gmail.com desai.p.rohan@gmail.com
DefaultStreamsRebalanceListener.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 99 6 2025-04-10 2025-04-10 1 1 cadonna@apache.org cadonna@apache.org
SharePartitionKey.java
in server-common/src/main/java/org/apache/kafka/server/share
 97 16 2025-01-16 2025-01-16 1 1 apoorvmittal10@gmail.com apoorvmittal10@gmail.com
SharePartitionMetrics.java
in server/src/main/java/org/apache/kafka/server/share/metrics
 97 12 2025-02-28 2025-02-28 1 1 apoorvmittal10@gmail.com apoorvmittal10@gmail.com
LogToClean.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 96 14 2025-03-27 2025-03-27 1 1 grimekillah@gmail.com grimekillah@gmail.com
StreamsGroupCommandOptions.java
in tools/src/main/java/org/apache/kafka/tools/streams
 95 3 2025-04-09 2025-04-15 2 1 107070585+aliehsaeedii@user... 107070585+aliehsaeedii@user...
MetadataJsonConvertersGenerator.java
in generator/src/main/java/org/apache/kafka/message
 95 6 2021-01-11 2021-01-11 1 1 cmccabe@confluent.io cmccabe@confluent.io
TaskPluginsMetadata.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 95 14 2025-04-24 2025-04-24 1 1 snehashisp1995@gmail.com snehashisp1995@gmail.com
StreamsGroupMemberAssignment.java
in clients/src/main/java/org/apache/kafka/clients/admin
 95 13 2025-03-07 2025-03-07 1 1 lbrutschy@confluent.io lbrutschy@confluent.io
Correlations

File Size vs. Number of Changes: 3541 points

clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java x: 4131 lines of code y: 252 # changes core/src/main/java/kafka/server/share/DelayedShareFetch.java x: 650 lines of code y: 27 # changes core/src/main/java/kafka/server/share/SharePartition.java x: 2060 lines of code y: 55 # changes core/src/main/scala/kafka/raft/KafkaMetadataLog.scala x: 548 lines of code y: 71 # changes core/src/main/scala/kafka/server/BrokerServer.scala x: 642 lines of code y: 196 # changes core/src/main/scala/kafka/server/DynamicBrokerConfig.scala x: 851 lines of code y: 115 # changes raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java x: 3122 lines of code y: 118 # changes raft/src/main/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachine.java x: 220 lines of code y: 16 # changes raft/src/main/java/org/apache/kafka/raft/internals/RecordsBatchReader.java x: 93 lines of code y: 9 # changes raft/src/main/java/org/apache/kafka/raft/internals/RecordsIterator.java x: 292 lines of code y: 14 # changes raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotReader.java x: 114 lines of code y: 11 # changes raft/src/main/java/org/apache/kafka/snapshot/Snapshots.java x: 134 lines of code y: 16 # changes clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java x: 38 lines of code y: 4 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/ListShareGroupOffsetsHandler.java x: 156 lines of code y: 5 # changes clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateSummaryResponse.java x: 107 lines of code y: 5 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java x: 1746 lines of code y: 66 # changes server-common/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java x: 486 lines of code y: 6 # changes server-common/src/main/java/org/apache/kafka/server/share/persister/NoOpStatePersister.java x: 70 lines of code y: 3 # changes server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateSummaryData.java x: 8 lines of code y: 2 # changes share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java x: 733 lines of code y: 20 # changes tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommand.java x: 501 lines of code y: 14 # changes core/src/main/scala/kafka/server/ForwardingManager.scala x: 146 lines of code y: 22 # changes server/src/main/java/org/apache/kafka/server/metrics/ForwardingManagerMetrics.java x: 88 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsOptions.java x: 13 lines of code y: 3 # changes clients/src/main/java/org/apache/kafka/common/protocol/Errors.java x: 492 lines of code y: 129 # changes tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java x: 1164 lines of code y: 16 # changes server/src/main/java/org/apache/kafka/server/share/fetch/DelayedShareFetchGroupKey.java x: 39 lines of code y: 2 # changes core/src/main/java/kafka/server/share/PendingRemoteFetches.java x: 56 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareSessionHandler.java x: 186 lines of code y: 9 # changes clients/src/main/java/org/apache/kafka/clients/Metadata.java x: 525 lines of code y: 63 # changes clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResult.java x: 81 lines of code y: 4 # changes server/src/main/java/org/apache/kafka/server/AssignmentsManager.java x: 367 lines of code y: 17 # changes tools/src/main/java/org/apache/kafka/tools/ClusterTool.java x: 165 lines of code y: 5 # changes clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java x: 290 lines of code y: 298 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java x: 1650 lines of code y: 88 # changes share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java x: 854 lines of code y: 17 # changes clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java x: 557 lines of code y: 87 # changes storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java x: 1748 lines of code y: 9 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java x: 5425 lines of code y: 112 # changes tools/src/main/java/org/apache/kafka/tools/DeleteRecordsCommand.java x: 137 lines of code y: 4 # changes tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java x: 323 lines of code y: 7 # changes tools/src/main/java/org/apache/kafka/tools/TopicCommand.java x: 834 lines of code y: 17 # changes tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java x: 1054 lines of code y: 18 # changes core/src/main/java/kafka/server/TierStateMachine.java x: 169 lines of code y: 10 # changes core/src/main/scala/kafka/cluster/Partition.scala x: 1320 lines of code y: 292 # changes core/src/main/scala/kafka/server/AbstractFetcherThread.scala x: 680 lines of code y: 157 # changes metadata/src/main/java/org/apache/kafka/controller/OffsetControlManager.java x: 244 lines of code y: 8 # changes metadata/src/main/java/org/apache/kafka/controller/QuorumController.java x: 1654 lines of code y: 127 # changes metadata/src/main/java/org/apache/kafka/image/MetadataImage.java x: 144 lines of code y: 16 # changes metadata/src/main/java/org/apache/kafka/image/MetadataProvenance.java x: 65 lines of code y: 4 # changes raft/src/main/java/org/apache/kafka/raft/QuorumState.java x: 719 lines of code y: 44 # changes raft/src/main/java/org/apache/kafka/raft/RaftClient.java x: 38 lines of code y: 29 # changes raft/src/main/java/org/apache/kafka/raft/RaftUtil.java x: 653 lines of code y: 14 # changes raft/src/main/java/org/apache/kafka/raft/ReplicatedLog.java x: 77 lines of code y: 26 # changes raft/src/main/java/org/apache/kafka/raft/ValidOffsetAndEpoch.java x: 52 lines of code y: 6 # changes raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotReader.java x: 61 lines of code y: 6 # changes raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotWriter.java x: 151 lines of code y: 10 # changes raft/src/main/java/org/apache/kafka/snapshot/NotifyingRawSnapshotWriter.java x: 46 lines of code y: 3 # changes raft/src/main/java/org/apache/kafka/snapshot/RawSnapshotReader.java x: 10 lines of code y: 7 # changes raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotWriter.java x: 207 lines of code y: 19 # changes raft/src/main/java/org/apache/kafka/snapshot/SnapshotPath.java x: 4 lines of code y: 5 # changes raft/src/main/java/org/apache/kafka/snapshot/SnapshotReader.java x: 11 lines of code y: 9 # changes raft/src/main/java/org/apache/kafka/snapshot/SnapshotWriter.java x: 13 lines of code y: 16 # changes server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java x: 236 lines of code y: 53 # changes clients/src/main/java/org/apache/kafka/common/requests/ListTransactionsRequest.java x: 56 lines of code y: 4 # changes core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala x: 818 lines of code y: 66 # changes core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala x: 647 lines of code y: 84 # changes core/src/main/scala/kafka/server/KafkaApis.scala x: 3343 lines of code y: 615 # changes tools/src/main/java/org/apache/kafka/tools/TransactionsCommand.java x: 873 lines of code y: 13 # changes core/src/main/java/kafka/server/share/SharePartitionManager.java x: 549 lines of code y: 52 # changes server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java x: 91 lines of code y: 4 # changes clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java x: 242 lines of code y: 58 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractHeartbeatRequestManager.java x: 284 lines of code y: 15 # changes streams/src/main/java/org/apache/kafka/streams/processor/assignment/assignors/StickyTaskAssignor.java x: 380 lines of code y: 6 # changes tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommandOptions.java x: 175 lines of code y: 7 # changes core/src/main/java/kafka/server/builders/KafkaApisBuilder.java x: 188 lines of code y: 24 # changes core/src/main/scala/kafka/server/AutoTopicCreationManager.scala x: 201 lines of code y: 20 # changes core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala x: 246 lines of code y: 45 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfig.java x: 121 lines of code y: 10 # changes core/src/main/scala/kafka/server/KafkaConfig.scala x: 607 lines of code y: 466 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java x: 564 lines of code y: 44 # changes server-common/src/main/java/org/apache/kafka/server/common/Feature.java x: 186 lines of code y: 5 # changes server-common/src/main/java/org/apache/kafka/server/common/StreamsVersion.java x: 46 lines of code y: 1 # changes core/src/main/scala/kafka/network/SocketServer.scala x: 1249 lines of code y: 200 # changes core/src/main/scala/kafka/server/ControllerServer.scala x: 379 lines of code y: 112 # changes core/src/main/scala/kafka/tools/TestRaftServer.scala x: 397 lines of code y: 54 # changes core/src/main/scala/kafka/utils/CoreUtils.scala x: 116 lines of code y: 55 # changes metadata/src/main/java/org/apache/kafka/metadata/BrokerRegistration.java x: 333 lines of code y: 26 # changes metadata/src/main/java/org/apache/kafka/metadata/ListenerInfo.java x: 261 lines of code y: 4 # changes metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java x: 194 lines of code y: 13 # changes tools/src/main/java/org/apache/kafka/tools/MetadataQuorumCommand.java x: 443 lines of code y: 14 # changes clients/src/main/java/org/apache/kafka/common/metrics/PluginMetrics.java x: 10 lines of code y: 2 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java x: 522 lines of code y: 11 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java x: 298 lines of code y: 5 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/EndpointToPartitionsManager.java x: 62 lines of code y: 1 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java x: 1511 lines of code y: 352 # changes clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java x: 69 lines of code y: 40 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java x: 1002 lines of code y: 15 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java x: 118 lines of code y: 196 # changes clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java x: 796 lines of code y: 151 # changes clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java x: 171 lines of code y: 51 # changes clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java x: 206 lines of code y: 54 # changes clients/src/main/java/org/apache/kafka/common/utils/Utils.java x: 924 lines of code y: 149 # changes core/src/main/scala/kafka/coordinator/group/CoordinatorPartitionWriter.scala x: 127 lines of code y: 19 # changes core/src/main/scala/kafka/server/DelayedProduce.scala x: 88 lines of code y: 32 # changes core/src/main/scala/kafka/server/ReplicaManager.scala x: 2203 lines of code y: 444 # changes tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java x: 331 lines of code y: 3 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java x: 965 lines of code y: 50 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java x: 1203 lines of code y: 173 # changes clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java x: 200 lines of code y: 36 # changes core/src/main/scala/kafka/log/LogManager.scala x: 1098 lines of code y: 232 # changes core/src/main/scala/kafka/server/AbstractFetcherManager.scala x: 184 lines of code y: 53 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java x: 292 lines of code y: 68 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginClassLoader.java x: 76 lines of code y: 8 # changes clients/src/main/java/org/apache/kafka/clients/admin/Admin.java x: 351 lines of code y: 66 # changes clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java x: 285 lines of code y: 20 # changes clients/src/main/java/org/apache/kafka/common/requests/DeleteShareGroupOffsetsResponse.java x: 40 lines of code y: 5 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java x: 868 lines of code y: 56 # changes storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManager.java x: 1657 lines of code y: 3 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java x: 599 lines of code y: 12 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java x: 754 lines of code y: 22 # changes streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java x: 1397 lines of code y: 227 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/ReadOnlyTask.java x: 187 lines of code y: 11 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java x: 245 lines of code y: 97 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java x: 1027 lines of code y: 233 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java x: 103 lines of code y: 57 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java x: 218 lines of code y: 13 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java x: 1727 lines of code y: 199 # changes streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java x: 858 lines of code y: 126 # changes metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadata.java x: 145 lines of code y: 8 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java x: 1033 lines of code y: 83 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractStatus.java x: 89 lines of code y: 7 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java x: 509 lines of code y: 19 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java x: 435 lines of code y: 14 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java x: 608 lines of code y: 50 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorStatus.java x: 22 lines of code y: 7 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java x: 422 lines of code y: 20 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskPluginsMetadata.java x: 95 lines of code y: 1 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TransformationChain.java x: 59 lines of code y: 13 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TransformationStage.java x: 104 lines of code y: 4 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java x: 1718 lines of code y: 98 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java x: 487 lines of code y: 31 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java x: 754 lines of code y: 84 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java x: 274 lines of code y: 77 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java x: 412 lines of code y: 45 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorStateInfo.java x: 109 lines of code y: 7 # changes connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java x: 556 lines of code y: 37 # changes clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java x: 831 lines of code y: 242 # changes clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java x: 431 lines of code y: 57 # changes clients/src/main/java/org/apache/kafka/clients/producer/Producer.java x: 36 lines of code y: 20 # changes clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java x: 528 lines of code y: 137 # changes clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java x: 1385 lines of code y: 100 # changes clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java x: 130 lines of code y: 8 # changes core/src/main/java/kafka/server/share/ShareFetchUtils.java x: 175 lines of code y: 21 # changes clients/src/main/java/org/apache/kafka/common/protocol/Readable.java x: 51 lines of code y: 14 # changes clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java x: 262 lines of code y: 112 # changes clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java x: 40 lines of code y: 16 # changes clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponse.java x: 106 lines of code y: 20 # changes clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java x: 85 lines of code y: 8 # changes clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsResponse.java x: 46 lines of code y: 11 # changes clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionReassignmentsResponse.java x: 44 lines of code y: 8 # changes clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionResponse.java x: 38 lines of code y: 5 # changes clients/src/main/java/org/apache/kafka/common/requests/CreateAclsResponse.java x: 40 lines of code y: 13 # changes clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java x: 41 lines of code y: 22 # changes clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsResponse.java x: 110 lines of code y: 19 # changes clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsResponse.java x: 57 lines of code y: 10 # changes clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsResponse.java x: 41 lines of code y: 19 # changes clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsResponse.java x: 128 lines of code y: 20 # changes clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenResponse.java x: 97 lines of code y: 10 # changes clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java x: 112 lines of code y: 27 # changes clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java x: 44 lines of code y: 20 # changes clients/src/main/java/org/apache/kafka/common/requests/DescribeQuorumResponse.java x: 67 lines of code y: 10 # changes clients/src/main/java/org/apache/kafka/common/requests/EndQuorumEpochResponse.java x: 39 lines of code y: 8 # changes clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java x: 195 lines of code y: 66 # changes clients/src/main/java/org/apache/kafka/common/requests/FetchSnapshotResponse.java x: 61 lines of code y: 9 # changes clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java x: 39 lines of code y: 25 # changes clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java x: 52 lines of code y: 34 # changes clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java x: 36 lines of code y: 22 # changes clients/src/main/java/org/apache/kafka/common/requests/ListOffsetsResponse.java x: 69 lines of code y: 5 # changes clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java x: 378 lines of code y: 62 # changes clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java x: 206 lines of code y: 39 # changes clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java x: 307 lines of code y: 43 # changes clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeResponse.java x: 38 lines of code y: 15 # changes clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java x: 138 lines of code y: 21 # changes clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersResponse.java x: 84 lines of code y: 15 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java x: 829 lines of code y: 5 # changes share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareGroupOffset.java x: 200 lines of code y: 7 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/AlterConsumerGroupOffsetsHandler.java x: 160 lines of code y: 8 # changes clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java x: 109 lines of code y: 37 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java x: 757 lines of code y: 27 # changes metadata/src/main/java/org/apache/kafka/controller/ConfigurationControlManager.java x: 591 lines of code y: 35 # changes metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java x: 376 lines of code y: 37 # changes raft/src/main/java/org/apache/kafka/raft/FollowerState.java x: 220 lines of code y: 23 # changes raft/src/main/java/org/apache/kafka/raft/LeaderState.java x: 874 lines of code y: 50 # changes raft/src/main/java/org/apache/kafka/raft/VoterSet.java x: 281 lines of code y: 5 # changes raft/src/main/java/org/apache/kafka/raft/internals/UpdateVoterHandler.java x: 242 lines of code y: 6 # changes server-common/src/main/java/org/apache/kafka/server/common/KRaftVersion.java x: 83 lines of code y: 7 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeShareGroupsHandler.java x: 150 lines of code y: 9 # changes server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterStateManager.java x: 1156 lines of code y: 7 # changes release/git.py x: 74 lines of code y: 2 # changes storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaner.java x: 359 lines of code y: 2 # changes clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerInterceptors.java x: 81 lines of code y: 10 # changes core/src/main/scala/kafka/raft/RaftManager.scala x: 244 lines of code y: 67 # changes core/src/main/scala/kafka/admin/ConfigCommand.scala x: 582 lines of code y: 113 # changes core/src/main/scala/kafka/server/DynamicConfig.scala x: 32 lines of code y: 32 # changes storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataManager.java x: 38 lines of code y: 10 # changes storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteStorageManager.java x: 27 lines of code y: 8 # changes storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java x: 513 lines of code y: 19 # changes clients/src/main/java/org/apache/kafka/common/serialization/Deserializer.java x: 20 lines of code y: 15 # changes clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java x: 15 lines of code y: 12 # changes core/src/main/scala/kafka/server/FetchSession.scala x: 580 lines of code y: 29 # changes clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java x: 574 lines of code y: 119 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java x: 335 lines of code y: 16 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/CompletedFetch.java x: 279 lines of code y: 12 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchCollector.java x: 271 lines of code y: 8 # changes clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java x: 164 lines of code y: 37 # changes connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java x: 219 lines of code y: 21 # changes raft/src/main/java/org/apache/kafka/raft/MetadataLogConfig.java x: 123 lines of code y: 2 # changes server/src/main/java/org/apache/kafka/server/config/AbstractKafkaConfig.java x: 58 lines of code y: 19 # changes core/src/main/scala/kafka/server/KafkaBroker.scala x: 82 lines of code y: 30 # changes metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java x: 650 lines of code y: 62 # changes clients/src/main/java/org/apache/kafka/common/errors/GroupMaxSizeReachedException.java x: 7 lines of code y: 3 # changes clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java x: 101 lines of code y: 40 # changes coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java x: 1472 lines of code y: 14 # changes core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala x: 243 lines of code y: 17 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Group.java x: 74 lines of code y: 22 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinator.java x: 172 lines of code y: 32 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java x: 806 lines of code y: 26 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroup.java x: 186 lines of code y: 11 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java x: 623 lines of code y: 7 # changes core/src/main/java/kafka/server/QuotaFactory.java x: 141 lines of code y: 3 # changes core/src/main/scala/kafka/server/ControllerApis.scala x: 975 lines of code y: 62 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/KRaftMetadataRequestBenchmark.java x: 210 lines of code y: 25 # changes connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java x: 268 lines of code y: 22 # changes tools/src/main/java/org/apache/kafka/tools/PushHttpMetricsReporter.java x: 255 lines of code y: 9 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java x: 856 lines of code y: 21 # changes core/src/main/scala/kafka/server/ConfigHandler.scala x: 122 lines of code y: 73 # changes core/src/main/scala/kafka/tools/TestRaftRequestHandler.scala x: 81 lines of code y: 19 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Herder.java x: 74 lines of code y: 34 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java x: 2304 lines of code y: 128 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java x: 729 lines of code y: 17 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java x: 494 lines of code y: 49 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/DeadLetterQueueReporter.java x: 155 lines of code y: 16 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java x: 215 lines of code y: 15 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java x: 197 lines of code y: 40 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java x: 393 lines of code y: 33 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java x: 501 lines of code y: 38 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginsRecommenders.java x: 195 lines of code y: 3 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/HerderRequestHandler.java x: 102 lines of code y: 10 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java x: 158 lines of code y: 21 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResource.java x: 137 lines of code y: 24 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java x: 345 lines of code y: 49 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java x: 503 lines of code y: 58 # changes connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java x: 868 lines of code y: 55 # changes connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java x: 287 lines of code y: 33 # changes connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryConfigBackingStore.java x: 160 lines of code y: 18 # changes server-common/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java x: 383 lines of code y: 13 # changes metadata/src/main/java/org/apache/kafka/metadata/util/SnapshotFileReader.java x: 172 lines of code y: 8 # changes core/src/main/scala/kafka/network/RequestChannel.scala x: 372 lines of code y: 158 # changes core/src/main/scala/kafka/server/KafkaRequestHandler.scala x: 168 lines of code y: 83 # changes config/log4j2.yaml x: 112 lines of code y: 3 # changes server-common/src/main/java/org/apache/kafka/server/config/ServerConfigs.java x: 102 lines of code y: 1 # changes storage/src/main/java/org/apache/kafka/storage/internals/log/Cleaner.java x: 462 lines of code y: 1 # changes storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleanerManager.java x: 502 lines of code y: 2 # changes storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java x: 540 lines of code y: 28 # changes tools/src/main/java/org/apache/kafka/tools/GroupsCommand.java x: 241 lines of code y: 3 # changes clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java x: 731 lines of code y: 114 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestManagers.java x: 329 lines of code y: 36 # changes clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java x: 382 lines of code y: 58 # changes server/src/main/java/org/apache/kafka/server/share/context/ShareFetchContext.java x: 25 lines of code y: 4 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java x: 444 lines of code y: 61 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java x: 561 lines of code y: 52 # changes streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java x: 1371 lines of code y: 239 # changes server/src/main/java/org/apache/kafka/network/metrics/RequestMetrics.java x: 165 lines of code y: 4 # changes core/src/main/scala/kafka/server/ClientQuotaManager.scala x: 405 lines of code y: 63 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/CheckpointBench.java x: 139 lines of code y: 44 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/PartitionCreationBench.java x: 175 lines of code y: 37 # changes core/src/main/java/kafka/docker/Log4jConfiguration.java x: 164 lines of code y: 2 # changes core/src/main/java/kafka/server/builders/ReplicaManagerBuilder.java x: 101 lines of code y: 28 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java x: 1114 lines of code y: 26 # changes clients/src/main/java/org/apache/kafka/clients/producer/Callback.java x: 5 lines of code y: 12 # changes storage/src/main/java/org/apache/kafka/storage/internals/log/LocalLog.java x: 666 lines of code y: 9 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java x: 1170 lines of code y: 154 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java x: 756 lines of code y: 10 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManager.java x: 218 lines of code y: 6 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManager.java x: 270 lines of code y: 5 # changes storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java x: 350 lines of code y: 12 # changes storage/src/main/java/org/apache/kafka/server/purgatory/DelayedRemoteListOffsets.java x: 146 lines of code y: 1 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java x: 236 lines of code y: 42 # changes storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemotePartitionMetadataStore.java x: 125 lines of code y: 8 # changes storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java x: 442 lines of code y: 22 # changes storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java x: 414 lines of code y: 27 # changes storage/src/main/java/org/apache/kafka/storage/internals/epoch/LeaderEpochFileCache.java x: 341 lines of code y: 18 # changes storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegment.java x: 531 lines of code y: 21 # changes storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegments.java x: 135 lines of code y: 6 # changes storage/src/main/java/org/apache/kafka/storage/internals/log/LogValidator.java x: 460 lines of code y: 13 # changes storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerStateManager.java x: 444 lines of code y: 17 # changes storage/src/main/java/org/apache/kafka/storage/log/metrics/BrokerTopicMetrics.java x: 327 lines of code y: 5 # changes streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java x: 5 lines of code y: 14 # changes streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java x: 8 lines of code y: 16 # changes raft/src/main/java/org/apache/kafka/raft/Batch.java x: 144 lines of code y: 6 # changes raft/src/main/java/org/apache/kafka/raft/Endpoints.java x: 250 lines of code y: 6 # changes raft/src/main/java/org/apache/kafka/raft/QuorumConfig.java x: 233 lines of code y: 10 # changes raft/src/main/java/org/apache/kafka/raft/RequestManager.java x: 241 lines of code y: 10 # changes raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java x: 451 lines of code y: 27 # changes raft/src/main/java/org/apache/kafka/raft/internals/VoterSetHistory.java x: 54 lines of code y: 9 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java x: 354 lines of code y: 45 # changes core/src/main/scala/kafka/server/RemoteLeaderEndPoint.scala x: 167 lines of code y: 13 # changes core/src/main/scala/kafka/server/ReplicaFetcherThread.scala x: 120 lines of code y: 164 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/InternalTopicManager.java x: 235 lines of code y: 4 # changes clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java x: 284 lines of code y: 136 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/CurrentAssignmentBuilder.java x: 248 lines of code y: 3 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroupMember.java x: 289 lines of code y: 5 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TasksTuple.java x: 126 lines of code y: 3 # changes metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java x: 1975 lines of code y: 97 # changes metadata/src/main/java/org/apache/kafka/image/ClusterImage.java x: 70 lines of code y: 13 # changes metadata/src/main/java/org/apache/kafka/image/TopicDelta.java x: 153 lines of code y: 14 # changes metadata/src/main/java/org/apache/kafka/image/publisher/SnapshotGenerator.java x: 193 lines of code y: 7 # changes metadata/src/main/java/org/apache/kafka/metadata/PartitionRegistration.java x: 404 lines of code y: 28 # changes clients/src/main/java/org/apache/kafka/clients/admin/DescribeTopicsOptions.java x: 24 lines of code y: 10 # changes gradle/spotbugs-exclude.xml x: 339 lines of code y: 67 # changes storage/src/main/java/org/apache/kafka/storage/internals/log/PreCleanStats.java x: 27 lines of code y: 1 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilder.java x: 316 lines of code y: 8 # changes clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java x: 567 lines of code y: 58 # changes clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java x: 285 lines of code y: 88 # changes clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java x: 154 lines of code y: 17 # changes clients/src/main/java/org/apache/kafka/common/requests/CreateAclsRequest.java x: 101 lines of code y: 14 # changes clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsRequest.java x: 81 lines of code y: 22 # changes clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsRequest.java x: 106 lines of code y: 16 # changes clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsRequest.java x: 60 lines of code y: 17 # changes clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersRequest.java x: 111 lines of code y: 8 # changes clients/src/main/java/org/apache/kafka/common/requests/EndTxnRequest.java x: 57 lines of code y: 16 # changes clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java x: 49 lines of code y: 24 # changes clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupRequest.java x: 89 lines of code y: 22 # changes clients/src/main/java/org/apache/kafka/common/requests/MetadataRequest.java x: 158 lines of code y: 36 # changes clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java x: 80 lines of code y: 21 # changes clients/src/main/java/org/apache/kafka/common/requests/RequestContext.java x: 169 lines of code y: 19 # changes clients/src/main/java/org/apache/kafka/common/requests/SyncGroupRequest.java x: 63 lines of code y: 20 # changes clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitRequest.java x: 214 lines of code y: 22 # changes clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersRequest.java x: 162 lines of code y: 14 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java x: 309 lines of code y: 30 # changes server-common/src/main/java/org/apache/kafka/server/common/CheckpointFile.java x: 137 lines of code y: 12 # changes server-common/src/main/java/org/apache/kafka/server/config/QuotaConfig.java x: 177 lines of code y: 4 # changes metadata/src/main/java/org/apache/kafka/metadata/storage/Formatter.java x: 390 lines of code y: 10 # changes clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java x: 420 lines of code y: 69 # changes core/src/main/scala/kafka/server/metadata/KRaftMetadataCache.scala x: 379 lines of code y: 41 # changes tools/src/main/java/org/apache/kafka/tools/AclCommand.java x: 531 lines of code y: 2 # changes clients/src/main/java/org/apache/kafka/common/record/FileRecords.java x: 332 lines of code y: 43 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeStreamsGroupsHandler.java x: 233 lines of code y: 2 # changes core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala x: 418 lines of code y: 31 # changes generator/src/main/java/org/apache/kafka/message/checker/Unifier.java x: 149 lines of code y: 2 # changes core/src/main/scala/kafka/cluster/Replica.scala x: 119 lines of code y: 54 # changes core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala x: 368 lines of code y: 51 # changes core/src/main/scala/kafka/server/ConfigHelper.scala x: 279 lines of code y: 15 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java x: 133 lines of code y: 42 # changes metadata/src/main/java/org/apache/kafka/metadata/MetadataCache.java x: 135 lines of code y: 1 # changes metadata/src/main/java/org/apache/kafka/controller/ClientQuotaControlManager.java x: 265 lines of code y: 17 # changes metadata/src/main/java/org/apache/kafka/image/FeaturesImage.java x: 77 lines of code y: 15 # changes metadata/src/main/java/org/apache/kafka/image/ScramImage.java x: 119 lines of code y: 7 # changes metadata/src/main/java/org/apache/kafka/metadata/KafkaConfigSchema.java x: 209 lines of code y: 9 # changes metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java x: 427 lines of code y: 15 # changes metadata/src/main/java/org/apache/kafka/metadata/properties/MetaPropertiesEnsemble.java x: 396 lines of code y: 8 # changes server/src/main/java/org/apache/kafka/server/ClientMetricsManager.java x: 490 lines of code y: 13 # changes clients/src/main/java/org/apache/kafka/common/utils/LogContext.java x: 636 lines of code y: 5 # changes core/src/main/scala/kafka/coordinator/group/CoordinatorLoaderImpl.scala x: 181 lines of code y: 14 # changes core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala x: 156 lines of code y: 50 # changes core/src/main/scala/kafka/tools/DumpLogSegments.scala x: 566 lines of code y: 121 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/StressTestLog.java x: 173 lines of code y: 4 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/TestLinearWriteSpeed.java x: 285 lines of code y: 4 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java x: 251 lines of code y: 12 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java x: 548 lines of code y: 38 # changes core/src/main/scala/kafka/metrics/KafkaMetricsReporter.scala x: 39 lines of code y: 14 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java x: 955 lines of code y: 45 # changes tools/src/main/java/org/apache/kafka/tools/ShareConsumerPerformance.java x: 384 lines of code y: 2 # changes clients/src/main/java/org/apache/kafka/clients/admin/StreamsGroupDescription.java x: 116 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/StreamsGroupMemberDescription.java x: 252 lines of code y: 1 # changes tools/src/main/java/org/apache/kafka/tools/VerifiableShareConsumer.java x: 514 lines of code y: 2 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/Graph.java x: 406 lines of code y: 6 # changes clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java x: 639 lines of code y: 77 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java x: 1174 lines of code y: 136 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/ModernGroup.java x: 274 lines of code y: 11 # changes core/src/main/scala/kafka/server/BrokerLifecycleManager.scala x: 408 lines of code y: 31 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java x: 244 lines of code y: 33 # changes clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java x: 124 lines of code y: 20 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java x: 135 lines of code y: 36 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHeterogeneousAssignmentBuilder.java x: 385 lines of code y: 7 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroupMember.java x: 200 lines of code y: 2 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetrics.java x: 475 lines of code y: 12 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupMember.java x: 393 lines of code y: 6 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupMember.java x: 218 lines of code y: 4 # changes clients/src/main/java/org/apache/kafka/common/metrics/MetricsReporter.java x: 22 lines of code y: 13 # changes storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentMetadata.java x: 203 lines of code y: 10 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java x: 1257 lines of code y: 115 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java x: 166 lines of code y: 46 # changes streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java x: 176 lines of code y: 58 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java x: 242 lines of code y: 26 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java x: 121 lines of code y: 28 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java x: 536 lines of code y: 63 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java x: 1118 lines of code y: 154 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/MaterializedInternal.java x: 92 lines of code y: 17 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java x: 1852 lines of code y: 112 # changes clients/src/main/java/org/apache/kafka/common/record/Records.java x: 19 lines of code y: 21 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeConsumerGroupsHandler.java x: 326 lines of code y: 12 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java x: 83 lines of code y: 44 # changes clients/src/main/java/org/apache/kafka/clients/ClientUtils.java x: 224 lines of code y: 40 # changes server-common/src/main/java/org/apache/kafka/server/util/FutureUtils.java x: 76 lines of code y: 10 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java x: 184 lines of code y: 45 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableTransformValues.java x: 152 lines of code y: 20 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java x: 119 lines of code y: 23 # changes streams/src/main/java/org/apache/kafka/streams/state/StateSerdes.java x: 95 lines of code y: 13 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueChangeBuffer.java x: 431 lines of code y: 4 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java x: 94 lines of code y: 25 # changes core/src/main/scala/kafka/server/KafkaRaftServer.scala x: 134 lines of code y: 48 # changes core/src/main/scala/kafka/tools/StorageTool.scala x: 401 lines of code y: 40 # changes metadata/src/main/java/org/apache/kafka/image/loader/MetadataBatchLoader.java x: 196 lines of code y: 8 # changes metadata/src/main/java/org/apache/kafka/image/loader/MetadataLoader.java x: 414 lines of code y: 21 # changes metadata/src/main/java/org/apache/kafka/image/publisher/SnapshotEmitter.java x: 104 lines of code y: 9 # changes metadata/src/main/java/org/apache/kafka/metadata/ControllerRegistration.java x: 187 lines of code y: 8 # changes tools/src/main/java/org/apache/kafka/tools/FeatureCommand.java x: 398 lines of code y: 11 # changes streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java x: 61 lines of code y: 29 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java x: 205 lines of code y: 25 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java x: 192 lines of code y: 33 # changes server/src/main/java/org/apache/kafka/network/RequestConvertToJson.java x: 794 lines of code y: 7 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java x: 789 lines of code y: 80 # changes streams/src/main/java/org/apache/kafka/streams/kstream/CogroupedKStream.java x: 25 lines of code y: 23 # changes streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java x: 37 lines of code y: 50 # changes streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java x: 39 lines of code y: 36 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java x: 206 lines of code y: 45 # changes streams/src/main/java/org/apache/kafka/streams/Topology.java x: 449 lines of code y: 34 # changes streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java x: 12 lines of code y: 14 # changes streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java x: 183 lines of code y: 134 # changes streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java x: 175 lines of code y: 77 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThread.java x: 219 lines of code y: 18 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java x: 75 lines of code y: 42 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetrics.java x: 267 lines of code y: 21 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java x: 403 lines of code y: 46 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/BaseRecordBatchBenchmark.java x: 110 lines of code y: 13 # changes clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java x: 122 lines of code y: 30 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/Acknowledgements.java x: 167 lines of code y: 2 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareCompletedFetch.java x: 307 lines of code y: 5 # changes core/src/main/scala/kafka/server/metadata/ClientQuotaMetadataManager.scala x: 146 lines of code y: 14 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java x: 459 lines of code y: 74 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java x: 444 lines of code y: 53 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java x: 458 lines of code y: 65 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java x: 125 lines of code y: 26 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractMergedSortedCacheStoreIterator.java x: 142 lines of code y: 12 # changes core/src/main/scala/kafka/server/ConfigAdminManager.scala x: 322 lines of code y: 11 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java x: 954 lines of code y: 98 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java x: 138 lines of code y: 27 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TargetAssignmentBuilder.java x: 187 lines of code y: 1 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/StickyTaskAssignor.java x: 344 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java x: 193 lines of code y: 75 # changes clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerInterceptor.java x: 9 lines of code y: 8 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java x: 168 lines of code y: 30 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMap.java x: 150 lines of code y: 31 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java x: 80 lines of code y: 13 # changes core/src/main/scala/kafka/server/SharedServer.scala x: 297 lines of code y: 32 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEvent.java x: 61 lines of code y: 32 # changes streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java x: 42 lines of code y: 46 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java x: 327 lines of code y: 33 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java x: 10 lines of code y: 22 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java x: 609 lines of code y: 54 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java x: 114 lines of code y: 35 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java x: 292 lines of code y: 83 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractDualSchemaRocksDBSegmentedBytesStore.java x: 250 lines of code y: 13 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java x: 430 lines of code y: 60 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java x: 410 lines of code y: 48 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java x: 473 lines of code y: 66 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingWindowStore.java x: 572 lines of code y: 6 # changes storage/src/main/java/org/apache/kafka/storage/log/metrics/BrokerTopicStats.java x: 196 lines of code y: 3 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java x: 829 lines of code y: 53 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java x: 341 lines of code y: 22 # changes clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java x: 321 lines of code y: 38 # changes clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrResponse.java x: 60 lines of code y: 23 # changes generator/src/main/java/org/apache/kafka/message/MessageGenerator.java x: 294 lines of code y: 25 # changes raft/src/main/java/org/apache/kafka/raft/CandidateState.java x: 166 lines of code y: 15 # changes clients/src/main/java/org/apache/kafka/common/security/JaasUtils.java x: 9 lines of code y: 20 # changes clients/src/main/java/org/apache/kafka/clients/NetworkClient.java x: 1124 lines of code y: 141 # changes clients/src/main/java/org/apache/kafka/clients/NodeApiVersions.java x: 170 lines of code y: 25 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBuffer.java x: 283 lines of code y: 8 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java x: 473 lines of code y: 75 # changes tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java x: 547 lines of code y: 31 # changes clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslServer.java x: 208 lines of code y: 13 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsRequestManager.java x: 596 lines of code y: 22 # changes tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java x: 612 lines of code y: 11 # changes core/src/main/scala/kafka/server/NodeToControllerChannelManager.scala x: 273 lines of code y: 13 # changes clients/src/main/java/org/apache/kafka/common/network/ChannelBuilders.java x: 167 lines of code y: 28 # changes clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java x: 345 lines of code y: 51 # changes clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java x: 530 lines of code y: 48 # changes generator/src/main/java/org/apache/kafka/message/CoordinatorRecordTypeGenerator.java x: 220 lines of code y: 2 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminMetadataManager.java x: 199 lines of code y: 15 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java x: 1435 lines of code y: 13 # changes streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java x: 104 lines of code y: 37 # changes core/src/main/scala/kafka/Kafka.scala x: 75 lines of code y: 47 # changes clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java x: 239 lines of code y: 37 # changes connect/api/src/main/java/org/apache/kafka/connect/data/SchemaBuilder.java x: 228 lines of code y: 16 # changes connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java x: 327 lines of code y: 28 # changes connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java x: 597 lines of code y: 33 # changes generator/src/main/java/org/apache/kafka/message/FieldType.java x: 375 lines of code y: 18 # changes generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java x: 1611 lines of code y: 46 # changes shell/src/main/java/org/apache/kafka/shell/command/LsCommandHandler.java x: 246 lines of code y: 8 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java x: 218 lines of code y: 46 # changes streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskAssignmentUtils.java x: 780 lines of code y: 10 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java x: 738 lines of code y: 61 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java x: 422 lines of code y: 41 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java x: 392 lines of code y: 18 # changes tools/src/main/java/org/apache/kafka/tools/JmxTool.java x: 369 lines of code y: 5 # changes tools/src/main/java/org/apache/kafka/tools/ReplicaVerificationTool.java x: 602 lines of code y: 8 # changes tools/src/main/java/org/apache/kafka/tools/consumer/ConsoleConsumerOptions.java x: 338 lines of code y: 12 # changes trogdor/src/main/java/org/apache/kafka/trogdor/workload/ExternalCommandWorker.java x: 281 lines of code y: 4 # changes tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java x: 441 lines of code y: 39 # changes connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java x: 623 lines of code y: 35 # changes connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java x: 413 lines of code y: 18 # changes connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java x: 407 lines of code y: 9 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/core/TestPurgatoryPerformance.java x: 380 lines of code y: 3 # changes tools/src/main/java/org/apache/kafka/tools/ConsoleProducer.java x: 292 lines of code y: 2 # changes trogdor/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java x: 456 lines of code y: 5 # changes clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java x: 568 lines of code y: 66 # changes streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java x: 31 lines of code y: 19 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java x: 254 lines of code y: 15 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java x: 592 lines of code y: 118 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java x: 793 lines of code y: 130 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java x: 107 lines of code y: 51 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/WindowToTimestampedWindowByteStoreAdapter.java x: 165 lines of code y: 11 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedStateStore.java x: 106 lines of code y: 18 # changes connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java x: 349 lines of code y: 37 # changes streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java x: 343 lines of code y: 41 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStore.java x: 616 lines of code y: 16 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorSupplier.java x: 183 lines of code y: 16 # changes committer-tools/kafka-merge-pr.py x: 304 lines of code y: 2 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerUtils.java x: 188 lines of code y: 16 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java x: 345 lines of code y: 25 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamStreamJoinNode.java x: 118 lines of code y: 16 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java x: 112 lines of code y: 21 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorParameters.java x: 67 lines of code y: 15 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java x: 353 lines of code y: 55 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java x: 508 lines of code y: 30 # changes streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala x: 164 lines of code y: 42 # changes clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java x: 669 lines of code y: 11 # changes trogdor/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java x: 269 lines of code y: 4 # changes trogdor/src/main/java/org/apache/kafka/trogdor/workload/ShareConsumeBenchWorker.java x: 406 lines of code y: 1 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java x: 133 lines of code y: 38 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java x: 312 lines of code y: 37 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java x: 404 lines of code y: 17 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java x: 171 lines of code y: 48 # changes streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KTable.scala x: 198 lines of code y: 24 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java x: 98 lines of code y: 25 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcher.java x: 305 lines of code y: 12 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java x: 138 lines of code y: 34 # changes streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java x: 95 lines of code y: 21 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java x: 286 lines of code y: 44 # changes clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java x: 263 lines of code y: 30 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiDriver.java x: 355 lines of code y: 10 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/AllBrokersStrategy.java x: 153 lines of code y: 3 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java x: 1024 lines of code y: 26 # changes clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java x: 1043 lines of code y: 80 # changes clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java x: 464 lines of code y: 23 # changes clients/src/main/java/org/apache/kafka/common/record/AbstractRecords.java x: 104 lines of code y: 23 # changes clients/src/main/java/org/apache/kafka/common/security/JaasContext.java x: 136 lines of code y: 13 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/connect/JsonConverterBenchmark.java x: 389 lines of code y: 3 # changes metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java x: 307 lines of code y: 14 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/TargetAssignmentBuilderBenchmark.java x: 146 lines of code y: 17 # changes clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java x: 224 lines of code y: 34 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java x: 573 lines of code y: 43 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java x: 153 lines of code y: 48 # changes core/src/main/scala/kafka/server/DelayedFetch.scala x: 128 lines of code y: 51 # changes trogdor/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkerBase.java x: 370 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java x: 219 lines of code y: 28 # changes clients/src/main/java/org/apache/kafka/common/network/Selector.java x: 1030 lines of code y: 107 # changes streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java x: 14 lines of code y: 25 # changes clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java x: 333 lines of code y: 45 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskManager.java x: 294 lines of code y: 10 # changes trogdor/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java x: 498 lines of code y: 3 # changes metadata/src/main/java/org/apache/kafka/metadata/properties/MetaProperties.java x: 184 lines of code y: 2 # changes connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java x: 248 lines of code y: 26 # changes connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConfig.java x: 218 lines of code y: 8 # changes generator/src/main/java/org/apache/kafka/message/FieldSpec.java x: 546 lines of code y: 19 # changes clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java x: 401 lines of code y: 25 # changes streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java x: 24 lines of code y: 17 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java x: 262 lines of code y: 36 # changes streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java x: 91 lines of code y: 28 # changes clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java x: 910 lines of code y: 29 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java x: 316 lines of code y: 20 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStoreSegmentValueFormatter.java x: 358 lines of code y: 6 # changes tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java x: 334 lines of code y: 4 # changes tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java x: 390 lines of code y: 33 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java x: 207 lines of code y: 37 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java x: 154 lines of code y: 86 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java x: 50 lines of code y: 28 # changes clients/src/main/java/org/apache/kafka/common/record/CompressionType.java x: 133 lines of code y: 27 # changes clients/src/main/java/org/apache/kafka/common/compress/Lz4BlockInputStream.java x: 209 lines of code y: 4 # changes clients/src/main/java/org/apache/kafka/common/security/authenticator/LoginManager.java x: 188 lines of code y: 20 # changes clients/src/main/java/org/apache/kafka/common/metrics/stats/Percentiles.java x: 109 lines of code y: 16 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java x: 192 lines of code y: 27 # changes connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java x: 71 lines of code y: 30 # changes clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java x: 129 lines of code y: 30 # changes clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java x: 482 lines of code y: 13 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java x: 148 lines of code y: 32 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java x: 139 lines of code y: 32 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListener.java x: 90 lines of code y: 16 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java x: 433 lines of code y: 40 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java x: 256 lines of code y: 7 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignor.java x: 231 lines of code y: 23 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/LegacyStickyTaskAssignor.java x: 302 lines of code y: 2 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/OffsetCheckpoint.java x: 133 lines of code y: 19 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/PrefixedSessionKeySchemas.java x: 297 lines of code y: 4 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/PrefixedWindowKeySchemas.java x: 310 lines of code y: 4 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java x: 391 lines of code y: 27 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java x: 171 lines of code y: 15 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java x: 188 lines of code y: 18 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java x: 734 lines of code y: 10 # changes connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java x: 468 lines of code y: 25 # changes clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java x: 302 lines of code y: 40 # changes clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java x: 406 lines of code y: 22 # changes clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java x: 11 lines of code y: 27 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java x: 446 lines of code y: 65 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java x: 172 lines of code y: 24 # changes clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java x: 697 lines of code y: 39 # changes clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosLogin.java x: 299 lines of code y: 22 # changes trogdor/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionWorker.java x: 395 lines of code y: 4 # changes clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollection.java x: 416 lines of code y: 11 # changes tools/src/main/java/org/apache/kafka/tools/ManifestWorkspace.java x: 455 lines of code y: 3 # changes trogdor/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java x: 466 lines of code y: 5 # changes connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceTask.java x: 197 lines of code y: 13 # changes connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java x: 214 lines of code y: 12 # changes tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java x: 471 lines of code y: 21 # changes clients/src/main/java/org/apache/kafka/common/Cluster.java x: 243 lines of code y: 39 # changes connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java x: 254 lines of code y: 20 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java x: 456 lines of code y: 11 # changes clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java x: 360 lines of code y: 35 # changes streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java x: 25 lines of code y: 21 # changes core/src/main/scala/kafka/utils/VerifiableProperties.scala x: 112 lines of code y: 25 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java x: 303 lines of code y: 18 # changes connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java x: 227 lines of code y: 8 # changes streams/src/main/java/org/apache/kafka/streams/state/Stores.java x: 213 lines of code y: 58 # changes streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java x: 79 lines of code y: 29 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocol.java x: 209 lines of code y: 6 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java x: 37 lines of code y: 30 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java x: 8 lines of code y: 17 # changes clients/src/main/java/org/apache/kafka/clients/ClientRequest.java x: 77 lines of code y: 20 # changes clients/src/main/java/org/apache/kafka/common/network/SSLTransportLayer.java x: 697 lines of code y: 6 # changes
615.0
# changes
  min: 1.0
  average: 10.44
  25th percentile: 2.0
  median: 4.0
  75th percentile: 9.0
  max: 615.0
0 5425.0
lines of code
min: 1.0 | average: 112.57 | 25th percentile: 16.0 | median: 46.0 | 75th percentile: 110.0 | max: 5425.0

Number of Contributors vs. Number of Changes: 3541 points

clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java x: 103 # contributors y: 252 # changes core/src/main/java/kafka/server/share/DelayedShareFetch.java x: 5 # contributors y: 27 # changes core/src/main/java/kafka/server/share/SharePartition.java x: 11 # contributors y: 55 # changes core/src/main/scala/kafka/raft/KafkaMetadataLog.scala x: 25 # contributors y: 71 # changes core/src/main/scala/kafka/server/BrokerServer.scala x: 66 # contributors y: 196 # changes core/src/main/scala/kafka/server/DynamicBrokerConfig.scala x: 46 # contributors y: 115 # changes raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java x: 47 # contributors y: 118 # changes raft/src/main/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachine.java x: 10 # contributors y: 16 # changes raft/src/main/java/org/apache/kafka/raft/internals/RecordsBatchReader.java x: 6 # contributors y: 9 # changes raft/src/main/java/org/apache/kafka/raft/internals/RecordsIterator.java x: 10 # contributors y: 14 # changes raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotReader.java x: 7 # contributors y: 11 # changes raft/src/main/java/org/apache/kafka/snapshot/Snapshots.java x: 11 # contributors y: 16 # changes clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java x: 4 # contributors y: 4 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/ListShareGroupOffsetsHandler.java x: 2 # contributors y: 5 # changes clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateSummaryResponse.java x: 4 # contributors y: 5 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java x: 22 # contributors y: 66 # changes server-common/src/main/java/org/apache/kafka/server/share/persister/NoOpStatePersister.java x: 2 # contributors y: 3 # changes server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionFactory.java x: 3 # contributors y: 3 # changes server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateSummaryData.java x: 2 # contributors y: 2 # changes share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java x: 8 # contributors y: 20 # changes tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommand.java x: 4 # contributors y: 14 # changes core/src/main/scala/kafka/server/ForwardingManager.scala x: 10 # contributors y: 22 # changes server/src/main/java/org/apache/kafka/server/metrics/ForwardingManagerMetrics.java x: 1 # contributors y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsOptions.java x: 1 # contributors y: 3 # changes clients/src/main/java/org/apache/kafka/common/protocol/Errors.java x: 61 # contributors y: 129 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareSessionHandler.java x: 5 # contributors y: 9 # changes clients/src/main/java/org/apache/kafka/clients/Metadata.java x: 36 # contributors y: 63 # changes server/src/main/java/org/apache/kafka/server/AssignmentsManager.java x: 13 # contributors y: 17 # changes tools/src/main/java/org/apache/kafka/tools/ClusterTool.java x: 5 # contributors y: 5 # changes clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java x: 130 # contributors y: 298 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java x: 26 # contributors y: 88 # changes share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java x: 7 # contributors y: 17 # changes clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java x: 47 # contributors y: 87 # changes storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java x: 7 # contributors y: 9 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java x: 26 # contributors y: 112 # changes tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java x: 7 # contributors y: 7 # changes tools/src/main/java/org/apache/kafka/tools/TopicCommand.java x: 17 # contributors y: 17 # changes tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java x: 14 # contributors y: 18 # changes core/src/main/java/kafka/server/TierStateMachine.java x: 9 # contributors y: 10 # changes core/src/main/scala/kafka/cluster/Partition.scala x: 92 # contributors y: 292 # changes core/src/main/scala/kafka/server/AbstractFetcherThread.scala x: 70 # contributors y: 157 # changes metadata/src/main/java/org/apache/kafka/controller/QuorumController.java x: 40 # contributors y: 127 # changes metadata/src/main/java/org/apache/kafka/image/MetadataImage.java x: 9 # contributors y: 16 # changes raft/src/main/java/org/apache/kafka/raft/QuorumState.java x: 20 # contributors y: 44 # changes raft/src/main/java/org/apache/kafka/raft/RaftClient.java x: 13 # contributors y: 29 # changes raft/src/main/java/org/apache/kafka/raft/RaftUtil.java x: 12 # contributors y: 14 # changes raft/src/main/java/org/apache/kafka/raft/ReplicatedLog.java x: 12 # contributors y: 26 # changes raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotWriter.java x: 5 # contributors y: 10 # changes raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotWriter.java x: 11 # contributors y: 19 # changes raft/src/main/java/org/apache/kafka/snapshot/SnapshotWriter.java x: 13 # contributors y: 16 # changes server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java x: 26 # contributors y: 53 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/ListTransactionsHandler.java x: 6 # contributors y: 7 # changes core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala x: 31 # contributors y: 66 # changes core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala x: 39 # contributors y: 84 # changes core/src/main/scala/kafka/server/KafkaApis.scala x: 148 # contributors y: 615 # changes core/src/main/java/kafka/server/share/SharePartitionManager.java x: 14 # contributors y: 52 # changes clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java x: 44 # contributors y: 58 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractHeartbeatRequestManager.java x: 8 # contributors y: 15 # changes core/src/main/java/kafka/server/builders/KafkaApisBuilder.java x: 17 # contributors y: 24 # changes core/src/main/scala/kafka/server/AutoTopicCreationManager.scala x: 16 # contributors y: 20 # changes core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala x: 24 # contributors y: 45 # changes core/src/main/scala/kafka/server/KafkaConfig.scala x: 172 # contributors y: 466 # changes core/src/main/scala/kafka/network/SocketServer.scala x: 84 # contributors y: 200 # changes core/src/main/scala/kafka/server/ControllerServer.scala x: 34 # contributors y: 112 # changes core/src/main/scala/kafka/tools/TestRaftServer.scala x: 27 # contributors y: 54 # changes core/src/main/scala/kafka/utils/CoreUtils.scala x: 30 # contributors y: 55 # changes metadata/src/main/java/org/apache/kafka/metadata/BrokerRegistration.java x: 16 # contributors y: 26 # changes metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java x: 13 # contributors y: 13 # changes tools/src/main/java/org/apache/kafka/tools/MetadataQuorumCommand.java x: 9 # contributors y: 14 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java x: 3 # contributors y: 11 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java x: 3 # contributors y: 5 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java x: 77 # contributors y: 352 # changes clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java x: 29 # contributors y: 40 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java x: 65 # contributors y: 196 # changes clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java x: 54 # contributors y: 151 # changes clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java x: 28 # contributors y: 51 # changes clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java x: 33 # contributors y: 54 # changes clients/src/main/java/org/apache/kafka/common/utils/Utils.java x: 90 # contributors y: 149 # changes core/src/main/scala/kafka/coordinator/group/CoordinatorPartitionWriter.scala x: 9 # contributors y: 19 # changes core/src/main/scala/kafka/server/DelayedProduce.scala x: 19 # contributors y: 32 # changes core/src/main/scala/kafka/server/ReplicaManager.scala x: 123 # contributors y: 444 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java x: 18 # contributors y: 50 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java x: 57 # contributors y: 173 # changes clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java x: 21 # contributors y: 36 # changes core/src/main/scala/kafka/log/LogManager.scala x: 87 # contributors y: 232 # changes core/src/main/scala/kafka/server/AbstractFetcherManager.scala x: 29 # contributors y: 53 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java x: 33 # contributors y: 68 # changes clients/src/main/java/org/apache/kafka/clients/admin/Admin.java x: 50 # contributors y: 66 # changes clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java x: 14 # contributors y: 20 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java x: 18 # contributors y: 56 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java x: 8 # contributors y: 12 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java x: 11 # contributors y: 22 # changes streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java x: 77 # contributors y: 227 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/ReadOnlyTask.java x: 6 # contributors y: 11 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java x: 26 # contributors y: 97 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java x: 58 # contributors y: 233 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java x: 17 # contributors y: 57 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java x: 36 # contributors y: 199 # changes streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java x: 37 # contributors y: 126 # changes clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupHeartbeatResponse.java x: 5 # contributors y: 4 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java x: 38 # contributors y: 83 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java x: 29 # contributors y: 50 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java x: 12 # contributors y: 20 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java x: 46 # contributors y: 98 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java x: 20 # contributors y: 31 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java x: 44 # contributors y: 84 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java x: 39 # contributors y: 77 # changes connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java x: 23 # contributors y: 37 # changes clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java x: 118 # contributors y: 242 # changes clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java x: 41 # contributors y: 57 # changes clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java x: 73 # contributors y: 137 # changes clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java x: 33 # contributors y: 100 # changes clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java x: 8 # contributors y: 8 # changes clients/src/main/java/org/apache/kafka/common/protocol/Readable.java x: 11 # contributors y: 14 # changes clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java x: 43 # contributors y: 112 # changes clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java x: 9 # contributors y: 9 # changes clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java x: 14 # contributors y: 22 # changes clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsResponse.java x: 10 # contributors y: 10 # changes clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java x: 13 # contributors y: 20 # changes clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java x: 17 # contributors y: 27 # changes clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java x: 30 # contributors y: 66 # changes clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java x: 14 # contributors y: 25 # changes clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdResponse.java x: 7 # contributors y: 14 # changes clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java x: 19 # contributors y: 34 # changes clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java x: 12 # contributors y: 22 # changes clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java x: 34 # contributors y: 62 # changes clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java x: 19 # contributors y: 39 # changes clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java x: 22 # contributors y: 43 # changes clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java x: 19 # contributors y: 37 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java x: 12 # contributors y: 27 # changes metadata/src/main/java/org/apache/kafka/controller/ConfigurationControlManager.java x: 15 # contributors y: 35 # changes metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java x: 17 # contributors y: 37 # changes raft/src/main/java/org/apache/kafka/raft/LeaderState.java x: 19 # contributors y: 50 # changes clients/src/main/java/org/apache/kafka/clients/consumer/KafkaShareConsumer.java x: 4 # contributors y: 10 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeShareGroupsHandler.java x: 2 # contributors y: 9 # changes core/src/main/scala/kafka/admin/ConfigCommand.scala x: 57 # contributors y: 113 # changes core/src/main/scala/kafka/server/DynamicConfig.scala x: 22 # contributors y: 32 # changes clients/src/main/java/org/apache/kafka/common/serialization/Deserializer.java x: 12 # contributors y: 15 # changes core/src/main/scala/kafka/server/FetchSession.scala x: 22 # contributors y: 29 # changes clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java x: 71 # contributors y: 119 # changes clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java x: 28 # contributors y: 37 # changes clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsResult.java x: 10 # contributors y: 9 # changes connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java x: 15 # contributors y: 21 # changes core/src/main/scala/kafka/server/KafkaBroker.scala x: 18 # contributors y: 30 # changes metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java x: 25 # contributors y: 62 # changes clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java x: 24 # contributors y: 40 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Group.java x: 13 # contributors y: 22 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinator.java x: 11 # contributors y: 32 # changes core/src/main/scala/kafka/server/ControllerApis.scala x: 30 # contributors y: 62 # changes connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java x: 16 # contributors y: 22 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java x: 10 # contributors y: 21 # changes core/src/main/scala/kafka/server/ConfigHandler.scala x: 39 # contributors y: 73 # changes core/src/main/scala/kafka/tools/TestRaftRequestHandler.scala x: 10 # contributors y: 19 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Herder.java x: 17 # contributors y: 34 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java x: 56 # contributors y: 128 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java x: 12 # contributors y: 17 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java x: 27 # contributors y: 49 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java x: 17 # contributors y: 40 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java x: 16 # contributors y: 33 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java x: 18 # contributors y: 38 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java x: 24 # contributors y: 49 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java x: 30 # contributors y: 58 # changes connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java x: 20 # contributors y: 33 # changes core/src/main/scala/kafka/network/RequestChannel.scala x: 60 # contributors y: 158 # changes core/src/main/scala/kafka/server/KafkaRequestHandler.scala x: 40 # contributors y: 83 # changes server-common/src/main/java/org/apache/kafka/server/config/ServerLogConfigs.java x: 12 # contributors y: 12 # changes storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java x: 18 # contributors y: 28 # changes clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java x: 55 # contributors y: 114 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestManagers.java x: 14 # contributors y: 36 # changes clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java x: 36 # contributors y: 58 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java x: 28 # contributors y: 61 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java x: 13 # contributors y: 52 # changes streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java x: 90 # contributors y: 239 # changes core/src/main/scala/kafka/server/ClientQuotaManager.scala x: 35 # contributors y: 63 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/PartitionCreationBench.java x: 22 # contributors y: 37 # changes core/src/main/java/kafka/server/builders/LogManagerBuilder.java x: 18 # contributors y: 22 # changes core/src/main/java/kafka/server/builders/ReplicaManagerBuilder.java x: 21 # contributors y: 28 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java x: 5 # contributors y: 26 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java x: 55 # contributors y: 154 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java x: 32 # contributors y: 51 # changes storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java x: 11 # contributors y: 12 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java x: 12 # contributors y: 42 # changes streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java x: 3 # contributors y: 14 # changes streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java x: 8 # contributors y: 13 # changes streams/src/main/java/org/apache/kafka/streams/kstream/Predicate.java x: 5 # contributors y: 13 # changes raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java x: 19 # contributors y: 27 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java x: 22 # contributors y: 45 # changes core/src/main/scala/kafka/server/ReplicaFetcherThread.scala x: 72 # contributors y: 164 # changes clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java x: 50 # contributors y: 136 # changes metadata/src/main/java/org/apache/kafka/controller/QuorumFeatures.java x: 11 # contributors y: 20 # changes metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java x: 35 # contributors y: 97 # changes metadata/src/main/java/org/apache/kafka/metadata/PartitionRegistration.java x: 15 # contributors y: 28 # changes gradle/spotbugs-exclude.xml x: 38 # contributors y: 67 # changes clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java x: 25 # contributors y: 58 # changes clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java x: 41 # contributors y: 88 # changes clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsRequest.java x: 15 # contributors y: 22 # changes clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java x: 9 # contributors y: 21 # changes clients/src/main/java/org/apache/kafka/common/requests/RequestContext.java x: 8 # contributors y: 19 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java x: 19 # contributors y: 30 # changes clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java x: 45 # contributors y: 69 # changes core/src/main/scala/kafka/server/metadata/KRaftMetadataCache.scala x: 26 # contributors y: 41 # changes clients/src/main/java/org/apache/kafka/common/record/FileRecords.java x: 16 # contributors y: 43 # changes core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala x: 15 # contributors y: 31 # changes core/src/main/scala/kafka/cluster/Replica.scala x: 24 # contributors y: 54 # changes core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala x: 27 # contributors y: 51 # changes core/src/main/scala/kafka/server/ConfigHelper.scala x: 14 # contributors y: 15 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java x: 23 # contributors y: 42 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java x: 23 # contributors y: 46 # changes core/src/main/scala/kafka/tools/DumpLogSegments.scala x: 55 # contributors y: 121 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java x: 8 # contributors y: 45 # changes core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala x: 15 # contributors y: 26 # changes clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java x: 34 # contributors y: 77 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java x: 38 # contributors y: 136 # changes core/src/main/scala/kafka/server/BrokerLifecycleManager.scala x: 17 # contributors y: 31 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java x: 12 # contributors y: 33 # changes clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java x: 17 # contributors y: 20 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformAssignor.java x: 6 # contributors y: 13 # changes clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java x: 15 # contributors y: 17 # changes clients/src/main/java/org/apache/kafka/common/acl/AclBinding.java x: 4 # contributors y: 8 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java x: 35 # contributors y: 115 # changes streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java x: 31 # contributors y: 58 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java x: 29 # contributors y: 63 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java x: 49 # contributors y: 154 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java x: 17 # contributors y: 26 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java x: 47 # contributors y: 112 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java x: 11 # contributors y: 25 # changes core/src/main/scala/kafka/server/KafkaRaftServer.scala x: 18 # contributors y: 48 # changes core/src/main/scala/kafka/tools/StorageTool.scala x: 21 # contributors y: 40 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java x: 13 # contributors y: 25 # changes streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java x: 20 # contributors y: 29 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java x: 17 # contributors y: 33 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java x: 26 # contributors y: 80 # changes streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java x: 20 # contributors y: 36 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java x: 21 # contributors y: 45 # changes streams/src/main/java/org/apache/kafka/streams/Topology.java x: 18 # contributors y: 34 # changes streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java x: 49 # contributors y: 134 # changes streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java x: 29 # contributors y: 77 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java x: 18 # contributors y: 42 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java x: 29 # contributors y: 46 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java x: 33 # contributors y: 74 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java x: 32 # contributors y: 65 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java x: 42 # contributors y: 98 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java x: 16 # contributors y: 30 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMap.java x: 10 # contributors y: 31 # changes core/src/main/scala/kafka/server/SharedServer.scala x: 14 # contributors y: 32 # changes streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java x: 17 # contributors y: 46 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java x: 23 # contributors y: 54 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java x: 16 # contributors y: 35 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java x: 33 # contributors y: 83 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java x: 21 # contributors y: 54 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java x: 22 # contributors y: 60 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java x: 19 # contributors y: 48 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java x: 16 # contributors y: 28 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java x: 18 # contributors y: 53 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java x: 7 # contributors y: 22 # changes clients/src/main/java/org/apache/kafka/clients/NetworkClient.java x: 60 # contributors y: 141 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBuffer.java x: 3 # contributors y: 8 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java x: 29 # contributors y: 75 # changes tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java x: 23 # contributors y: 31 # changes clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java x: 21 # contributors y: 51 # changes clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java x: 22 # contributors y: 48 # changes streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java x: 14 # contributors y: 37 # changes core/src/main/scala/kafka/Kafka.scala x: 32 # contributors y: 47 # changes connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java x: 23 # contributors y: 33 # changes generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java x: 19 # contributors y: 46 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java x: 25 # contributors y: 46 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java x: 5 # contributors y: 18 # changes tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java x: 33 # contributors y: 39 # changes connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java x: 32 # contributors y: 35 # changes connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java x: 18 # contributors y: 18 # changes clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java x: 21 # contributors y: 66 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java x: 35 # contributors y: 118 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java x: 43 # contributors y: 130 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java x: 20 # contributors y: 51 # changes connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java x: 27 # contributors y: 37 # changes streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java x: 16 # contributors y: 41 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStore.java x: 5 # contributors y: 16 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMapValues.java x: 13 # contributors y: 31 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java x: 35 # contributors y: 55 # changes streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala x: 26 # contributors y: 42 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java x: 15 # contributors y: 37 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java x: 14 # contributors y: 28 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java x: 15 # contributors y: 44 # changes clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java x: 24 # contributors y: 30 # changes clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java x: 16 # contributors y: 37 # changes clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java x: 53 # contributors y: 80 # changes clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java x: 25 # contributors y: 34 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java x: 31 # contributors y: 43 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java x: 21 # contributors y: 48 # changes core/src/main/scala/kafka/server/DelayedFetch.scala x: 24 # contributors y: 51 # changes clients/src/main/java/org/apache/kafka/common/network/Selector.java x: 55 # contributors y: 107 # changes clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java x: 35 # contributors y: 45 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java x: 11 # contributors y: 36 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/TasksRegistry.java x: 4 # contributors y: 16 # changes clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java x: 23 # contributors y: 29 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java x: 20 # contributors y: 37 # changes tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java x: 26 # contributors y: 33 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java x: 22 # contributors y: 86 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StateUpdater.java x: 4 # contributors y: 18 # changes clients/src/main/java/org/apache/kafka/common/metrics/stats/Percentiles.java x: 15 # contributors y: 16 # changes clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java x: 20 # contributors y: 41 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamBranch.java x: 8 # contributors y: 7 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java x: 15 # contributors y: 32 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java x: 18 # contributors y: 40 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignor.java x: 9 # contributors y: 23 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java x: 25 # contributors y: 65 # changes connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java x: 18 # contributors y: 20 # changes core/src/main/scala/kafka/utils/VerifiableProperties.scala x: 18 # contributors y: 25 # changes streams/src/main/java/org/apache/kafka/streams/state/Stores.java x: 24 # contributors y: 58 # changes streams/src/main/java/org/apache/kafka/streams/state/VersionedKeyValueStore.java x: 1 # contributors y: 5 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogReader.java x: 6 # contributors y: 16 # changes clients/src/main/java/org/apache/kafka/common/TopicPartition.java x: 9 # contributors y: 7 # changes streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java x: 11 # contributors y: 27 # changes
615.0
# changes
  min: 1.0
  average: 10.44
  25th percentile: 2.0
  median: 4.0
  75th percentile: 9.0
  max: 615.0
0 172.0
# contributors
min: 1.0 | average: 6.14 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 7.0 | max: 172.0

Number of Contributors vs. File Size: 3541 points

clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java x: 103 # contributors y: 4131 lines of code core/src/main/java/kafka/server/share/DelayedShareFetch.java x: 5 # contributors y: 650 lines of code core/src/main/java/kafka/server/share/SharePartition.java x: 11 # contributors y: 2060 lines of code core/src/main/scala/kafka/raft/KafkaMetadataLog.scala x: 25 # contributors y: 548 lines of code core/src/main/scala/kafka/server/BrokerServer.scala x: 66 # contributors y: 642 lines of code core/src/main/scala/kafka/server/DynamicBrokerConfig.scala x: 46 # contributors y: 851 lines of code raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java x: 47 # contributors y: 3122 lines of code raft/src/main/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachine.java x: 10 # contributors y: 220 lines of code raft/src/main/java/org/apache/kafka/raft/internals/RecordsBatchReader.java x: 6 # contributors y: 93 lines of code raft/src/main/java/org/apache/kafka/raft/internals/RecordsIterator.java x: 10 # contributors y: 292 lines of code raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotReader.java x: 7 # contributors y: 114 lines of code raft/src/main/java/org/apache/kafka/snapshot/Snapshots.java x: 11 # contributors y: 134 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java x: 4 # contributors y: 38 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/ListShareGroupOffsetsHandler.java x: 2 # contributors y: 156 lines of code clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateSummaryResponse.java x: 4 # contributors y: 107 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java x: 22 # contributors y: 1746 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java x: 4 # contributors y: 486 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/NoOpStatePersister.java x: 2 # contributors y: 70 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionFactory.java x: 3 # contributors y: 31 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateSummaryData.java x: 2 # contributors y: 8 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java x: 8 # contributors y: 733 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommand.java x: 4 # contributors y: 501 lines of code core/src/main/scala/kafka/server/ForwardingManager.scala x: 10 # contributors y: 146 lines of code server/src/main/java/org/apache/kafka/server/metrics/ForwardingManagerMetrics.java x: 1 # contributors y: 88 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsOptions.java x: 1 # contributors y: 13 lines of code clients/src/main/java/org/apache/kafka/common/protocol/Errors.java x: 61 # contributors y: 492 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java x: 10 # contributors y: 1164 lines of code server/src/main/java/org/apache/kafka/server/share/fetch/DelayedShareFetchGroupKey.java x: 1 # contributors y: 39 lines of code core/src/main/java/kafka/server/share/PendingRemoteFetches.java x: 1 # contributors y: 56 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareSessionHandler.java x: 5 # contributors y: 186 lines of code clients/src/main/java/org/apache/kafka/clients/Metadata.java x: 36 # contributors y: 525 lines of code clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResult.java x: 4 # contributors y: 81 lines of code server/src/main/java/org/apache/kafka/server/AssignmentsManager.java x: 13 # contributors y: 367 lines of code tools/src/main/java/org/apache/kafka/tools/ClusterTool.java x: 5 # contributors y: 165 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java x: 130 # contributors y: 290 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java x: 26 # contributors y: 1650 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/CloseOptions.java x: 2 # contributors y: 36 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java x: 7 # contributors y: 854 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java x: 47 # contributors y: 557 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java x: 7 # contributors y: 1748 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java x: 26 # contributors y: 5425 lines of code streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java x: 4 # contributors y: 10 lines of code tools/src/main/java/org/apache/kafka/tools/DeleteRecordsCommand.java x: 4 # contributors y: 137 lines of code tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java x: 7 # contributors y: 323 lines of code tools/src/main/java/org/apache/kafka/tools/TopicCommand.java x: 17 # contributors y: 834 lines of code tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java x: 14 # contributors y: 1054 lines of code core/src/main/java/kafka/server/TierStateMachine.java x: 9 # contributors y: 169 lines of code core/src/main/scala/kafka/cluster/Partition.scala x: 92 # contributors y: 1320 lines of code core/src/main/scala/kafka/server/AbstractFetcherThread.scala x: 70 # contributors y: 680 lines of code metadata/src/main/java/org/apache/kafka/controller/OffsetControlManager.java x: 7 # contributors y: 244 lines of code metadata/src/main/java/org/apache/kafka/controller/QuorumController.java x: 40 # contributors y: 1654 lines of code metadata/src/main/java/org/apache/kafka/image/MetadataImage.java x: 9 # contributors y: 144 lines of code raft/src/main/java/org/apache/kafka/raft/QuorumState.java x: 20 # contributors y: 719 lines of code raft/src/main/java/org/apache/kafka/raft/RaftClient.java x: 13 # contributors y: 38 lines of code raft/src/main/java/org/apache/kafka/raft/RaftUtil.java x: 12 # contributors y: 653 lines of code raft/src/main/java/org/apache/kafka/raft/ReplicatedLog.java x: 12 # contributors y: 77 lines of code raft/src/main/java/org/apache/kafka/raft/ValidOffsetAndEpoch.java x: 4 # contributors y: 52 lines of code raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotReader.java x: 5 # contributors y: 61 lines of code raft/src/main/java/org/apache/kafka/snapshot/NotifyingRawSnapshotWriter.java x: 3 # contributors y: 46 lines of code raft/src/main/java/org/apache/kafka/snapshot/RawSnapshotReader.java x: 5 # contributors y: 10 lines of code raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotWriter.java x: 11 # contributors y: 207 lines of code raft/src/main/java/org/apache/kafka/snapshot/SnapshotReader.java x: 7 # contributors y: 11 lines of code raft/src/main/java/org/apache/kafka/snapshot/SnapshotWriter.java x: 13 # contributors y: 13 lines of code server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java x: 26 # contributors y: 236 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala x: 31 # contributors y: 818 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala x: 39 # contributors y: 647 lines of code core/src/main/scala/kafka/server/KafkaApis.scala x: 148 # contributors y: 3343 lines of code tools/src/main/java/org/apache/kafka/tools/TransactionsCommand.java x: 10 # contributors y: 873 lines of code core/src/main/java/kafka/server/share/SharePartitionManager.java x: 14 # contributors y: 549 lines of code server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java x: 3 # contributors y: 91 lines of code clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java x: 44 # contributors y: 242 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractHeartbeatRequestManager.java x: 8 # contributors y: 284 lines of code streams/src/main/java/org/apache/kafka/streams/processor/assignment/assignors/StickyTaskAssignor.java x: 4 # contributors y: 380 lines of code core/src/main/java/kafka/server/builders/KafkaApisBuilder.java x: 17 # contributors y: 188 lines of code core/src/main/scala/kafka/server/AutoTopicCreationManager.scala x: 16 # contributors y: 201 lines of code core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala x: 24 # contributors y: 246 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfig.java x: 5 # contributors y: 121 lines of code core/src/main/scala/kafka/server/KafkaConfig.scala x: 172 # contributors y: 607 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java x: 20 # contributors y: 564 lines of code core/src/main/scala/kafka/network/SocketServer.scala x: 84 # contributors y: 1249 lines of code core/src/main/scala/kafka/server/ControllerServer.scala x: 34 # contributors y: 379 lines of code core/src/main/scala/kafka/tools/TestRaftServer.scala x: 27 # contributors y: 397 lines of code core/src/main/scala/kafka/utils/CoreUtils.scala x: 30 # contributors y: 116 lines of code metadata/src/main/java/org/apache/kafka/metadata/BrokerRegistration.java x: 16 # contributors y: 333 lines of code metadata/src/main/java/org/apache/kafka/metadata/ListenerInfo.java x: 3 # contributors y: 261 lines of code metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java x: 13 # contributors y: 194 lines of code server-common/src/main/java/org/apache/kafka/server/network/EndpointReadyFutures.java x: 6 # contributors y: 152 lines of code tools/src/main/java/org/apache/kafka/tools/MetadataQuorumCommand.java x: 9 # contributors y: 443 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java x: 3 # contributors y: 522 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java x: 3 # contributors y: 298 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java x: 77 # contributors y: 1511 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java x: 29 # contributors y: 69 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java x: 13 # contributors y: 1002 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java x: 65 # contributors y: 118 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java x: 54 # contributors y: 796 lines of code clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java x: 28 # contributors y: 171 lines of code clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java x: 33 # contributors y: 206 lines of code clients/src/main/java/org/apache/kafka/common/utils/Utils.java x: 90 # contributors y: 924 lines of code core/src/main/scala/kafka/coordinator/group/CoordinatorPartitionWriter.scala x: 9 # contributors y: 127 lines of code core/src/main/scala/kafka/server/DelayedProduce.scala x: 19 # contributors y: 88 lines of code core/src/main/scala/kafka/server/ReplicaManager.scala x: 123 # contributors y: 2203 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerRequestBenchmark.java x: 6 # contributors y: 62 lines of code clients/src/main/java/org/apache/kafka/clients/producer/PreparedTxnState.java x: 1 # contributors y: 65 lines of code tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java x: 1 # contributors y: 331 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java x: 18 # contributors y: 965 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java x: 57 # contributors y: 1203 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java x: 21 # contributors y: 200 lines of code core/src/main/scala/kafka/log/LogManager.scala x: 87 # contributors y: 1098 lines of code core/src/main/scala/kafka/server/AbstractFetcherManager.scala x: 29 # contributors y: 184 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java x: 33 # contributors y: 292 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginClassLoader.java x: 5 # contributors y: 76 lines of code clients/src/main/java/org/apache/kafka/clients/admin/Admin.java x: 50 # contributors y: 351 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java x: 14 # contributors y: 285 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteShareGroupOffsetsHandler.java x: 2 # contributors y: 130 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java x: 18 # contributors y: 868 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManager.java x: 3 # contributors y: 1657 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java x: 8 # contributors y: 599 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java x: 11 # contributors y: 754 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsCoordinatorRecordHelpers.java x: 3 # contributors y: 327 lines of code streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java x: 77 # contributors y: 1397 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ReadOnlyTask.java x: 6 # contributors y: 187 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java x: 58 # contributors y: 1027 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java x: 17 # contributors y: 103 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java x: 9 # contributors y: 218 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java x: 36 # contributors y: 1727 lines of code streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java x: 37 # contributors y: 858 lines of code metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadata.java x: 5 # contributors y: 145 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java x: 38 # contributors y: 1033 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java x: 11 # contributors y: 509 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java x: 12 # contributors y: 435 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java x: 29 # contributors y: 608 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorStatus.java x: 6 # contributors y: 22 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java x: 12 # contributors y: 422 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TransformationChain.java x: 10 # contributors y: 59 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java x: 46 # contributors y: 1718 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java x: 20 # contributors y: 487 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java x: 44 # contributors y: 754 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java x: 39 # contributors y: 274 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java x: 24 # contributors y: 412 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java x: 23 # contributors y: 556 lines of code clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java x: 118 # contributors y: 831 lines of code clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java x: 41 # contributors y: 431 lines of code clients/src/main/java/org/apache/kafka/clients/producer/Producer.java x: 16 # contributors y: 36 lines of code clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java x: 73 # contributors y: 528 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java x: 33 # contributors y: 1385 lines of code clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java x: 8 # contributors y: 130 lines of code core/src/main/java/kafka/server/share/ShareFetchUtils.java x: 8 # contributors y: 175 lines of code server/src/main/java/org/apache/kafka/server/share/fetch/ShareFetch.java x: 2 # contributors y: 117 lines of code clients/src/main/java/org/apache/kafka/common/protocol/Readable.java x: 11 # contributors y: 51 lines of code clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java x: 43 # contributors y: 262 lines of code clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java x: 10 # contributors y: 40 lines of code clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponse.java x: 12 # contributors y: 106 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java x: 8 # contributors y: 85 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsResponse.java x: 8 # contributors y: 46 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionResponse.java x: 5 # contributors y: 38 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java x: 8 # contributors y: 41 lines of code clients/src/main/java/org/apache/kafka/common/requests/BeginQuorumEpochResponse.java x: 7 # contributors y: 40 lines of code clients/src/main/java/org/apache/kafka/common/requests/CreateAclsResponse.java x: 9 # contributors y: 40 lines of code clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java x: 9 # contributors y: 75 lines of code clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java x: 14 # contributors y: 41 lines of code clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsResponse.java x: 11 # contributors y: 110 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsResponse.java x: 12 # contributors y: 128 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasResponse.java x: 8 # contributors y: 88 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java x: 17 # contributors y: 112 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java x: 14 # contributors y: 44 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeProducersResponse.java x: 2 # contributors y: 46 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeQuorumResponse.java x: 7 # contributors y: 67 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java x: 3 # contributors y: 68 lines of code clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java x: 9 # contributors y: 43 lines of code clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java x: 30 # contributors y: 195 lines of code clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorResponse.java x: 14 # contributors y: 137 lines of code clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdResponse.java x: 7 # contributors y: 43 lines of code clients/src/main/java/org/apache/kafka/common/requests/InitializeShareGroupStateResponse.java x: 4 # contributors y: 96 lines of code clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java x: 19 # contributors y: 52 lines of code clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java x: 12 # contributors y: 36 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java x: 19 # contributors y: 206 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java x: 22 # contributors y: 307 lines of code clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java x: 13 # contributors y: 138 lines of code clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersResponse.java x: 10 # contributors y: 84 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java x: 2 # contributors y: 829 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareGroupOffset.java x: 2 # contributors y: 200 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/AlterConsumerGroupOffsetsHandler.java x: 7 # contributors y: 160 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java x: 19 # contributors y: 109 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java x: 12 # contributors y: 757 lines of code metadata/src/main/java/org/apache/kafka/controller/ConfigurationControlManager.java x: 15 # contributors y: 591 lines of code metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java x: 17 # contributors y: 376 lines of code raft/src/main/java/org/apache/kafka/raft/LeaderState.java x: 19 # contributors y: 874 lines of code raft/src/main/java/org/apache/kafka/raft/VoterSet.java x: 4 # contributors y: 281 lines of code raft/src/main/java/org/apache/kafka/raft/internals/UpdateVoterHandler.java x: 5 # contributors y: 242 lines of code server-common/src/main/java/org/apache/kafka/server/common/KRaftVersion.java x: 6 # contributors y: 83 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterStateManager.java x: 4 # contributors y: 1156 lines of code release/release.py x: 6 # contributors y: 237 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaner.java x: 2 # contributors y: 359 lines of code core/src/main/scala/kafka/raft/RaftManager.scala x: 30 # contributors y: 244 lines of code core/src/main/scala/kafka/admin/ConfigCommand.scala x: 57 # contributors y: 582 lines of code core/src/main/scala/kafka/server/DynamicConfig.scala x: 22 # contributors y: 32 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java x: 14 # contributors y: 513 lines of code clients/src/main/java/org/apache/kafka/common/serialization/Deserializer.java x: 12 # contributors y: 20 lines of code clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java x: 10 # contributors y: 15 lines of code core/src/main/scala/kafka/server/FetchSession.scala x: 22 # contributors y: 580 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java x: 71 # contributors y: 574 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java x: 10 # contributors y: 335 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchCollector.java x: 7 # contributors y: 271 lines of code clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java x: 28 # contributors y: 164 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java x: 7 # contributors y: 86 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java x: 15 # contributors y: 219 lines of code server/src/main/java/org/apache/kafka/server/config/AbstractKafkaConfig.java x: 13 # contributors y: 58 lines of code core/src/main/scala/kafka/server/KafkaBroker.scala x: 18 # contributors y: 82 lines of code metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java x: 25 # contributors y: 650 lines of code clients/src/main/java/org/apache/kafka/common/errors/GroupMaxSizeReachedException.java x: 3 # contributors y: 7 lines of code clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java x: 24 # contributors y: 101 lines of code coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java x: 10 # contributors y: 1472 lines of code core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala x: 11 # contributors y: 243 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Group.java x: 13 # contributors y: 74 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinator.java x: 11 # contributors y: 172 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java x: 14 # contributors y: 806 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroup.java x: 7 # contributors y: 186 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java x: 3 # contributors y: 623 lines of code clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java x: 6 # contributors y: 121 lines of code core/src/main/java/kafka/server/QuotaFactory.java x: 3 # contributors y: 141 lines of code core/src/main/scala/kafka/server/ControllerApis.scala x: 30 # contributors y: 975 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java x: 16 # contributors y: 268 lines of code tools/src/main/java/org/apache/kafka/tools/PushHttpMetricsReporter.java x: 8 # contributors y: 255 lines of code core/src/main/scala/kafka/server/ConfigHandler.scala x: 39 # contributors y: 122 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Herder.java x: 17 # contributors y: 74 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SubmittedRecords.java x: 3 # contributors y: 158 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java x: 56 # contributors y: 2304 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java x: 12 # contributors y: 729 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java x: 27 # contributors y: 494 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/DeadLetterQueueReporter.java x: 10 # contributors y: 155 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java x: 11 # contributors y: 215 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java x: 17 # contributors y: 197 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java x: 16 # contributors y: 393 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java x: 18 # contributors y: 501 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java x: 16 # contributors y: 158 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResource.java x: 16 # contributors y: 137 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java x: 24 # contributors y: 345 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java x: 30 # contributors y: 503 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java x: 5 # contributors y: 315 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java x: 27 # contributors y: 868 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java x: 20 # contributors y: 287 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryConfigBackingStore.java x: 13 # contributors y: 160 lines of code server-common/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java x: 9 # contributors y: 383 lines of code core/src/main/scala/kafka/network/RequestChannel.scala x: 60 # contributors y: 372 lines of code core/src/main/scala/kafka/server/KafkaRequestHandler.scala x: 40 # contributors y: 168 lines of code config/log4j2.yaml x: 3 # contributors y: 112 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/Cleaner.java x: 1 # contributors y: 462 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleanerManager.java x: 1 # contributors y: 502 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java x: 18 # contributors y: 540 lines of code tools/src/main/java/org/apache/kafka/tools/GroupsCommand.java x: 3 # contributors y: 241 lines of code core/src/main/scala/kafka/server/ControllerMutationQuotaManager.scala x: 4 # contributors y: 151 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java x: 55 # contributors y: 731 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestManagers.java x: 14 # contributors y: 329 lines of code clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java x: 36 # contributors y: 382 lines of code server/src/main/java/org/apache/kafka/server/share/context/ShareSessionContext.java x: 4 # contributors y: 173 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupConfig.java x: 7 # contributors y: 280 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java x: 28 # contributors y: 444 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java x: 13 # contributors y: 561 lines of code streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java x: 90 # contributors y: 1371 lines of code core/src/main/scala/kafka/server/ClientQuotaManager.scala x: 35 # contributors y: 405 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/CheckpointBench.java x: 24 # contributors y: 139 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/PartitionCreationBench.java x: 22 # contributors y: 175 lines of code core/src/main/java/kafka/server/builders/LogManagerBuilder.java x: 18 # contributors y: 135 lines of code core/src/main/java/kafka/server/builders/ReplicaManagerBuilder.java x: 21 # contributors y: 101 lines of code core/src/main/java/kafka/server/handlers/DescribeTopicPartitionsRequestHandler.java x: 5 # contributors y: 97 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java x: 5 # contributors y: 1114 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LocalLog.java x: 5 # contributors y: 666 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java x: 55 # contributors y: 1170 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java x: 6 # contributors y: 756 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManager.java x: 5 # contributors y: 218 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManager.java x: 2 # contributors y: 270 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java x: 32 # contributors y: 174 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java x: 11 # contributors y: 350 lines of code server-common/src/main/java/org/apache/kafka/server/util/InterBrokerSendThread.java x: 5 # contributors y: 202 lines of code storage/src/main/java/org/apache/kafka/server/purgatory/DelayedRemoteListOffsets.java x: 1 # contributors y: 146 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java x: 12 # contributors y: 236 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java x: 14 # contributors y: 442 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java x: 17 # contributors y: 414 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegments.java x: 6 # contributors y: 135 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogValidator.java x: 12 # contributors y: 460 lines of code storage/src/main/java/org/apache/kafka/storage/log/metrics/BrokerTopicMetrics.java x: 5 # contributors y: 327 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java x: 8 # contributors y: 5 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java x: 9 # contributors y: 8 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKeySupplier.java x: 6 # contributors y: 7 lines of code raft/src/main/java/org/apache/kafka/raft/ElectionState.java x: 8 # contributors y: 152 lines of code raft/src/main/java/org/apache/kafka/raft/QuorumConfig.java x: 7 # contributors y: 233 lines of code raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java x: 19 # contributors y: 451 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java x: 22 # contributors y: 354 lines of code core/src/main/scala/kafka/server/ReplicaFetcherManager.scala x: 19 # contributors y: 37 lines of code core/src/main/scala/kafka/server/ReplicaFetcherThread.scala x: 72 # contributors y: 120 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/InternalTopicManager.java x: 2 # contributors y: 235 lines of code clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java x: 50 # contributors y: 284 lines of code metadata/src/main/java/org/apache/kafka/controller/QuorumFeatures.java x: 11 # contributors y: 101 lines of code metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java x: 35 # contributors y: 1975 lines of code metadata/src/main/java/org/apache/kafka/metadata/PartitionRegistration.java x: 15 # contributors y: 404 lines of code gradle/spotbugs-exclude.xml x: 38 # contributors y: 339 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilder.java x: 8 # contributors y: 316 lines of code clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java x: 25 # contributors y: 567 lines of code clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java x: 41 # contributors y: 285 lines of code clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java x: 11 # contributors y: 154 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsRequest.java x: 9 # contributors y: 97 lines of code clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsRequest.java x: 14 # contributors y: 85 lines of code clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsRequest.java x: 15 # contributors y: 81 lines of code clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsRequest.java x: 15 # contributors y: 86 lines of code clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersRequest.java x: 8 # contributors y: 111 lines of code clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorRequest.java x: 10 # contributors y: 102 lines of code clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java x: 16 # contributors y: 49 lines of code clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupRequest.java x: 13 # contributors y: 89 lines of code clients/src/main/java/org/apache/kafka/common/requests/MetadataRequest.java x: 21 # contributors y: 158 lines of code clients/src/main/java/org/apache/kafka/common/requests/SyncGroupRequest.java x: 12 # contributors y: 63 lines of code clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitRequest.java x: 13 # contributors y: 214 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java x: 19 # contributors y: 309 lines of code server-common/src/main/java/org/apache/kafka/server/common/CheckpointFile.java x: 7 # contributors y: 137 lines of code tools/src/main/java/org/apache/kafka/tools/ClientMetricsCommand.java x: 6 # contributors y: 296 lines of code metadata/src/main/java/org/apache/kafka/metadata/storage/Formatter.java x: 10 # contributors y: 390 lines of code clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java x: 45 # contributors y: 420 lines of code core/src/main/scala/kafka/server/metadata/KRaftMetadataCache.scala x: 26 # contributors y: 379 lines of code tools/src/main/java/org/apache/kafka/tools/AclCommand.java x: 2 # contributors y: 531 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeStreamsGroupsHandler.java x: 2 # contributors y: 233 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala x: 15 # contributors y: 418 lines of code generator/src/main/java/org/apache/kafka/message/checker/FieldSpecPairIterator.java x: 2 # contributors y: 89 lines of code core/src/main/scala/kafka/cluster/Replica.scala x: 24 # contributors y: 119 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala x: 27 # contributors y: 368 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java x: 23 # contributors y: 133 lines of code metadata/src/main/java/org/apache/kafka/controller/ClientQuotaControlManager.java x: 10 # contributors y: 265 lines of code metadata/src/main/java/org/apache/kafka/image/TopicsDelta.java x: 13 # contributors y: 174 lines of code metadata/src/main/java/org/apache/kafka/metadata/KafkaConfigSchema.java x: 7 # contributors y: 209 lines of code metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java x: 10 # contributors y: 427 lines of code metadata/src/main/java/org/apache/kafka/metadata/placement/StripedReplicaPlacer.java x: 6 # contributors y: 213 lines of code metadata/src/main/java/org/apache/kafka/metadata/properties/MetaPropertiesEnsemble.java x: 7 # contributors y: 396 lines of code server/src/main/java/org/apache/kafka/server/ClientMetricsManager.java x: 7 # contributors y: 490 lines of code clients/src/main/java/org/apache/kafka/common/utils/LogContext.java x: 5 # contributors y: 636 lines of code core/src/main/scala/kafka/server/LocalLeaderEndPoint.scala x: 10 # contributors y: 182 lines of code core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala x: 27 # contributors y: 156 lines of code core/src/main/scala/kafka/tools/DumpLogSegments.scala x: 55 # contributors y: 566 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java x: 17 # contributors y: 548 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogLoader.java x: 5 # contributors y: 374 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java x: 8 # contributors y: 955 lines of code tools/src/main/java/org/apache/kafka/tools/ShareConsumerPerformance.java x: 2 # contributors y: 384 lines of code metadata/src/main/java/org/apache/kafka/controller/PeriodicTaskControlManager.java x: 3 # contributors y: 171 lines of code clients/src/main/java/org/apache/kafka/clients/admin/StreamsGroupDescription.java x: 1 # contributors y: 116 lines of code clients/src/main/java/org/apache/kafka/clients/admin/StreamsGroupMemberDescription.java x: 1 # contributors y: 252 lines of code tools/src/main/java/org/apache/kafka/tools/VerifiableShareConsumer.java x: 1 # contributors y: 514 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/Graph.java x: 2 # contributors y: 406 lines of code clients/src/main/java/org/apache/kafka/common/config/internals/BrokerSecurityConfigs.java x: 14 # contributors y: 158 lines of code clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java x: 34 # contributors y: 639 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java x: 38 # contributors y: 1174 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/ModernGroup.java x: 6 # contributors y: 274 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java x: 17 # contributors y: 135 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHeterogeneousAssignmentBuilder.java x: 6 # contributors y: 385 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetrics.java x: 8 # contributors y: 475 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupMember.java x: 5 # contributors y: 393 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupMember.java x: 3 # contributors y: 218 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java x: 15 # contributors y: 167 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java x: 35 # contributors y: 1257 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java x: 20 # contributors y: 166 lines of code streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java x: 31 # contributors y: 176 lines of code streams/src/main/java/org/apache/kafka/streams/TopologyConfig.java x: 12 # contributors y: 284 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java x: 16 # contributors y: 242 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java x: 29 # contributors y: 536 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java x: 49 # contributors y: 1118 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java x: 47 # contributors y: 1852 lines of code clients/src/main/java/org/apache/kafka/common/record/Records.java x: 14 # contributors y: 19 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeConsumerGroupsHandler.java x: 8 # contributors y: 326 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java x: 22 # contributors y: 83 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java x: 19 # contributors y: 71 lines of code clients/src/main/java/org/apache/kafka/clients/ClientUtils.java x: 26 # contributors y: 224 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TopicIds.java x: 4 # contributors y: 220 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java x: 20 # contributors y: 184 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueChangeBuffer.java x: 3 # contributors y: 431 lines of code core/src/main/scala/kafka/server/AlterPartitionManager.scala x: 14 # contributors y: 215 lines of code core/src/main/scala/kafka/tools/StorageTool.scala x: 21 # contributors y: 401 lines of code metadata/src/main/java/org/apache/kafka/image/loader/MetadataLoader.java x: 11 # contributors y: 414 lines of code tools/src/main/java/org/apache/kafka/tools/FeatureCommand.java x: 9 # contributors y: 398 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java x: 15 # contributors y: 19 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java x: 20 # contributors y: 38 lines of code server/src/main/java/org/apache/kafka/network/RequestConvertToJson.java x: 6 # contributors y: 794 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java x: 26 # contributors y: 789 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java x: 27 # contributors y: 37 lines of code streams/src/main/java/org/apache/kafka/streams/Topology.java x: 18 # contributors y: 449 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java x: 49 # contributors y: 183 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetrics.java x: 15 # contributors y: 267 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java x: 29 # contributors y: 403 lines of code clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java x: 20 # contributors y: 122 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/Acknowledgements.java x: 1 # contributors y: 167 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareCompletedFetch.java x: 2 # contributors y: 307 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java x: 33 # contributors y: 459 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java x: 26 # contributors y: 444 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java x: 32 # contributors y: 458 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java x: 15 # contributors y: 125 lines of code core/src/main/scala/kafka/server/ConfigAdminManager.scala x: 9 # contributors y: 322 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java x: 42 # contributors y: 954 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerde.java x: 9 # contributors y: 188 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TargetAssignmentBuilder.java x: 1 # contributors y: 187 lines of code streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java x: 17 # contributors y: 42 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java x: 19 # contributors y: 327 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStore.java x: 14 # contributors y: 95 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java x: 23 # contributors y: 609 lines of code core/src/main/scala/kafka/server/ControllerConfigurationValidator.scala x: 16 # contributors y: 105 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java x: 16 # contributors y: 114 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java x: 21 # contributors y: 215 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java x: 22 # contributors y: 430 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java x: 19 # contributors y: 410 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java x: 30 # contributors y: 473 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java x: 11 # contributors y: 77 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingWindowStore.java x: 5 # contributors y: 572 lines of code storage/src/main/java/org/apache/kafka/storage/log/metrics/BrokerTopicStats.java x: 3 # contributors y: 196 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java x: 18 # contributors y: 829 lines of code clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java x: 23 # contributors y: 321 lines of code clients/src/main/java/org/apache/kafka/common/security/JaasUtils.java x: 11 # contributors y: 9 lines of code clients/src/main/java/org/apache/kafka/clients/NetworkClient.java x: 60 # contributors y: 1124 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContext.java x: 10 # contributors y: 113 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java x: 29 # contributors y: 473 lines of code tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java x: 23 # contributors y: 547 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsRequestManager.java x: 14 # contributors y: 596 lines of code tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java x: 10 # contributors y: 612 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommandOptions.java x: 9 # contributors y: 244 lines of code core/src/main/scala/kafka/server/NodeToControllerChannelManager.scala x: 12 # contributors y: 273 lines of code clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java x: 21 # contributors y: 345 lines of code clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java x: 22 # contributors y: 530 lines of code generator/src/main/java/org/apache/kafka/message/CoordinatorRecordTypeGenerator.java x: 1 # contributors y: 220 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminMetadataManager.java x: 9 # contributors y: 199 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java x: 11 # contributors y: 1435 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java x: 8 # contributors y: 459 lines of code core/src/main/scala/kafka/Kafka.scala x: 32 # contributors y: 75 lines of code clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java x: 22 # contributors y: 239 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java x: 17 # contributors y: 327 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java x: 23 # contributors y: 597 lines of code generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java x: 19 # contributors y: 1611 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java x: 25 # contributors y: 218 lines of code streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskAssignmentUtils.java x: 4 # contributors y: 780 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java x: 28 # contributors y: 738 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java x: 8 # contributors y: 226 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/StoreQueryUtils.java x: 7 # contributors y: 446 lines of code streams/test-utils/src/main/java/org/apache/kafka/streams/processor/api/MockProcessorContext.java x: 9 # contributors y: 346 lines of code tools/src/main/java/org/apache/kafka/tools/ReplicaVerificationTool.java x: 7 # contributors y: 602 lines of code tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java x: 33 # contributors y: 441 lines of code connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java x: 32 # contributors y: 623 lines of code connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java x: 18 # contributors y: 413 lines of code connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java x: 8 # contributors y: 407 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/core/TestPurgatoryPerformance.java x: 3 # contributors y: 380 lines of code server-common/src/main/java/org/apache/kafka/timeline/TimelineHashSet.java x: 4 # contributors y: 195 lines of code tools/src/main/java/org/apache/kafka/tools/ConsoleProducer.java x: 2 # contributors y: 292 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java x: 5 # contributors y: 456 lines of code clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java x: 21 # contributors y: 568 lines of code streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java x: 11 # contributors y: 31 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java x: 35 # contributors y: 592 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java x: 17 # contributors y: 164 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStore.java x: 13 # contributors y: 119 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java x: 43 # contributors y: 793 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java x: 27 # contributors y: 349 lines of code streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java x: 16 # contributors y: 343 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStore.java x: 5 # contributors y: 616 lines of code connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java x: 15 # contributors y: 38 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java x: 14 # contributors y: 345 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java x: 14 # contributors y: 112 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java x: 35 # contributors y: 353 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java x: 13 # contributors y: 508 lines of code streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala x: 26 # contributors y: 164 lines of code clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java x: 7 # contributors y: 669 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java x: 4 # contributors y: 269 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/workload/ShareConsumeBenchWorker.java x: 1 # contributors y: 406 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java x: 21 # contributors y: 138 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java x: 15 # contributors y: 312 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java x: 11 # contributors y: 404 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java x: 19 # contributors y: 171 lines of code streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KTable.scala x: 18 # contributors y: 198 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcher.java x: 10 # contributors y: 305 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java x: 15 # contributors y: 286 lines of code clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java x: 24 # contributors y: 263 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiDriver.java x: 7 # contributors y: 355 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java x: 16 # contributors y: 1024 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java x: 16 # contributors y: 373 lines of code clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java x: 53 # contributors y: 1043 lines of code clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java x: 14 # contributors y: 464 lines of code clients/src/main/java/org/apache/kafka/common/security/ssl/CommonNameLoggingTrustManagerFactoryWrapper.java x: 4 # contributors y: 302 lines of code raft/src/main/java/org/apache/kafka/raft/internals/AddVoterHandler.java x: 5 # contributors y: 268 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/connect/JsonConverterBenchmark.java x: 3 # contributors y: 389 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java x: 31 # contributors y: 573 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkerBase.java x: 1 # contributors y: 370 lines of code clients/src/main/java/org/apache/kafka/common/network/Selector.java x: 55 # contributors y: 1030 lines of code clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java x: 35 # contributors y: 333 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java x: 3 # contributors y: 498 lines of code clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java x: 12 # contributors y: 162 lines of code metadata/src/main/java/org/apache/kafka/metadata/properties/MetaProperties.java x: 2 # contributors y: 184 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/util/ByteUtilsBenchmark.java x: 6 # contributors y: 452 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConfig.java x: 8 # contributors y: 268 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java x: 15 # contributors y: 248 lines of code connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java x: 12 # contributors y: 184 lines of code generator/src/main/java/org/apache/kafka/message/FieldSpec.java x: 11 # contributors y: 546 lines of code clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java x: 14 # contributors y: 401 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java x: 11 # contributors y: 262 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java x: 18 # contributors y: 91 lines of code clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java x: 23 # contributors y: 910 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java x: 20 # contributors y: 237 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java x: 13 # contributors y: 316 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStoreSegmentValueFormatter.java x: 4 # contributors y: 358 lines of code tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java x: 26 # contributors y: 390 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java x: 22 # contributors y: 154 lines of code clients/src/main/java/org/apache/kafka/common/record/CompressionType.java x: 19 # contributors y: 133 lines of code server-common/src/main/java/org/apache/kafka/timeline/SnapshottableHashTable.java x: 5 # contributors y: 280 lines of code clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java x: 20 # contributors y: 392 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java x: 20 # contributors y: 71 lines of code clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java x: 13 # contributors y: 482 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java x: 15 # contributors y: 148 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java x: 18 # contributors y: 433 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java x: 20 # contributors y: 329 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/PrefixedWindowKeySchemas.java x: 3 # contributors y: 310 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/SessionKeySchema.java x: 12 # contributors y: 146 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java x: 3 # contributors y: 734 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java x: 17 # contributors y: 468 lines of code clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java x: 29 # contributors y: 302 lines of code clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java x: 17 # contributors y: 11 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java x: 25 # contributors y: 446 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java x: 14 # contributors y: 172 lines of code clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java x: 15 # contributors y: 51 lines of code clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java x: 18 # contributors y: 697 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionWorker.java x: 4 # contributors y: 395 lines of code clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java x: 12 # contributors y: 194 lines of code clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollection.java x: 7 # contributors y: 416 lines of code tools/src/main/java/org/apache/kafka/tools/ManifestWorkspace.java x: 3 # contributors y: 455 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/coordinator/TaskManager.java x: 5 # contributors y: 484 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java x: 4 # contributors y: 466 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java x: 4 # contributors y: 237 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java x: 6 # contributors y: 214 lines of code tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java x: 14 # contributors y: 471 lines of code tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java x: 11 # contributors y: 341 lines of code clients/src/main/java/org/apache/kafka/common/Cluster.java x: 21 # contributors y: 243 lines of code clients/src/main/java/org/apache/kafka/common/network/PlaintextChannelBuilder.java x: 16 # contributors y: 80 lines of code connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java x: 18 # contributors y: 254 lines of code generator/src/main/java/org/apache/kafka/message/SchemaGenerator.java x: 11 # contributors y: 283 lines of code clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java x: 18 # contributors y: 360 lines of code core/src/main/scala/kafka/utils/VerifiableProperties.scala x: 18 # contributors y: 112 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java x: 7 # contributors y: 303 lines of code streams/src/main/java/org/apache/kafka/streams/state/Stores.java x: 24 # contributors y: 213 lines of code clients/src/main/java/org/apache/kafka/common/protocol/types/Struct.java x: 24 # contributors y: 432 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java x: 16 # contributors y: 417 lines of code clients/src/main/java/org/apache/kafka/common/network/SSLTransportLayer.java x: 4 # contributors y: 697 lines of code
5425.0
lines of code
  min: 1.0
  average: 112.57
  25th percentile: 16.0
  median: 46.0
  75th percentile: 110.0
  max: 5425.0
0 172.0
# contributors
min: 1.0 | average: 6.14 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 7.0 | max: 172.0