apache / pekko-connectors-kafka
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 122 files with 9,905 lines of code in files.
    • 122 files that are 366+ days old (9,905 lines of code)
    • 0 files that are 181-365 days old (0 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 0 files that are 31-90 days old (0 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
100% | 0% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 122 files with 9,905 lines of code in files.
    • 114 files have been last changed 366+ days ago (9,403 lines of code)
    • 5 files have been last changed 181-365 days ago (270 lines of code)
    • 1 files have been last changed 91-180 days ago (6 lines of code)
    • 1 files have been last changed 31-90 days ago (28 lines of code)
    • 1 files have been last changed 1-30 days ago (198 lines of code)
94% | 2% | <1% | <1% | 1%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
scala, java, md, yaml, xml, txt, sbt, gitignore, gitattributes, sh, proto, properties
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
scala100% | 0% | 0% | 0% | 0%
java100% | 0% | 0% | 0% | 0%
sbt100% | 0% | 0% | 0% | 0%
xml100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
scala98% | <1% | <1% | <1% | 0%
java71% | 3% | 0% | 0% | 24%
xml100% | 0% | 0% | 0% | 0%
sbt0% | 100% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
core100% | 0% | 0% | 0% | 0%
benchmarks100% | 0% | 0% | 0% | 0%
testkit100% | 0% | 0% | 0% | 0%
project100% | 0% | 0% | 0% | 0%
cluster-sharding100% | 0% | 0% | 0% | 0%
ROOT100% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
core100% | 0% | 0% | 0% | 0%
benchmarks100% | 0% | 0% | 0% | 0%
testkit85% | 1% | 0% | 0% | 12%
project69% | 22% | 1% | 6% | 0%
cluster-sharding100% | 0% | 0% | 0% | 0%
ROOT0% | 100% | 0% | 0% | 0%
Oldest Files (Top 50)
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...
23 1 2020-08-24 2024-03-22 7 4 marcos.silva@gmail.com 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...
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...
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...
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...
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...
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...
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...
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...
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...
KafkaTestKit.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal
 98 6 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...
BaseSingleSourceLogic.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 97 6 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
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...
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...
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...
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...
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
PartitionAssignmentHelpers.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 85 9 2023-02-05 2023-06-23 5 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...
ConsumerProgressTracking.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 84 14 2023-02-05 2023-06-23 4 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...
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...
DeferredProducer.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 74 6 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
logback.xml
in benchmarks/src/main/resources
 25 - 2016-01-13 2023-02-05 6 5 krzysztof.ciesielski@softwa... 3521036+seetaramayya@users....
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...
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...
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...
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...
7 - 2018-05-24 2023-06-23 5 5 mmartynas@gmail.com 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...
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...
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...
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...
KafkaConsumerActor.scala
in core/src/main/scala/org/apache/pekko/kafka
 16 - 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
16 - 2023-02-21 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
17 - 2023-02-21 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KafkaSourceStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 18 1 2023-02-05 2023-06-23 4 3 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...
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...
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...
ExternalSingleSourceLogic.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 21 1 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ProducerStage.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 21 - 2023-02-05 2023-06-23 4 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...
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...
TestcontainersKafkaLike.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl
 26 2 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
KafkaProducerFixtureGen.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 26 3 2023-02-05 2023-06-23 4 3 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...
KafkaConsumerFixtureGen.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 30 3 2023-02-05 2023-06-23 4 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...
ConsumerControlFactory.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl
 35 1 2023-02-05 2023-06-23 4 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...
ConsumerControlFactory.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/javadsl
 39 1 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ConsumerResultFactory.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit
 40 - 2023-02-05 2023-06-23 4 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...
ReactiveKafkaProducerFixtures.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 42 2 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
DiscoverySupport.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 43 4 2023-02-05 2023-06-23 5 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ProducerResultFactory.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit
 45 1 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...
SourceLogicSubscription.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 46 1 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Committer.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 46 2 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ReactiveKafkaProducerBenchmarks.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 47 1 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
ReactiveKafkaConsumerFixtures.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 47 3 2023-02-05 2023-06-23 4 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...
ReactiveKafkaTransactionBenchmarks.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 50 1 2023-02-05 2023-06-23 4 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...
ConnectionChecker.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 52 3 2023-02-05 2023-06-23 4 3 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...
CommitObservationLogic.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 54 3 2023-02-05 2023-06-23 4 3 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...
KafkaTransactionFixtureGen.scala
in benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks
 59 3 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
6 - 2024-01-25 2025-01-10 4 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
23 - 2023-07-26 2023-07-26 1 1 matthew.dedetrich@aiven.io matthew.dedetrich@aiven.io
15 - 2023-06-17 2024-03-22 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
96 4 2023-02-21 2023-07-13 4 2 pjfanning@users.noreply.git... 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...
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...
34 - 2023-02-06 2024-10-09 14 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
Versions.scala
in project
 28 - 2023-02-06 2025-02-18 25 4 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
5 - 2023-02-06 2024-03-10 8 3 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...
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...
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...
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...
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...
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...
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...
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...
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...
KafkaTestKit.scala
in testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal
 98 6 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...
BaseSingleSourceLogic.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 97 6 2023-02-05 2023-06-23 4 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
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...
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...
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...
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...
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
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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...
Versions.scala
in project
 28 - 2023-02-06 2025-02-18 25 4 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
6 - 2024-01-25 2025-01-10 4 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
build.sbt
in root
 138 - 2014-12-30 2024-10-09 303 50 krzysztof.ciesielski@softwa... pjfanning@users.noreply.git...
53 - 2023-02-06 2024-10-09 11 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
34 - 2023-02-06 2024-10-09 14 3 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...
plugins.sbt
in project
 15 - 2015-06-30 2024-09-27 126 20 krzysztof.ciesielski@softwa... pjfanning@users.noreply.git...
106 - 2023-02-06 2024-03-22 14 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...
15 - 2023-06-17 2024-03-22 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
5 - 2023-02-06 2024-03-10 8 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
23 - 2023-07-26 2023-07-26 1 1 matthew.dedetrich@aiven.io matthew.dedetrich@aiven.io
96 4 2023-02-21 2023-07-13 4 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
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/scaladsl
 144 3 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...
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...
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...
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...
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...
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...
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...
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
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...