apache / incubator-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 121 files with 9,915 lines of code in files.
    • 5 files that are 366+ days old (212 lines of code)
    • 111 files that are 181-365 days old (9,535 lines of code)
    • 3 files that are 91-180 days old (129 lines of code)
    • 1 files that are 31-90 days old (16 lines of code)
    • 1 files that are 1-30 days old (23 lines of code)
2% | 96% | 1% | <1% | <1%
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 121 files with 9,915 lines of code in files.
    • 0 files have been last changed 366+ days ago (0 lines of code)
    • 1 files have been last changed 181-365 days ago (25 lines of code)
    • 0 files have been last changed 91-180 days ago (0 lines of code)
    • 112 files have been last changed 31-90 days ago (9,483 lines of code)
    • 8 files have been last changed 1-30 days ago (407 lines of code)
0% | <1% | 0% | 95% | 4%
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, yml, xml, txt, sbt, gitignore, gitattributes, sh, proto, json, properties, yaml
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
sbt100% | 0% | 0% | 0% | 0%
scala<1% | 97% | 1% | <1% | <1%
xml100% | 0% | 0% | 0% | 0%
java0% | 100% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
xml0% | 100% | 0% | 0% | 0%
scala0% | 0% | 0% | 97% | 2%
java0% | 0% | 0% | 100% | 0%
sbt0% | 0% | 0% | 0% | 100%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
ROOT100% | 0% | 0% | 0% | 0%
project11% | 51% | 28% | 3% | 5%
benchmarks1% | 98% | 0% | 0% | 0%
core0% | 100% | 0% | 0% | 0%
testkit0% | 100% | 0% | 0% | 0%
cluster-sharding0% | 100% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
benchmarks0% | 1% | 0% | 98% | 0%
core0% | 0% | 0% | 100% | 0%
testkit0% | 0% | 0% | 100% | 0%
project0% | 0% | 0% | 40% | 59%
cluster-sharding0% | 0% | 0% | 100% | 0%
ROOT0% | 0% | 0% | 0% | 100%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
build.sbt
in root
 134 - 2014-12-30 2023-08-01 292 49 krzysztof.ciesielski@softwa... matthew.dedetrich@aiven.io
plugins.sbt
in project
 23 - 2015-06-30 2023-07-28 119 20 krzysztof.ciesielski@softwa... matthew.dedetrich@aiven.io
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 2023-06-23 6 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 9 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
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 9 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
Consumer.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 217 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
 199 15 2023-02-05 2023-06-23 3 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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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
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...
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...
Transactional.scala
in core/src/main/scala/org/apache/pekko/kafka/scaladsl
 81 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....
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...
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...
7 - 2018-05-24 2023-06-23 5 5 mmartynas@gmail.com 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...
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...
16 - 2023-02-21 2023-06-23 2 1 pjfanning@users.noreply.git... 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...
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...
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...
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...
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...
23 1 2020-08-24 2023-06-23 6 4 marcos.silva@gmail.com 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...
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...
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...
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...
SchemaRegistryContainer.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit/internal
 31 4 2023-02-05 2023-06-23 3 2 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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
Most Recently Created Files (Top 50)
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
16 - 2023-06-17 2023-07-12 2 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...
107 - 2023-02-06 2023-06-23 13 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
54 - 2023-02-06 2023-07-26 9 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
41 - 2023-02-06 2023-07-26 9 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
Versions.scala
in project
 29 - 2023-02-06 2023-07-26 17 4 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
7 - 2023-02-06 2023-07-14 7 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 9 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
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 9 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
Consumer.scala
in core/src/main/scala/org/apache/pekko/kafka/javadsl
 217 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
 199 15 2023-02-05 2023-06-23 3 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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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
build.sbt
in root
 134 - 2014-12-30 2023-08-01 292 49 krzysztof.ciesielski@softwa... matthew.dedetrich@aiven.io
plugins.sbt
in project
 23 - 2015-06-30 2023-07-28 119 20 krzysztof.ciesielski@softwa... matthew.dedetrich@aiven.io
54 - 2023-02-06 2023-07-26 9 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
41 - 2023-02-06 2023-07-26 9 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
Versions.scala
in project
 29 - 2023-02-06 2023-07-26 17 4 3521036+seetaramayya@users.... pjfanning@users.noreply.git...
23 - 2023-07-26 2023-07-26 1 1 matthew.dedetrich@aiven.io matthew.dedetrich@aiven.io
7 - 2023-02-06 2023-07-14 7 3 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
16 - 2023-06-17 2023-07-12 2 1 pjfanning@users.noreply.git... 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 9 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
ProducerSettings.scala
in core/src/main/scala/org/apache/pekko/kafka
 223 5 2023-02-05 2023-07-11 9 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
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...
ConfigSettings.scala
in core/src/main/scala/org/apache/pekko/kafka/internal
 46 3 2023-02-05 2023-07-11 6 3 3521036+seetaramayya@users.... matthew.dedetrich@aiven.io
TestcontainersKafkaJunit4Test.java
in testkit/src/main/java/org/apache/pekko/kafka/testkit
 44 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
 31 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...
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
 217 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
 199 15 2023-02-05 2023-06-23 3 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...
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...
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...
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...
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...
107 - 2023-02-06 2023-06-23 13 3 3521036+seetaramayya@users.... pjfanning@users.noreply.git...