30525446494
83%

Ran 30 Jul 2026 08:13AM UTC

Jobs 2

Files 106

Run time 1min

Badge

Embed ▾

Committed 30 Jul 2026 08:07AM UTC coverage: 83.341%. Remained the same

Build # 30525446494

Build Type

push

Committed by

web-flow

Commit Message

Mark the snapshot writer's transactional.id as such (#876)

* Mark the snapshot writer's transactional.id as such

Every other identifier this module mints says "snapshot" - the producer's
client.id in the same copy, and both recovery consumers in
KafkaPartitionPersistence. Only the transactional.id was bare
`<prefix>-<partition>`.

The gap is widest by default: client.id is an Option the suffix maps over, so a
caller who never sets one is left with the transactional.id as the producer's
only operator-visible name. The label is approximate in one respect - the same
producer also commits the input offsets, and an offset-only transaction carries
no snapshot record - but client.id already made that same approximation.

* Drop meaningless 8 (uuid8)

Leak from earlier implementation detail where the first 8 chars of an UUID was used.

* Keep the design doc to id properties, not spelling

Nothing in the doc's reasoning depends on how the id is spelled - only
that it is stable, with nothing per-assignment in it. The spelling is a
module artifact; persistence.md and the scaladoc carry it, so the three
copies quoted here were only drift liability.

Coverage Stats

1831 of 2197 relevant lines covered (83.34%)

1.31 hits per line

Coverage Regressions

Lines	Coverage	∆	File
16	85.09	-7.76%	core/src/main/scala/com/evolutiongaming/kafka/flow/PartitionFlow.scala
14	42.86	-5.29%	core/src/main/scala/com/evolutiongaming/kafka/flow/FoldOption.scala
12	53.13	-8.41%	core/src/main/scala/com/evolutiongaming/kafka/flow/KeyContext.scala
12	68.57	-9.21%	core/src/main/scala/com/evolutiongaming/kafka/flow/persistence/Persistence.scala
9	75.81	0.81%	core/src/main/scala/com/evolutiongaming/kafka/flow/snapshot/Snapshots.scala
8	54.17	-0.67%	core/src/main/scala/com/evolutiongaming/kafka/flow/Fold.scala
8	48.61	11.65%	core/src/main/scala/com/evolutiongaming/kafka/flow/kafka/Consumer.scala
8	40.0	-10.0%	core/src/main/scala/com/evolutiongaming/kafka/flow/KafkaFlow.scala
8	0.0	0.0%	core/src/main/scala/com/evolutiongaming/kafka/flow/persistence/compression/CompressorSyntax.scala
8	46.67	46.67%	metrics/src/main/scala/com/evolutiongaming/kafka/flow/journal/JournalDatabaseMetrics.scala
8	59.09	0.76%	persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/cassandra/SessionHelper.scala
6	0.0	0.0%	metrics/src/main/scala/com/evolutiongaming/kafka/flow/compression/CompressorMetrics.scala
6	61.9	-13.1%	persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/cassandra/CassandraPersistence.scala
6	89.41	-3.92%	persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/journal/CassandraJournals.scala
6	91.46	-6.61%	persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/snapshot/CassandraSnapshots.scala
5	0.0	0.0%	core/src/main/scala/com/evolutiongaming/kafka/flow/kafka/EmptyRebalanceConsumer.scala
5	31.58	4.91%	core/src/main/scala/com/evolutiongaming/kafka/flow/persistence/PersistenceModule.scala
5	18.18	-15.15%	core/src/main/scala/com/evolutiongaming/kafka/flow/TickOption.scala
5	48.65	23.65%	metrics/src/main/scala/com/evolutiongaming/kafka/flow/key/KeyDatabaseMetrics.scala
4	23.53	5.35%	core/src/main/scala/com/evolutiongaming/kafka/flow/EnhancedFold.scala
4	70.0	5.29%	core/src/main/scala/com/evolutiongaming/kafka/flow/persistence/PersistenceOf.scala
4	93.06	-5.09%	persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/key/CassandraKeys.scala
4	94.62	-3.49%	persistence-kafka/src/main/scala/com/evolutiongaming/kafka/flow/kafkapersistence/KafkaPersistenceModule.scala
3	76.19	10.81%	core/src/main/scala/com/evolutiongaming/kafka/flow/KeyStateOf.scala
3	0.0	0.0%	core/src/main/scala/com/evolutiongaming/kafka/flow/timer/TimerWindow.scala
3	88.57	-8.73%	core/src/main/scala/com/evolutiongaming/kafka/flow/TopicFlow.scala
3	0.0	0.0%	metrics/src/main/scala/com/evolutiongaming/kafka/flow/PartitionFlowMetrics.scala
3	0.0	0.0%	metrics/src/main/scala/com/evolutiongaming/kafka/flow/snapshot/SnapshotDatabaseMetrics.scala
3	0.0	0.0%	metrics/src/main/scala/com/evolutiongaming/kafka/flow/TopicFlowMetrics.scala
3	85.19	-5.72%	persistence-cassandra/src/main/scala/com/evolution/kafka/flow/cassandra/CassandraModule.scala
3	33.33	-6.67%	persistence-kafka/src/main/scala/com/evolutiongaming/kafka/flow/kafkapersistence/KafkaPersistencePartitionMapper.scala
2	42.86	9.52%	core/src/main/scala/com/evolutiongaming/kafka/flow/ConsumerFlowOf.scala
2	97.14	-2.86%	core/src/main/scala/com/evolutiongaming/kafka/flow/timer/TimerFlowOf.scala
2	0.0	0.0%	metrics/src/main/scala/com/evolutiongaming/kafka/flow/KeyStateMetrics.scala
2	84.38	2.02%	metrics/src/main/scala/com/evolutiongaming/kafka/flow/metrics/syntax/package.scala
2	0.0	0.0%	metrics/src/main/scala/com/evolutiongaming/kafka/flow/persistence/PersistenceModuleMetrics.scala
2	76.47	2.56%	persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/cassandra/CassandraCodecs.scala
2	33.33	-66.67%	persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/cassandra/ConsistencyOverrides.scala
2	0.0	0.0%	persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/journal/conversions/HeaderToTuple.scala
2	0.0	0.0%	persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/journal/conversions/TupleToHeader.scala
2	60.0	-9.23%	persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/key/SegmentNr.scala
1	88.89	-11.11%	core/src/main/scala/com/evolutiongaming/kafka/flow/AdditionalStatePersist.scala
1	57.14	-27.47%	core/src/main/scala/com/evolutiongaming/kafka/flow/FoldToState.scala
1	70.0	-0.59%	core/src/main/scala/com/evolutiongaming/kafka/flow/journal/JournalDatabase.scala
1	50.0	0.0%	core/src/main/scala/com/evolutiongaming/kafka/flow/kafka/Codecs.scala
1	77.78	11.11%	core/src/main/scala/com/evolutiongaming/kafka/flow/key/KeyDatabase.scala
1	80.0	-20.0%	core/src/main/scala/com/evolutiongaming/kafka/flow/PartitionFlowOf.scala
1	87.5	1.14%	core/src/main/scala/com/evolutiongaming/kafka/flow/persistence/compression/Compressor.scala
1	80.56	4.56%	core/src/main/scala/com/evolutiongaming/kafka/flow/registry/EntityRegistry.scala
1	50.0	50.0%	core/src/main/scala/com/evolutiongaming/kafka/flow/snapshot/KafkaSnapshot.scala
1	81.82	10.39%	core/src/main/scala/com/evolutiongaming/kafka/flow/snapshot/SnapshotDatabase.scala
1	28.57	-4.76%	core/src/main/scala/com/evolutiongaming/kafka/flow/Tick.scala
1	40.0	-35.0%	core/src/main/scala/com/evolutiongaming/kafka/flow/TickToState.scala
1	0.0	0.0%	core/src/main/scala/com/evolutiongaming/kafka/flow/timer/KafkaTimer.scala
1	80.0	-20.0%	core/src/main/scala/com/evolutiongaming/kafka/flow/timer/TimerContext.scala
1	50.0	0.0%	core/src/main/scala/com/evolutiongaming/kafka/flow/timer/TimerFlow.scala
1	90.0	-10.0%	core/src/main/scala/com/evolutiongaming/kafka/flow/timer/Timestamps.scala
1	40.0	6.67%	core/src/main/scala/com/evolutiongaming/kafka/flow/TopicFlowOf.scala
1	90.0	-10.0%	kafka-journal/src/main/scala/com/evolutiongaming/kafka/flow/journal/JournalFold.scala
1	16.67	2.38%	metrics/src/main/scala/com/evolutiongaming/kafka/flow/FlowMetrics.scala
1	47.06	23.73%	metrics/src/main/scala/com/evolutiongaming/kafka/flow/FoldMetrics.scala
1	33.33	33.33%	metrics/src/main/scala/com/evolutiongaming/kafka/flow/metrics/Metrics.scala
1	98.25	-1.75%	persistence-kafka/src/main/scala/com/evolutiongaming/kafka/flow/kafkapersistence/KafkaSnapshotWriteDatabase.scala

Jobs

ID	Job ID	Ran	Files	Coverage
1	30525446494.1	30 Jul 2026 08:13AM UTC	106	71.64
2	30525446494.2	30 Jul 2026 08:14AM UTC	103	71.14

evolution-gaming / kafka-flow / 30525446494
83%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

Coverage Regressions

Jobs

Source Files on build 30525446494

evolution-gaming / kafka-flow / 30525446494 83%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

Coverage Regressions

Jobs

Source Files on build 30525446494

evolution-gaming / kafka-flow / 30525446494
83%

README BADGES
x