31510719680
89%

Ran 11 Aug 2026 04:22PM UTC

Jobs 2

Files 215

Run time 1min

Badge

Embed ▾

Committed 11 Aug 2026 04:07PM UTC coverage: 91.553% (+0.04%) from 91.515%

Build # 31510719680

Build Type

push

github

Committed by

web-flow

Commit Message

Cover TopicReplicator cancellation semantics with tests (#960)

IO-based tests for key failure handling: guards #957 (sibling keys of
same partition are not cancelled) and documents the remaining
cross-partition cancellation via pendingUntilFixed — flips to a
regression test once fixed.

---------

Co-authored-by: sshevchenko <sshevchenko@evolution.com>

Coverage Stats

1151 of 1457 branches covered (79.0%)

Branch coverage included in aggregate %.

6230 of 6605 relevant lines covered (94.32%)

1.64 hits per line

Coverage Regressions

Lines	Coverage	∆	File
95	78.1	6.81%	com/evolution/kafka/journal/LogFromAkka.scala
73	63.97	-2.25%	com/evolution/kafka/journal/replicator/CacheOf.scala
67	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
19	49.28	-4.57%	com/evolution/kafka/journal/util/Fail.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
10	0.0	0.0%	com/evolution/kafka/journal/execution/ForkJoinPoolOf.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
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
6	0.0	0.0%	com/evolution/kafka/journal/util/Executors.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	85.29	-0.42%	com/evolution/kafka/journal/JsonCodec.scala
5	91.18	2.67%	com/evolution/kafka/journal/replicator/Replicator.scala
5	20.0	11.67%	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
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	0.0	0.0%	com/evolution/kafka/journal/execution/ThreadFactoryOf.scala
3	0.0	0.0%	com/evolution/kafka/journal/execution/ThreadPoolOf.scala
3	81.01	-2.09%	com/evolution/kafka/journal/HeadInfo.scala
3	42.86	-7.14%	com/evolution/kafka/journal/IOSuite.scala
3	54.84	-1.16%	com/evolution/kafka/journal/util/TemporalHelper.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	91.18	-3.82%	com/evolution/kafka/journal/eventual/EventualRead.scala
2	76.92	-10.58%	com/evolution/kafka/journal/eventual/EventualWrite.scala
2	70.0	-16.11%	com/evolution/kafka/journal/eventual/ReplicatedJournal.scala
2	0.0	0.0%	com/evolution/kafka/journal/execution/ScheduledExecutorServiceOf.scala
2	93.24	9.2%	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	50.0	0.0%	com/evolution/kafka/journal/PayloadMetadata.scala
2	0.0	0.0%	com/evolution/kafka/journal/replicator/TopicFlowOf.scala
2	85.19	-3.05%	com/evolution/kafka/journal/util/CatsHelper.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.08	-1.36%	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	80.0	8.57%	com/evolution/kafka/journal/FromBytes.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	98.53	1.35%	com/evolution/kafka/journal/replicator/TopicReplicatorMetrics.scala
1	90.0	-10.0%	com/evolution/kafka/journal/Settings.scala
1	66.67	18.52%	com/evolution/kafka/journal/util/ScodecHelper.scala
1	80.0	-3.33%	com/evolution/kafka/journal/util/SkafkaHelper.scala
1	89.47	6.14%	com/evolution/kafka/journal/util/StartResource.scala

Jobs

ID	Job ID	Ran	Files	Coverage
1	Scala 3.3.8 - 31510719680.1	11 Aug 2026 04:22PM UTC	215	81.74	GitHub Action Run
2	Scala 2.13.18 - 31510719680.2	11 Aug 2026 04:22PM UTC	212	83.78	GitHub Action Run

evolution-gaming / kafka-journal / 31510719680
89%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

Coverage Regressions

Jobs

Source Files on build 31510719680

evolution-gaming / kafka-journal / 31510719680 89%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

Coverage Regressions

Jobs

Source Files on build 31510719680

evolution-gaming / kafka-journal / 31510719680
89%

README BADGES
x