path	# lines of code
kafka-test/src/it/scala/org/apache/pekko/projection/kafka/KafkaSourceProviderSpec.scala	47
kafka-test/src/it/scala/org/apache/pekko/projection/kafka/integration/KafkaToSlickIntegrationSpec.scala	267
kafka-test/src/it/scala/org/apache/pekko/projection/kafka/KafkaSpecBase.scala	43
kafka-test/src/it/resources/logback-test.xml	25
slick/src/main/scala/org/apache/pekko/projection/slick/SlickProjection.scala	260
slick/src/main/scala/org/apache/pekko/projection/slick/internal/SlickSettings.scala	20
slick/src/main/scala/org/apache/pekko/projection/slick/internal/SlickOffsetStore.scala	169
slick/src/main/scala/org/apache/pekko/projection/slick/internal/SlickProjectionImpl.scala	162
slick/src/it/scala/org/apache/pekko/projection/slick/SlickContainerOffsetStoreSpec.scala	110
slick/src/it/resources/logback-test.xml	17
project/CopyrightHeader.scala	96
project/AutomaticModuleName.scala	7
project/AddMetaInfLicenseFiles.scala	9
project/Dependencies.scala	170
project/SequentialTestExecution.scala	12
project/PekkoConnectorsKafkaDependency.scala	7
project/plugins.sbt	14
project/LicenseReport.scala	31
project/PekkoConnectorsDependency.scala	7
project/Protobuf.scala	145
project/PekkoDisciplinePlugin.scala	57
project/Common.scala	63
project/PekkoCoreDependency.scala	7
kafka/src/main/scala/org/apache/pekko/projection/kafka/scaladsl/KafkaSourceProvider.scala	25
kafka/src/main/scala/org/apache/pekko/projection/kafka/javadsl/KafkaSourceProvider.scala	27
kafka/src/main/scala/org/apache/pekko/projection/kafka/KafkaOffsets.scala	25
kafka/src/main/scala/org/apache/pekko/projection/kafka/internal/KafkaSourceProviderSettings.scala	19
kafka/src/main/scala/org/apache/pekko/projection/kafka/internal/KafkaSourceProviderImpl.scala	132
kafka/src/main/scala/org/apache/pekko/projection/kafka/internal/MetadataClientAdapter.scala	42
durable-state/src/main/scala/org/apache/pekko/projection/state/scaladsl/DurableStateSourceProvider.scala	102
durable-state/src/main/scala/org/apache/pekko/projection/state/javadsl/DurableStateSourceProvider.scala	114
core/src/main/scala/org/apache/pekko/projection/ProjectionBehavior.scala	202
core/src/main/scala/org/apache/pekko/projection/ProjectionId.scala	28
core/src/main/scala/org/apache/pekko/projection/scaladsl/ActorHandler.scala	14
core/src/main/scala/org/apache/pekko/projection/scaladsl/Handler.scala	36
core/src/main/scala/org/apache/pekko/projection/scaladsl/Projections.scala	86
core/src/main/scala/org/apache/pekko/projection/scaladsl/SourceProvider.scala	20
core/src/main/scala/org/apache/pekko/projection/scaladsl/ProjectionManagement.scala	96
core/src/main/scala/org/apache/pekko/projection/scaladsl/StatefulHandler.scala	31
core/src/main/scala/org/apache/pekko/projection/BySlicesSourceProvider.scala	5
core/src/main/scala/org/apache/pekko/projection/ProjectionContext.scala	2
core/src/main/scala/org/apache/pekko/projection/javadsl/ActorHandler.scala	15
core/src/main/scala/org/apache/pekko/projection/javadsl/Handler.scala	29
core/src/main/scala/org/apache/pekko/projection/javadsl/Projections.scala	87
core/src/main/scala/org/apache/pekko/projection/javadsl/SourceProvider.scala	22
core/src/main/scala/org/apache/pekko/projection/javadsl/ProjectionManagement.scala	31
core/src/main/scala/org/apache/pekko/projection/javadsl/StatefulHandler.scala	31
core/src/main/scala/org/apache/pekko/projection/HandlerRecoveryStrategy.scala	34
core/src/main/scala/org/apache/pekko/projection/Projection.scala	68
core/src/main/scala/org/apache/pekko/projection/StatusObserver.scala	16
core/src/main/scala/org/apache/pekko/projection/MergeableOffset.scala	4
core/src/main/scala/org/apache/pekko/projection/OffsetVerification.scala	16
core/src/main/scala/org/apache/pekko/projection/internal/HandlerRecoveryImpl.scala	144
core/src/main/scala/org/apache/pekko/projection/internal/InternalProjection.scala	7
core/src/main/scala/org/apache/pekko/projection/internal/ActorHandlerInit.scala	20
core/src/main/scala/org/apache/pekko/projection/internal/NoopStatusObserver.scala	20
core/src/main/scala/org/apache/pekko/projection/internal/ProjectionContextImpl.scala	17
core/src/main/scala/org/apache/pekko/projection/internal/ProjectionSettings.scala	93
core/src/main/scala/org/apache/pekko/projection/internal/ProjectionSerializer.scala	142
core/src/main/scala/org/apache/pekko/projection/internal/InternalProjectionState.scala	404
core/src/main/scala/org/apache/pekko/projection/internal/Telemetry.scala	71
core/src/main/scala/org/apache/pekko/projection/internal/OffsetSerialization.scala	81
core/src/main/scala/org/apache/pekko/projection/internal/HandlerAdapter.scala	58
core/src/main/scala/org/apache/pekko/projection/internal/OffsetStrategy.scala	80
core/src/main/scala/org/apache/pekko/projection/internal/SourceProviderAdapter.scala	26
core/src/main/protobuf/ProjectionMessages.proto	45
testkit/src/main/scala/org/apache/pekko/projection/testkit/scaladsl/TestOffsetStore.scala	16
testkit/src/main/scala/org/apache/pekko/projection/testkit/scaladsl/ProjectionTestKit.scala	65
testkit/src/main/scala/org/apache/pekko/projection/testkit/scaladsl/TestProjection.scala	38
testkit/src/main/scala/org/apache/pekko/projection/testkit/scaladsl/TestSourceProvider.scala	28
testkit/src/main/scala/org/apache/pekko/projection/testkit/javadsl/TestOffsetStore.scala	17
testkit/src/main/scala/org/apache/pekko/projection/testkit/javadsl/ProjectionTestKit.scala	29
testkit/src/main/scala/org/apache/pekko/projection/testkit/javadsl/TestProjection.scala	40
testkit/src/main/scala/org/apache/pekko/projection/testkit/javadsl/TestSourceProvider.scala	30
testkit/src/main/scala/org/apache/pekko/projection/testkit/internal/TestInMemoryOffsetStoreImpl.scala	28
testkit/src/main/scala/org/apache/pekko/projection/testkit/internal/TestProjectionImpl.scala	136
testkit/src/main/scala/org/apache/pekko/projection/testkit/internal/TestSourceProviderImpl.scala	78
testkit/src/main/scala/org/apache/pekko/projection/testkit/internal/TestOffsetStoreAdapter.scala	29
testkit/src/main/scala/org/apache/pekko/projection/testkit/internal/TestClock.scala	26
eventsourced/src/main/scala/org/apache/pekko/projection/eventsourced/scaladsl/EventSourcedProvider.scala	125
eventsourced/src/main/scala/org/apache/pekko/projection/eventsourced/EventEnvelope.scala	60
eventsourced/src/main/scala/org/apache/pekko/projection/eventsourced/javadsl/EventSourcedProvider.scala	164
docker-files/cassandra.yaml	91
build.sbt	197
jdbc/src/main/scala/org/apache/pekko/projection/jdbc/JdbcSession.scala	17
jdbc/src/main/scala/org/apache/pekko/projection/jdbc/JdbcHandlerLifecycle.scala	6
jdbc/src/main/scala/org/apache/pekko/projection/jdbc/scaladsl/JdbcHandler.scala	18
jdbc/src/main/scala/org/apache/pekko/projection/jdbc/scaladsl/JdbcProjection.scala	159
jdbc/src/main/scala/org/apache/pekko/projection/jdbc/javadsl/JdbcHandler.scala	25
jdbc/src/main/scala/org/apache/pekko/projection/jdbc/javadsl/JdbcProjection.scala	186
jdbc/src/main/scala/org/apache/pekko/projection/jdbc/internal/JdbcProjectionImpl.scala	231
jdbc/src/main/scala/org/apache/pekko/projection/jdbc/internal/JdbcSettings.scala	69
jdbc/src/main/scala/org/apache/pekko/projection/jdbc/internal/JdbcSessionUtil.scala	56
jdbc/src/main/scala/org/apache/pekko/projection/jdbc/internal/JdbcHandlerAdapter.scala	26
jdbc/src/main/scala/org/apache/pekko/projection/jdbc/internal/JdbcOffsetStore.scala	231
jdbc/src/main/scala/org/apache/pekko/projection/jdbc/internal/Dialect.scala	358
jdbc/src/it/scala/org/apache/pekko/projection/jdbc/JdbcContainerOffsetStoreSpec.scala	108
jdbc/src/it/scala/org/apache/pekko/projection/jdbc/JdbcProjectionSpec.scala	1112
jdbc/src/it/resources/logback-test.xml	16
jdbc/src/it/resources/db/default-init.sql	1
cassandra/src/main/scala/org/apache/pekko/projection/cassandra/scaladsl/CassandraProjection.scala	84
cassandra/src/main/scala/org/apache/pekko/projection/cassandra/javadsl/CassandraProjection.scala	88
cassandra/src/main/scala/org/apache/pekko/projection/cassandra/internal/CassandraSettings.scala	18
cassandra/src/main/scala/org/apache/pekko/projection/cassandra/internal/CassandraOffsetStore.scala	118
cassandra/src/main/scala/org/apache/pekko/projection/cassandra/internal/CassandraProjectionImpl.scala	162
cassandra/src/it/scala/org/apache/pekko/projection/cassandra/ContainerSessionProvider.scala	37
cassandra/src/it/scala/org/apache/pekko/projection/cassandra/CassandraProjectionSpec.scala	869
cassandra/src/it/scala/org/apache/pekko/projection/cassandra/CassandraOffsetStoreSpec.scala	186
cassandra/src/it/java/org/apache/pekko/projection/cassandra/CassandraProjectionTest.java	324
cassandra/src/it/resources/logback-test.xml	20