apache / pekko-connectors-kafka
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
0% | 6% | 26% | 27% | 39%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
scala0% | 6% | 25% | 25% | 41%
java0% | 0% | 40% | 39% | 20%
sbt0% | 0% | 0% | 90% | 9%
xml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
core0% | 10% | 36% | 17% | 35%
testkit0% | 0% | 20% | 39% | 40%
benchmarks0% | 0% | 11% | 36% | 52%
cluster-sharding0% | 0% | 0% | 100% | 0%
ROOT0% | 0% | 0% | 100% | 0%
project0% | 0% | 0% | 23% | 76%
Longest Files (Top 50)
File# lines# units
KafkaConsumerActor.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 620 34
SubSourceLogic.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 359 16
TransactionalSources.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 335 14
ConsumerSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 330 5
KafkaContainerCluster.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/internal
 328 25
ProducerSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 223 5
Consumer.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 221 8
CommittingProducerSinkStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 214 17
TransactionalProducerStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 208 21
CommittableSources.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 207 15
InflightMetrics.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 202 15
PekkoConnectorsKafkaContainer.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/internal
 198 15
MessageBuilder.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 183 14
KafkaTestkitTestcontainersSettings.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit
 174 4
KafkaClusterSharding.scala
in cluster-sharding/src/main/scala/org/apache/pekko/kafka/cluster/sharding
 174 7
KafkaConsumerBenchmarks.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 157 5
DefaultProducerStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 156 12
Consumer.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 144 3
KafkaSpec.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl
 143 10
build.sbt
in root
 138 -
ReactiveKafkaConsumerBenchmarks.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 136 6
BaseKafkaTest.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl
 124 12
CommitCollectorStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 122 11
Subscriptions.scala
in core/src/main/scala/org/apache/pekko/kafka
 119 7
PekkoConnectorsCommittableSinkFixtures.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 114 3
Benchmarks.scala
in benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks
 114 2
Producer.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 110 4
ConsumerResetProtection.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 107 8
106 -
Timed.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 101 4
ConsumerMessage.scala
in core/src/main/scala/org/apache/pekko/kafka
 101 7
CsvFormatter.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 100 2
CommitterSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 100 4
KafkaTestKit.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal
 98 6
Metadata.scala
in core/src/main/scala/org/apache/pekko/kafka
 97 5
BaseSingleSourceLogic.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 97 6
96 4
Producer.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 94 3
PerfFixtureHelpers.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 91 4
TestcontainersKafka.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal
 91 3
MetadataClient.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 89 8
MetadataClient.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 85 8
PartitionAssignmentHelpers.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 85 9
ControlImplementations.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 84 5
ConsumerProgressTracking.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 84 14
Transactional.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 82 3
DiscoverySupport.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 81 8
DeferredProducer.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 74 6
KafkaTransactionBenchmarks.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 71 1
SingleSourceLogic.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 71 6
Files With Most Units (Top 50)
File# lines# units
KafkaConsumerActor.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 620 34
KafkaContainerCluster.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/internal
 328 25
TransactionalProducerStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 208 21
CommittingProducerSinkStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 214 17
SubSourceLogic.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 359 16
InflightMetrics.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 202 15
CommittableSources.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 207 15
PekkoConnectorsKafkaContainer.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/internal
 198 15
MessageBuilder.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 183 14
TransactionalSources.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 335 14
ConsumerProgressTracking.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 84 14
DefaultProducerStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 156 12
BaseKafkaTest.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl
 124 12
CommitCollectorStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 122 11
KafkaSpec.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl
 143 10
PartitionAssignmentHelpers.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 85 9
MetadataClient.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 89 8
DiscoverySupport.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 81 8
Consumer.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 221 8
MetadataClient.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 85 8
ConsumerResetProtection.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 107 8
TestcontainersKafkaJunit4Test.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit
 43 8
Subscriptions.scala
in core/src/main/scala/org/apache/pekko/kafka
 119 7
ConsumerMessage.scala
in core/src/main/scala/org/apache/pekko/kafka
 101 7
KafkaClusterSharding.scala
in cluster-sharding/src/main/scala/org/apache/pekko/kafka/cluster/sharding
 174 7
ReactiveKafkaConsumerBenchmarks.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 136 6
ProducerMessage.scala
in core/src/main/scala/org/apache/pekko/kafka
 68 6
DeferredProducer.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 74 6
SingleSourceLogic.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 71 6
BaseSingleSourceLogic.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 97 6
KafkaTestKit.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal
 98 6
TestcontainersKafkaTest.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit
 30 6
KafkaConsumerBenchmarks.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 157 5
Metadata.scala
in core/src/main/scala/org/apache/pekko/kafka
 97 5
ConsumerSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 330 5
ProducerSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 223 5
ControlImplementations.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 84 5
KafkaTest.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit
 31 5
KafkaJunit4Test.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl
 29 5
Timed.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 101 4
PerfFixtureHelpers.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 91 4
96 4
CommitterSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 100 4
Producer.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 110 4
SendProducer.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 63 4
DiscoverySupport.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 43 4
KafkaTestkitTestcontainersSettings.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit
 174 4
SchemaRegistryContainer.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/internal
 30 4
KafkaTransactionFixtureGen.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 59 3
KafkaConsumerFixtureGen.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 30 3
Files With Long Lines (Top 12)

There are 12 files with lines longer than 120 characters. In total, there are 16 long lines.

File# lines# units# long lines
53 - 3
ProducerSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 223 5 2
ConsumerResetProtection.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 107 8 2
106 - 1
ConsumerFailed.scala
in core/src/main/scala/org/apache/pekko/kafka
 20 2 1
CommitterSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 100 4 1
DiscoverySupport.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 81 8 1
ConsumerSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 330 5 1
MessageBuilder.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 183 14 1
DefaultProducerStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 156 12 1
TransactionalProducerStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 208 21 1
KafkaTestKitChecks.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal
 56 1 1
Correlations

File Size vs. Commits (all time): 122 points

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

File Size vs. Contributors (all time): 122 points

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

File Size vs. Commits (30 days): 1 points

testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java x: 1 commits (30d) y: 198 lines of code
198.0
lines of code
  min: 198.0
  average: 198.0
  25th percentile: 198.0
  median: 198.0
  75th percentile: 198.0
  max: 198.0
0 1.0
commits (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

File Size vs. Contributors (30 days): 1 points

testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java x: 1 contributors (30d) y: 198 lines of code
198.0
lines of code
  min: 198.0
  average: 198.0
  25th percentile: 198.0
  median: 198.0
  75th percentile: 198.0
  max: 198.0
0 1.0
contributors (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

File Size vs. Commits (90 days): 2 points

testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java x: 2 commits (90d) y: 198 lines of code project/Versions.scala x: 1 commits (90d) y: 28 lines of code
198.0
lines of code
  min: 28.0
  average: 113.0
  25th percentile: 28.0
  median: 113.0
  75th percentile: 198.0
  max: 198.0
0 2.0
commits (90d)
min: 1.0 | average: 1.5 | 25th percentile: 1.0 | median: 1.5 | 75th percentile: 2.0 | max: 2.0

File Size vs. Contributors (90 days): 2 points

testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java x: 1 contributors (90d) y: 198 lines of code project/Versions.scala x: 1 contributors (90d) y: 28 lines of code
198.0
lines of code
  min: 28.0
  average: 113.0
  25th percentile: 28.0
  median: 113.0
  75th percentile: 198.0
  max: 198.0
0 1.0
contributors (90d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0