apache / pekko-connectors-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 122 files with 9,905 lines of code.
    • 2 files changed more than 100 times (153 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 1 file changed 21-50 times (28 lines of code)
    • 33 files changed 6-20 times (4,396 lines of code)
    • 86 files changed 1-5 times (5,328 lines of code)
1% | 0% | <1% | 44% | 53%
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 122 files with 9,905 lines of code.
    • 1 file changed by more than 25 contributors (138 lines of code)
    • 1 file changed by 11-25 contributors (15 lines of code)
    • 0 files changed by 6-10 contributors (0 lines of code)
    • 115 files changed by 2-5 contributors (9,675 lines of code)
    • 5 files changed by 1 contributor (77 lines of code)
1% | <1% | 0% | 97% | <1%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
scala, java, md, yaml, xml, txt, sbt, gitignore, gitattributes, sh, proto, properties
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
sbt100% | 0% | 0% | 0% | 0%
scala0% | 0% | <1% | 45% | 54%
java0% | 0% | 0% | 39% | 60%
xml0% | 0% | 0% | 100% | 0%
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
ROOT100% | 0% | 0% | 0% | 0%
project3% | 0% | 6% | 49% | 40%
core0% | 0% | 0% | 55% | 44%
testkit0% | 0% | 0% | 34% | 65%
benchmarks0% | 0% | 0% | 13% | 86%
cluster-sharding0% | 0% | 0% | 100% | 0%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
build.sbt
in root
 138 - 2014-12-30 2024-10-09 303 50 krzysztof.ciesielski@softwa... pjfanning@users.noreply.git...
plugins.sbt
in project
 15 - 2015-06-30 2024-09-27 126 20 krzysztof.ciesielski@softwa... pjfanning@users.noreply.git...
Versions.scala
in project
 28 - 2023-02-06 2025-02-18 25 4 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
34 - 2023-02-06 2024-10-09 14 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
106 - 2023-02-06 2024-03-22 14 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
53 - 2023-02-06 2024-10-09 11 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ProducerSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 223 5 2023-02-05 2023-07-11 10 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ConsumerSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 330 5 2023-02-05 2023-07-11 10 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
5 - 2023-02-06 2024-03-10 8 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
SendProducer.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 22 - 2023-02-05 2023-07-11 7 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
23 1 2020-08-24 2024-03-22 7 4 marcos.silva@gmail.com pjfanning@users.noreply.git...
MetadataClient.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 85 8 2023-02-05 2023-07-11 7 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
Producer.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 94 3 2023-02-05 2023-07-11 7 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ConsumerMessage.scala
in core/src/main/scala/org/apache/pekko/kafka
 101 7 2023-02-05 2023-07-11 7 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
MessageBuilder.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 183 14 2023-02-05 2023-06-23 7 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Consumer.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 221 8 2023-02-05 2023-06-23 7 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
logback.xml
in benchmarks/src/main/resources
 25 - 2016-01-13 2023-02-05 6 5 krzysztof.ciesielski@softwa... 3521036+seetaramayya@users....
ConfigSettings.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 46 3 2023-02-05 2023-07-10 6 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
Transactional.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 61 - 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
SendProducer.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 63 4 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
DiscoverySupport.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 81 8 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ControlImplementations.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 84 5 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
MetadataClient.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 89 8 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
TestcontainersKafka.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal
 91 3 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
CommitterSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 100 4 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ConsumerResetProtection.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 107 8 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Producer.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 110 4 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Subscriptions.scala
in core/src/main/scala/org/apache/pekko/kafka
 119 7 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
BaseKafkaTest.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl
 124 12 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaSpec.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl
 143 10 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Consumer.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 144 3 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaClusterSharding.scala
in cluster-sharding/src/main/scala/org/apache/pekko/kafka/cluster/sharding
 174 7 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
PekkoConnectorsKafkaContainer.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/internal
 198 15 2023-02-05 2025-04-21 6 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
InflightMetrics.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 202 15 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
TransactionalSources.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 335 14 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
KafkaConsumerActor.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 620 34 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
7 - 2018-05-24 2023-06-23 5 5 mmartynas@gmail.com pjfanning@users.noreply.git...
PartitionAssignmentHandler.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 10 - 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
PartitionAssignmentHandler.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 10 - 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
SourceLogicBuffer.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 22 1 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
NoCommitBackpressure.scala
in benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks
 23 - 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
RestrictedConsumer.scala
in core/src/main/scala/org/apache/pekko/kafka
 27 - 2023-02-05 2023-07-11 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaJunit4Test.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl
 29 5 2023-02-05 2023-07-11 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
TestcontainersKafkaTest.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit
 30 6 2023-02-05 2023-07-11 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaTest.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit
 31 5 2023-02-05 2023-07-11 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Committer.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 31 - 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
PekkoConnectorsCommittableProducer.scala
in benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks
 35 - 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Transactions.scala
in benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks
 36 - 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
LoggingWithId.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 41 - 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
TestcontainersKafkaJunit4Test.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit
 43 8 2023-02-05 2023-07-11 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
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
build.sbt
in root
 138 - 2014-12-30 2024-10-09 303 50 krzysztof.ciesielski@softwa... pjfanning@users.noreply.git...
plugins.sbt
in project
 15 - 2015-06-30 2024-09-27 126 20 krzysztof.ciesielski@softwa... pjfanning@users.noreply.git...
logback.xml
in benchmarks/src/main/resources
 25 - 2016-01-13 2023-02-05 6 5 krzysztof.ciesielski@softwa... 3521036+seetaramayya@users....
7 - 2018-05-24 2023-06-23 5 5 mmartynas@gmail.com pjfanning@users.noreply.git...
Versions.scala
in project
 28 - 2023-02-06 2025-02-18 25 4 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
23 1 2020-08-24 2024-03-22 7 4 marcos.silva@gmail.com pjfanning@users.noreply.git...
34 - 2023-02-06 2024-10-09 14 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
106 - 2023-02-06 2024-03-22 14 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
53 - 2023-02-06 2024-10-09 11 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ConsumerSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 330 5 2023-02-05 2023-07-11 10 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ProducerSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 223 5 2023-02-05 2023-07-11 10 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
5 - 2023-02-06 2024-03-10 8 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Consumer.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 221 8 2023-02-05 2023-06-23 7 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
MetadataClient.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 85 8 2023-02-05 2023-07-11 7 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
Producer.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 94 3 2023-02-05 2023-07-11 7 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
SendProducer.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 22 - 2023-02-05 2023-07-11 7 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ConsumerMessage.scala
in core/src/main/scala/org/apache/pekko/kafka
 101 7 2023-02-05 2023-07-11 7 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
MessageBuilder.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 183 14 2023-02-05 2023-06-23 7 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
InflightMetrics.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 202 15 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Subscriptions.scala
in core/src/main/scala/org/apache/pekko/kafka
 119 7 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
CommitterSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 100 4 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Consumer.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 144 3 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
MetadataClient.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 89 8 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Producer.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 110 4 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
SendProducer.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 63 4 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
DiscoverySupport.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 81 8 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Transactional.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 61 - 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ConsumerResetProtection.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 107 8 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ControlImplementations.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 84 5 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ConfigSettings.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 46 3 2023-02-05 2023-07-10 6 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
KafkaConsumerActor.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 620 34 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
TransactionalSources.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 335 14 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
KafkaSpec.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl
 143 10 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
TestcontainersKafka.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal
 91 3 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
BaseKafkaTest.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl
 124 12 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaClusterSharding.scala
in cluster-sharding/src/main/scala/org/apache/pekko/kafka/cluster/sharding
 174 7 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Timed.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 101 4 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
PekkoConnectorsCommittableProducer.scala
in benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks
 35 - 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Producer.scala
in benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks
 45 - 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
BatchedConsumer.scala
in benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks
 51 - 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Transactions.scala
in benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks
 36 - 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Benchmarks.scala
in benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks
 114 2 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
NoCommitBackpressure.scala
in benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks
 23 - 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Metadata.scala
in core/src/main/scala/org/apache/pekko/kafka
 97 5 2023-02-05 2023-07-11 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
PartitionAssignmentHandler.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 10 - 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Transactional.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 82 3 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ProducerMessage.scala
in core/src/main/scala/org/apache/pekko/kafka
 68 6 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
RestrictedConsumer.scala
in core/src/main/scala/org/apache/pekko/kafka
 27 - 2023-02-05 2023-07-11 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
OffsetResetProtectionSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 48 3 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Committer.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 31 - 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
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
23 - 2023-07-26 2023-07-26 1 1 matthew.dedetrich@aiven.io matthew.dedetrich@aiven.io
17 - 2023-02-21 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
16 - 2023-02-21 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
15 - 2023-06-17 2024-03-22 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
6 - 2024-01-25 2025-01-10 4 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KafkaContainerCluster.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/internal
 328 25 2023-02-05 2023-06-23 4 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
PekkoConnectorsKafkaContainer.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/internal
 198 15 2023-02-05 2025-04-21 6 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
CsvFormatter.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 100 2 2023-02-05 2023-06-23 3 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
96 4 2023-02-21 2023-07-13 4 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
PerfFixtureHelpers.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 91 4 2023-02-05 2023-06-23 3 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaTestKitChecks.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal
 56 1 2023-02-05 2023-06-23 3 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ConnectionCheckerSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 53 2 2023-02-05 2023-06-23 4 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
SchemaRegistryContainer.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/internal
 30 4 2023-02-05 2024-10-01 4 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaProducerBenchmarks.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 28 1 2023-02-05 2023-06-23 3 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaTestkitSettings.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit
 24 2 2023-02-05 2023-06-23 4 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ConsumerFailed.scala
in core/src/main/scala/org/apache/pekko/kafka
 20 2 2023-02-05 2023-06-23 3 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
CommitTrigger.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 19 - 2023-02-05 2023-06-23 3 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
TestFrameworkInterface.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal
 19 3 2023-02-05 2023-06-23 3 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
SpecBase.scala
in benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks
 13 - 2023-02-05 2023-06-23 3 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
TestcontainersKafkaPerClassLike.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl
 12 2 2023-02-05 2023-06-23 3 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
RunTestCommand.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/app
 8 - 2023-02-05 2023-06-23 3 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ScalatestKafkaSpec.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl
 7 - 2023-02-05 2023-06-23 3 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaConnectionFailed.scala
in core/src/main/scala/org/apache/pekko/kafka
 4 - 2023-02-05 2023-06-23 3 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
FixtureGen.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 3 - 2023-02-05 2023-06-23 3 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
CommitTimeoutException.scala
in core/src/main/scala/org/apache/pekko/kafka
 3 - 2023-02-05 2023-06-23 3 2 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaConsumerActor.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 620 34 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
SubSourceLogic.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 359 16 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
TransactionalSources.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 335 14 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
ConsumerSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 330 5 2023-02-05 2023-07-11 10 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ProducerSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 223 5 2023-02-05 2023-07-11 10 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Consumer.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 221 8 2023-02-05 2023-06-23 7 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
CommittingProducerSinkStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 214 17 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
TransactionalProducerStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 208 21 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
CommittableSources.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 207 15 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
InflightMetrics.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 202 15 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
MessageBuilder.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 183 14 2023-02-05 2023-06-23 7 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaTestkitTestcontainersSettings.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit
 174 4 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaClusterSharding.scala
in cluster-sharding/src/main/scala/org/apache/pekko/kafka/cluster/sharding
 174 7 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaConsumerBenchmarks.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 157 5 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
DefaultProducerStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 156 12 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Consumer.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 144 3 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaSpec.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl
 143 10 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ReactiveKafkaConsumerBenchmarks.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 136 6 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
BaseKafkaTest.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl
 124 12 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
CommitCollectorStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 122 11 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Subscriptions.scala
in core/src/main/scala/org/apache/pekko/kafka
 119 7 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
PekkoConnectorsCommittableSinkFixtures.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 114 3 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Benchmarks.scala
in benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks
 114 2 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Producer.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 110 4 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ConsumerResetProtection.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 107 8 2023-02-05 2023-06-23 6 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Correlations

File Size vs. Number of Changes: 122 points

testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java x: 198 lines of code y: 6 # changes project/Versions.scala x: 28 lines of code y: 25 # changes project/PekkoCoreDependency.scala x: 6 lines of code y: 4 # changes build.sbt x: 138 lines of code y: 303 # changes project/Dependencies.scala x: 34 lines of code y: 14 # changes project/ParadoxSettings.scala x: 53 lines of code y: 11 # changes testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/SchemaRegistryContainer.java x: 30 lines of code y: 4 # changes project/plugins.sbt x: 15 lines of code y: 126 # changes project/AddMetaInfLicenseFiles.scala x: 15 lines of code y: 3 # changes project/ProjectSettings.scala x: 106 lines of code y: 14 # changes project/VersionGenerator.scala x: 23 lines of code y: 7 # changes project/ResolverSettings.scala x: 5 lines of code y: 8 # changes project/LicenseReport.scala x: 23 lines of code y: 1 # changes project/CopyrightHeader.scala x: 96 lines of code y: 4 # changes core/src/main/scala/org/apache/pekko/kafka/ConsumerMessage.scala x: 101 lines of code y: 7 # changes core/src/main/scala/org/apache/pekko/kafka/ConsumerSettings.scala x: 330 lines of code y: 10 # changes core/src/main/scala/org/apache/pekko/kafka/Metadata.scala x: 97 lines of code y: 5 # changes core/src/main/scala/org/apache/pekko/kafka/ProducerSettings.scala x: 223 lines of code y: 10 # changes core/src/main/scala/org/apache/pekko/kafka/RestrictedConsumer.scala x: 27 lines of code y: 5 # changes core/src/main/scala/org/apache/pekko/kafka/Subscriptions.scala x: 119 lines of code y: 6 # changes core/src/main/scala/org/apache/pekko/kafka/javadsl/MetadataClient.scala x: 85 lines of code y: 7 # changes core/src/main/scala/org/apache/pekko/kafka/javadsl/Producer.scala x: 94 lines of code y: 7 # changes core/src/main/scala/org/apache/pekko/kafka/javadsl/SendProducer.scala x: 22 lines of code y: 7 # changes core/src/main/scala/org/apache/pekko/kafka/scaladsl/Consumer.scala x: 144 lines of code y: 6 # changes core/src/main/scala/org/apache/pekko/kafka/scaladsl/MetadataClient.scala x: 89 lines of code y: 6 # changes core/src/main/scala/org/apache/pekko/kafka/scaladsl/Producer.scala x: 110 lines of code y: 6 # changes core/src/main/scala/org/apache/pekko/kafka/scaladsl/SendProducer.scala x: 63 lines of code y: 6 # changes testkit/src/main/java/org/apache/pekko/kafka/testkit/KafkaTest.java x: 31 lines of code y: 5 # changes testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaJunit4Test.java x: 43 lines of code y: 5 # changes testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaTest.java x: 30 lines of code y: 5 # changes testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl/BaseKafkaTest.java x: 124 lines of code y: 6 # changes testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl/KafkaJunit4Test.java x: 29 lines of code y: 5 # changes core/src/main/scala/org/apache/pekko/kafka/internal/TransactionalSources.scala x: 335 lines of code y: 6 # changes core/src/main/scala/org/apache/pekko/kafka/internal/ConfigSettings.scala x: 46 lines of code y: 6 # changes benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/BatchedConsumer.scala x: 51 lines of code y: 5 # changes benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/Benchmarks.scala x: 114 lines of code y: 5 # changes benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/NoCommitBackpressure.scala x: 23 lines of code y: 5 # changes benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableProducer.scala x: 35 lines of code y: 5 # changes benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/Producer.scala x: 45 lines of code y: 5 # changes benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/SpecBase.scala x: 13 lines of code y: 3 # changes benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/Transactions.scala x: 36 lines of code y: 5 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/CsvFormatter.scala x: 100 lines of code y: 3 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/FixtureGen.scala x: 3 lines of code y: 3 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/InflightMetrics.scala x: 202 lines of code y: 6 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerBenchmarks.scala x: 157 lines of code y: 4 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaProducerBenchmarks.scala x: 28 lines of code y: 3 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaProducerFixtureGen.scala x: 26 lines of code y: 4 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaTransactionBenchmarks.scala x: 71 lines of code y: 4 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaTransactionFixtureGen.scala x: 59 lines of code y: 4 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableSinkFixtures.scala x: 114 lines of code y: 4 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PerfFixtureHelpers.scala x: 91 lines of code y: 3 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerBenchmarks.scala x: 136 lines of code y: 4 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerFixtures.scala x: 47 lines of code y: 4 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaProducerFixtures.scala x: 42 lines of code y: 4 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaTransactionBenchmarks.scala x: 50 lines of code y: 4 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaTransactionFixtures.scala x: 64 lines of code y: 4 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/Timed.scala x: 101 lines of code y: 5 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/app/RunTestCommand.scala x: 8 lines of code y: 3 # changes cluster-sharding/src/main/scala/org/apache/pekko/kafka/cluster/sharding/KafkaClusterSharding.scala x: 174 lines of code y: 6 # changes core/src/main/scala/org/apache/pekko/kafka/CommitterSettings.scala x: 100 lines of code y: 6 # changes core/src/main/scala/org/apache/pekko/kafka/ConnectionCheckerSettings.scala x: 53 lines of code y: 4 # changes core/src/main/scala/org/apache/pekko/kafka/ConsumerFailed.scala x: 20 lines of code y: 3 # changes core/src/main/scala/org/apache/pekko/kafka/KafkaConnectionFailed.scala x: 4 lines of code y: 3 # changes core/src/main/scala/org/apache/pekko/kafka/KafkaConsumerActor.scala x: 16 lines of code y: 4 # changes core/src/main/scala/org/apache/pekko/kafka/OffsetResetProtectionSettings.scala x: 48 lines of code y: 5 # changes core/src/main/scala/org/apache/pekko/kafka/ProducerMessage.scala x: 68 lines of code y: 5 # changes core/src/main/scala/org/apache/pekko/kafka/internal/BaseSingleSourceLogic.scala x: 97 lines of code y: 4 # changes core/src/main/scala/org/apache/pekko/kafka/internal/CommitCollectorStage.scala x: 122 lines of code y: 4 # changes core/src/main/scala/org/apache/pekko/kafka/internal/CommitObservationLogic.scala x: 54 lines of code y: 4 # changes core/src/main/scala/org/apache/pekko/kafka/internal/CommitTrigger.scala x: 19 lines of code y: 3 # changes core/src/main/scala/org/apache/pekko/kafka/internal/CommittableSources.scala x: 207 lines of code y: 4 # changes core/src/main/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkStage.scala x: 214 lines of code y: 5 # changes core/src/main/scala/org/apache/pekko/kafka/internal/ConnectionChecker.scala x: 52 lines of code y: 4 # changes core/src/main/scala/org/apache/pekko/kafka/internal/ConsumerProgressTracking.scala x: 84 lines of code y: 4 # changes core/src/main/scala/org/apache/pekko/kafka/internal/ConsumerResetProtection.scala x: 107 lines of code y: 6 # changes core/src/main/scala/org/apache/pekko/kafka/internal/DefaultProducerStage.scala x: 156 lines of code y: 5 # changes core/src/main/scala/org/apache/pekko/kafka/internal/DeferredProducer.scala x: 74 lines of code y: 5 # changes core/src/main/scala/org/apache/pekko/kafka/internal/ExternalSingleSourceLogic.scala x: 21 lines of code y: 4 # changes core/src/main/scala/org/apache/pekko/kafka/internal/KafkaConsumerActor.scala x: 620 lines of code y: 6 # changes core/src/main/scala/org/apache/pekko/kafka/internal/KafkaSourceStage.scala x: 18 lines of code y: 4 # changes core/src/main/scala/org/apache/pekko/kafka/internal/LoggingWithId.scala x: 41 lines of code y: 5 # changes core/src/main/scala/org/apache/pekko/kafka/internal/MessageBuilder.scala x: 183 lines of code y: 7 # changes core/src/main/scala/org/apache/pekko/kafka/internal/PartitionAssignmentHelpers.scala x: 85 lines of code y: 5 # changes core/src/main/scala/org/apache/pekko/kafka/internal/PlainSources.scala x: 62 lines of code y: 4 # changes core/src/main/scala/org/apache/pekko/kafka/internal/SourceLogicBuffer.scala x: 22 lines of code y: 5 # changes core/src/main/scala/org/apache/pekko/kafka/internal/SubSourceLogic.scala x: 359 lines of code y: 5 # changes core/src/main/scala/org/apache/pekko/kafka/internal/TransactionalProducerStage.scala x: 208 lines of code y: 5 # changes core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala x: 221 lines of code y: 7 # changes core/src/main/scala/org/apache/pekko/kafka/javadsl/PartitionAssignmentHandler.scala x: 10 lines of code y: 5 # changes core/src/main/scala/org/apache/pekko/kafka/javadsl/Transactional.scala x: 61 lines of code y: 6 # changes core/src/main/scala/org/apache/pekko/kafka/scaladsl/DiscoverySupport.scala x: 81 lines of code y: 6 # changes core/src/main/scala/org/apache/pekko/kafka/scaladsl/Transactional.scala x: 82 lines of code y: 5 # changes project/AutomaticModuleName.scala x: 7 lines of code y: 5 # changes project/CopyrightHeaderForBuild.scala x: 17 lines of code y: 2 # changes project/CopyrightHeaderForProtobuf.scala x: 16 lines of code y: 2 # changes testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/KafkaContainerCluster.java x: 328 lines of code y: 4 # changes testkit/src/main/scala/org/apache/pekko/kafka/testkit/ConsumerResultFactory.scala x: 40 lines of code y: 4 # changes testkit/src/main/scala/org/apache/pekko/kafka/testkit/KafkaTestkitSettings.scala x: 24 lines of code y: 4 # changes testkit/src/main/scala/org/apache/pekko/kafka/testkit/KafkaTestkitTestcontainersSettings.scala x: 174 lines of code y: 5 # changes testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal/KafkaTestKit.scala x: 98 lines of code y: 5 # changes testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal/KafkaTestKitChecks.scala x: 56 lines of code y: 3 # changes testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal/TestcontainersKafka.scala x: 91 lines of code y: 6 # changes testkit/src/main/scala/org/apache/pekko/kafka/testkit/javadsl/ConsumerControlFactory.scala x: 39 lines of code y: 4 # changes testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/ConsumerControlFactory.scala x: 35 lines of code y: 4 # changes testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/KafkaSpec.scala x: 143 lines of code y: 6 # changes testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/ScalatestKafkaSpec.scala x: 7 lines of code y: 3 # changes testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/TestcontainersKafkaPerClassLike.scala x: 12 lines of code y: 3 # changes benchmarks/src/main/resources/logback.xml x: 25 lines of code y: 6 # changes
303.0
# changes
  min: 1.0
  average: 8.56
  25th percentile: 4.0
  median: 5.0
  75th percentile: 6.0
  max: 303.0
0 620.0
lines of code
min: 3.0 | average: 81.19 | 25th percentile: 25.75 | median: 51.5 | 75th percentile: 101.0 | max: 620.0

Number of Contributors vs. Number of Changes: 122 points

testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java x: 2 # contributors y: 6 # changes project/Versions.scala x: 4 # contributors y: 25 # changes project/PekkoCoreDependency.scala x: 1 # contributors y: 4 # changes build.sbt x: 50 # contributors y: 303 # changes project/Dependencies.scala x: 3 # contributors y: 14 # changes project/ParadoxSettings.scala x: 3 # contributors y: 11 # changes testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/SchemaRegistryContainer.java x: 2 # contributors y: 4 # changes project/plugins.sbt x: 20 # contributors y: 126 # changes project/AddMetaInfLicenseFiles.scala x: 1 # contributors y: 3 # changes project/VersionGenerator.scala x: 4 # contributors y: 7 # changes project/ResolverSettings.scala x: 3 # contributors y: 8 # changes project/LicenseReport.scala x: 1 # contributors y: 1 # changes core/src/main/scala/org/apache/pekko/kafka/ConsumerMessage.scala x: 3 # contributors y: 7 # changes core/src/main/scala/org/apache/pekko/kafka/ConsumerSettings.scala x: 3 # contributors y: 10 # changes core/src/main/scala/org/apache/pekko/kafka/Metadata.scala x: 3 # contributors y: 5 # changes benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/SpecBase.scala x: 2 # contributors y: 3 # changes benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerBenchmarks.scala x: 3 # contributors y: 4 # changes project/AutomaticModuleName.scala x: 5 # contributors y: 5 # changes project/CopyrightHeaderForBuild.scala x: 1 # contributors y: 2 # changes benchmarks/src/main/resources/logback.xml x: 5 # contributors y: 6 # changes
303.0
# changes
  min: 1.0
  average: 8.56
  25th percentile: 4.0
  median: 5.0
  75th percentile: 6.0
  max: 303.0
0 50.0
# contributors
min: 1.0 | average: 3.33 | 25th percentile: 3.0 | median: 3.0 | 75th percentile: 3.0 | max: 50.0

Number of Contributors vs. File Size: 122 points

testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java x: 2 # contributors y: 198 lines of code project/Versions.scala x: 4 # contributors y: 28 lines of code project/PekkoCoreDependency.scala x: 1 # contributors y: 6 lines of code build.sbt x: 50 # contributors y: 138 lines of code project/Dependencies.scala x: 3 # contributors y: 34 lines of code project/ParadoxSettings.scala x: 3 # contributors y: 53 lines of code testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/SchemaRegistryContainer.java x: 2 # contributors y: 30 lines of code project/plugins.sbt x: 20 # contributors y: 15 lines of code project/AddMetaInfLicenseFiles.scala x: 1 # contributors y: 15 lines of code project/ProjectSettings.scala x: 3 # contributors y: 106 lines of code project/VersionGenerator.scala x: 4 # contributors y: 23 lines of code project/ResolverSettings.scala x: 3 # contributors y: 5 lines of code project/LicenseReport.scala x: 1 # contributors y: 23 lines of code project/CopyrightHeader.scala x: 2 # contributors y: 96 lines of code core/src/main/scala/org/apache/pekko/kafka/ConsumerMessage.scala x: 3 # contributors y: 101 lines of code core/src/main/scala/org/apache/pekko/kafka/ConsumerSettings.scala x: 3 # contributors y: 330 lines of code core/src/main/scala/org/apache/pekko/kafka/Metadata.scala x: 3 # contributors y: 97 lines of code core/src/main/scala/org/apache/pekko/kafka/ProducerSettings.scala x: 3 # contributors y: 223 lines of code core/src/main/scala/org/apache/pekko/kafka/RestrictedConsumer.scala x: 3 # contributors y: 27 lines of code core/src/main/scala/org/apache/pekko/kafka/Subscriptions.scala x: 3 # contributors y: 119 lines of code core/src/main/scala/org/apache/pekko/kafka/javadsl/MetadataClient.scala x: 3 # contributors y: 85 lines of code core/src/main/scala/org/apache/pekko/kafka/javadsl/Producer.scala x: 3 # contributors y: 94 lines of code core/src/main/scala/org/apache/pekko/kafka/javadsl/SendProducer.scala x: 3 # contributors y: 22 lines of code core/src/main/scala/org/apache/pekko/kafka/scaladsl/Consumer.scala x: 3 # contributors y: 144 lines of code core/src/main/scala/org/apache/pekko/kafka/scaladsl/MetadataClient.scala x: 3 # contributors y: 89 lines of code core/src/main/scala/org/apache/pekko/kafka/scaladsl/Producer.scala x: 3 # contributors y: 110 lines of code core/src/main/scala/org/apache/pekko/kafka/scaladsl/SendProducer.scala x: 3 # contributors y: 63 lines of code testkit/src/main/java/org/apache/pekko/kafka/testkit/KafkaTest.java x: 3 # contributors y: 31 lines of code testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaJunit4Test.java x: 3 # contributors y: 43 lines of code testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl/BaseKafkaTest.java x: 3 # contributors y: 124 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/TransactionalSources.scala x: 3 # contributors y: 335 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/ConfigSettings.scala x: 3 # contributors y: 46 lines of code benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/BatchedConsumer.scala x: 3 # contributors y: 51 lines of code benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/Benchmarks.scala x: 3 # contributors y: 114 lines of code benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableProducer.scala x: 3 # contributors y: 35 lines of code benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/SpecBase.scala x: 2 # contributors y: 13 lines of code benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/CsvFormatter.scala x: 2 # contributors y: 100 lines of code benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/FixtureGen.scala x: 2 # contributors y: 3 lines of code benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/InflightMetrics.scala x: 3 # contributors y: 202 lines of code benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerBenchmarks.scala x: 3 # contributors y: 157 lines of code benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaProducerBenchmarks.scala x: 2 # contributors y: 28 lines of code benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaProducerFixtureGen.scala x: 3 # contributors y: 26 lines of code benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaTransactionBenchmarks.scala x: 3 # contributors y: 71 lines of code benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaTransactionFixtureGen.scala x: 3 # contributors y: 59 lines of code benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PerfFixtureHelpers.scala x: 2 # contributors y: 91 lines of code benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerBenchmarks.scala x: 3 # contributors y: 136 lines of code benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerFixtures.scala x: 3 # contributors y: 47 lines of code benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaTransactionFixtures.scala x: 3 # contributors y: 64 lines of code benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/app/RunTestCommand.scala x: 2 # contributors y: 8 lines of code cluster-sharding/src/main/scala/org/apache/pekko/kafka/cluster/sharding/KafkaClusterSharding.scala x: 3 # contributors y: 174 lines of code core/src/main/scala/org/apache/pekko/kafka/CommitterSettings.scala x: 3 # contributors y: 100 lines of code core/src/main/scala/org/apache/pekko/kafka/ConnectionCheckerSettings.scala x: 2 # contributors y: 53 lines of code core/src/main/scala/org/apache/pekko/kafka/ConsumerFailed.scala x: 2 # contributors y: 20 lines of code core/src/main/scala/org/apache/pekko/kafka/KafkaConsumerActor.scala x: 3 # contributors y: 16 lines of code core/src/main/scala/org/apache/pekko/kafka/ProducerMessage.scala x: 3 # contributors y: 68 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/CommitCollectorStage.scala x: 3 # contributors y: 122 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/CommitObservationLogic.scala x: 3 # contributors y: 54 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/CommitTrigger.scala x: 2 # contributors y: 19 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/CommittableSources.scala x: 3 # contributors y: 207 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkStage.scala x: 3 # contributors y: 214 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/DefaultProducerStage.scala x: 3 # contributors y: 156 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/DeferredProducer.scala x: 3 # contributors y: 74 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/ExternalSingleSourceLogic.scala x: 3 # contributors y: 21 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/KafkaConsumerActor.scala x: 3 # contributors y: 620 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/KafkaSourceStage.scala x: 3 # contributors y: 18 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/LoggingWithId.scala x: 3 # contributors y: 41 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/MessageBuilder.scala x: 3 # contributors y: 183 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/SubSourceLogic.scala x: 3 # contributors y: 359 lines of code core/src/main/scala/org/apache/pekko/kafka/internal/TransactionalProducerStage.scala x: 3 # contributors y: 208 lines of code core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala x: 3 # contributors y: 221 lines of code core/src/main/scala/org/apache/pekko/kafka/javadsl/PartitionAssignmentHandler.scala x: 3 # contributors y: 10 lines of code core/src/main/scala/org/apache/pekko/kafka/scaladsl/DiscoverySupport.scala x: 3 # contributors y: 81 lines of code project/AutomaticModuleName.scala x: 5 # contributors y: 7 lines of code testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/KafkaContainerCluster.java x: 2 # contributors y: 328 lines of code testkit/src/main/scala/org/apache/pekko/kafka/testkit/KafkaTestkitSettings.scala x: 2 # contributors y: 24 lines of code testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal/KafkaTestKitChecks.scala x: 2 # contributors y: 56 lines of code testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal/TestcontainersKafka.scala x: 3 # contributors y: 91 lines of code testkit/src/main/scala/org/apache/pekko/kafka/testkit/javadsl/ConsumerControlFactory.scala x: 3 # contributors y: 39 lines of code testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/ScalatestKafkaSpec.scala x: 2 # contributors y: 7 lines of code testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/TestcontainersKafkaPerClassLike.scala x: 2 # contributors y: 12 lines of code benchmarks/src/main/resources/logback.xml x: 5 # contributors y: 25 lines of code
620.0
lines of code
  min: 3.0
  average: 81.19
  25th percentile: 25.75
  median: 51.5
  75th percentile: 101.0
  max: 620.0
0 50.0
# contributors
min: 1.0 | average: 3.33 | 25th percentile: 3.0 | median: 3.0 | 75th percentile: 3.0 | max: 50.0