29844675163
91%

Ran 21 Jul 2026 03:50PM UTC

Jobs 2

Files 173

Run time 1min

Badge

Embed ▾

Committed 21 Jul 2026 03:35PM UTC coverage: 92.292% (+0.001%) from 92.291%

Build # 29844675163

Build Type

push

github

Committed by

web-flow

Commit Message

Bound TopicReplicator key replication concurrency (#936)

The key-level `parFoldMap1` in `TopicReplicator` started a Cassandra write
chain per key with no limit, so a poll spanning thousands of keys could
exhaust the connection pool. A per-key semaphore now bounds concurrent
key replication, sized by the new `replication-parallelism` config
(default 1024).

---------

Co-authored-by: sshevchenko <sshevchenko@evolution.com>
Co-authored-by: Mareks Rampāns <8796159+mr-git@users.noreply.github.com>

Coverage Stats

1078 of 1339 branches covered (80.51%)

Branch coverage included in aggregate %.

5699 of 6004 relevant lines covered (94.92%)

1.52 hits per line

Coverage Regressions

Lines	Coverage	∆	File
93	78.37	7.69%	com/evolution/kafka/journal/LogFromAkka.scala
76	63.0	-3.21%	com/evolution/kafka/journal/replicator/CacheOf.scala
66	70.99	-1.35%	com/evolution/kafka/journal/eventual/EventualJournal.scala
24	76.55	-0.78%	com/evolution/kafka/journal/eventual/cassandra/MetaJournalStatements.scala
20	94.21	-0.08%	com/evolution/kafka/journal/eventual/cassandra/CassandraCluster.scala
16	12.0	12.0%	com/evolution/kafka/journal/replicator/PurgeExpired.scala
12	72.41	-6.31%	com/evolution/kafka/journal/replicator/ReplicateRecords.scala
11	78.99	0.99%	com/evolution/kafka/journal/replicator/DistributeJob.scala
9	50.0	-33.33%	com/evolution/kafka/journal/conversions/ConsRecordToActionHeader.scala
9	67.27	3.27%	com/evolution/kafka/journal/Group.scala
9	9.38	3.66%	com/evolution/kafka/journal/JournalMetrics.scala
9	74.19	-5.51%	com/evolution/kafka/journal/Journal.scala
9	88.67	0.52%	com/evolution/kafka/journal/PartitionCache.scala
8	83.2	-2.36%	com/evolution/kafka/journal/replicator/commit/AsyncPeriodicTopicCommit.scala
7	92.92	-2.53%	com/evolution/kafka/journal/akka/persistence/ActorSystemRef.scala
7	88.04	-4.26%	com/evolution/kafka/journal/Damper.scala
7	84.8	-6.57%	com/evolution/kafka/journal/Journals.scala
7	92.92	-2.53%	com/evolution/kafka/journal/pekko/persistence/ActorSystemRef.scala
7	91.18	2.67%	com/evolution/kafka/journal/replicator/Replicator.scala
6	83.94	-2.63%	com/evolution/kafka/journal/akka/persistence/KafkaJournal.scala
6	77.94	-2.49%	com/evolution/kafka/journal/conversions/KafkaWrite.scala
6	83.94	-2.63%	com/evolution/kafka/journal/pekko/persistence/KafkaJournal.scala
5	71.88	-5.9%	com/evolution/kafka/journal/eventual/cassandra/Pointer2Statements.scala
5	12.5	2.5%	com/evolution/kafka/journal/eventual/TopicPointers.scala
5	13.33	5.0%	com/evolution/kafka/journal/replicator/TopicCommit.scala
5	0.0	0.0%	com/evolution/kafka/journal/SnapshotSelectionCriteria.scala
4	46.67	-8.89%	com/evolution/kafka/journal/cassandra/PlayJsonHelperExtension.scala
4	0.0	0.0%	com/evolution/kafka/journal/ConsumerPoolMetrics.scala
4	46.88	2.88%	com/evolution/kafka/journal/ConsumerPool.scala
4	0.0	0.0%	com/evolution/kafka/journal/conversions/KafkaReadMetrics.scala
4	78.95	0.0%	com/evolution/kafka/journal/conversions/KafkaRead.scala
4	0.0	0.0%	com/evolution/kafka/journal/conversions/KafkaWriteMetrics.scala
4	92.52	1.51%	com/evolution/kafka/journal/eventual/cassandra/EventualCassandra.scala
4	60.0	-16.47%	com/evolution/kafka/journal/Produce.scala
4	90.91	1.88%	com/evolution/kafka/journal/TopicCache.scala
3	40.0	-60.0%	com/evolution/kafka/journal/ConsRecord.scala
3	88.75	-0.14%	com/evolution/kafka/journal/eventual/cassandra/SegmentNr.scala
3	28.95	-0.46%	com/evolution/kafka/journal/eventual/cassandra/Segments.scala
3	65.0	-11.36%	com/evolution/kafka/journal/eventual/ReplicatedKeyJournal.scala
3	65.0	-11.92%	com/evolution/kafka/journal/eventual/ReplicatedPartitionJournal.scala
3	50.0	0.0%	com/evolution/kafka/journal/eventual/ReplicatedTopicJournal.scala
3	81.01	-2.09%	com/evolution/kafka/journal/HeadInfo.scala
2	83.33	-16.67%	com/evolution/kafka/journal/cassandra/CreateTables.scala
2	50.0	0.0%	com/evolution/kafka/journal/cassandra/RecordMetadataExtension.scala
2	70.0	-10.0%	com/evolution/kafka/journal/cassandra/SeqNrExtension.scala
2	80.95	-10.35%	com/evolution/kafka/journal/circe/Codecs.scala
2	50.0	-25.0%	com/evolution/kafka/journal/ConsumeActionRecords.scala
2	62.5	-12.5%	com/evolution/kafka/journal/conversions/ActionHeaderToHeader.scala
2	89.66	-2.65%	com/evolution/kafka/journal/conversions/ConsRecordToActionRecord.scala
2	62.5	-12.5%	com/evolution/kafka/journal/conversions/TupleToHeader.scala
2	87.5	3.29%	com/evolution/kafka/journal/eventual/cassandra/CassandraHelper.scala
2	83.33	-2.71%	com/evolution/kafka/journal/eventual/cassandra/ExpiryService.scala
2	0.0	0.0%	com/evolution/kafka/journal/eventual/cassandra/MetaJournalEntry.scala
2	94.87	-3.73%	com/evolution/kafka/journal/eventual/cassandra/ReplicatedCassandra.scala
2	76.6	-2.47%	com/evolution/kafka/journal/eventual/cassandra/SegmentSize.scala
2	70.0	-16.11%	com/evolution/kafka/journal/eventual/ReplicatedJournal.scala
2	91.89	3.59%	com/evolution/kafka/journal/HeadCache.scala
2	20.0	-13.33%	com/evolution/kafka/journal/HeaderMetadata.scala
2	73.68	23.68%	com/evolution/kafka/journal/KafkaConsumer.scala
2	0.0	0.0%	com/evolution/kafka/journal/replicator/TopicFlowOf.scala
2	94.12	-3.07%	com/evolution/kafka/journal/replicator/TopicReplicatorMetrics.scala
1	63.64	1.14%	com/evolution/kafka/journal/akka/OriginExtension.scala
1	80.0	-20.0%	com/evolution/kafka/journal/akka/persistence/Batching.scala
1	92.45	0.9%	com/evolution/kafka/journal/akka/persistence/EventSerializer.scala
1	82.61	-9.16%	com/evolution/kafka/journal/akka/persistence/JournalAdapter.scala
1	57.14	-9.52%	com/evolution/kafka/journal/akka/persistence/PersistentBinary.scala
1	75.0	8.33%	com/evolution/kafka/journal/akka/persistence/SerializedMsgSerializer.scala
1	96.88	-3.13%	com/evolution/kafka/journal/akka/persistence/ToKey.scala
1	96.15	-1.28%	com/evolution/kafka/journal/Bounds.scala
1	80.95	-3.26%	com/evolution/kafka/journal/BufferNr.scala
1	94.17	9.33%	com/evolution/kafka/journal/cassandra/CassandraSync.scala
1	87.5	-12.5%	com/evolution/kafka/journal/cassandra/DeleteToExtension.scala
1	97.67	-2.33%	com/evolution/kafka/journal/circe/package.scala
1	97.14	-2.86%	com/evolution/kafka/journal/conversions/ActionToProducerRecord.scala
1	66.67	0.0%	com/evolution/kafka/journal/conversions/HeaderToTuple.scala
1	90.0	-6.15%	com/evolution/kafka/journal/eventual/cassandra/CassandraSession.scala
1	60.0	10.0%	com/evolution/kafka/journal/HeadCacheOf.scala
1	66.67	-33.33%	com/evolution/kafka/journal/KafkaProducer.scala
1	80.0	0.0%	com/evolution/kafka/journal/PayloadAndType.scala
1	63.64	1.14%	com/evolution/kafka/journal/pekko/OriginExtension.scala
1	80.0	-20.0%	com/evolution/kafka/journal/pekko/persistence/Batching.scala
1	92.45	0.9%	com/evolution/kafka/journal/pekko/persistence/EventSerializer.scala
1	82.61	-9.16%	com/evolution/kafka/journal/pekko/persistence/JournalAdapter.scala
1	57.14	-9.52%	com/evolution/kafka/journal/pekko/persistence/PersistentBinary.scala
1	75.0	8.33%	com/evolution/kafka/journal/pekko/persistence/SerializedMsgSerializer.scala
1	96.88	-3.13%	com/evolution/kafka/journal/pekko/persistence/ToKey.scala
1	66.67	0.0%	com/evolution/kafka/journal/ProduceAction.scala
1	97.06	6.58%	com/evolution/kafka/journal/replicator/ConsumeTopic.scala
1	83.33	-3.33%	com/evolution/kafka/journal/replicator/DurationTo.scala
1	91.67	-8.33%	com/evolution/kafka/journal/replicator/PartitionsToSegments.scala
1	0.0	0.0%	com/evolution/kafka/journal/replicator/TopicFlow.scala
1	80.0	-3.33%	com/evolution/kafka/journal/util/SkafkaHelper.scala

Jobs

ID	Job ID	Ran	Files	Coverage
1	Scala 3.3.8 - 29844675163.1	21 Jul 2026 03:50PM UTC	173	82.51	GitHub Action Run
2	Scala 2.13.18 - 29844675163.2	21 Jul 2026 03:51PM UTC	170	84.62	GitHub Action Run

evolution-gaming / kafka-journal / 29844675163
91%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

Coverage Regressions

Jobs

Source Files on build 29844675163

evolution-gaming / kafka-journal / 29844675163 91%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

Coverage Regressions

Jobs

Source Files on build 29844675163

evolution-gaming / kafka-journal / 29844675163
91%

README BADGES
x