• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

evolution-gaming / kafka-journal / 13242495144
83%
master: 94%

Build:
Build:
LAST BUILD BRANCH: update/logback-classic-1.5.24
DEFAULT BRANCH: master
Ran 10 Feb 2025 02:01PM UTC
Jobs 1
Files 183
Run time 56min
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst

10 Feb 2025 01:32PM UTC coverage: 82.914% (-0.2%) from 83.115%
13242495144

push

web-flow
Add ReplicatedOffsetNotifier callback (#720)

Current recovery logic doesn't scale when the volume of events is large,
because clients have to consume all the events on all the app nodes.
Additionally, current logic creates Kafka consumers on-demand, which is
a heavy operation. This consumer creation happens in spikes, when
replicator is running late, and affects client applications stability.

Introducing a side channel for notifications about replication progress
will allow us in the future to have an alternative implementation for
recovery without these flaws. I.e. notifications go to a separate lean
Kafka topic which is read by all client nodes. On recovery:
- a mark is written
- wait until mark offset confirmed replicated in the notification topic
(with potential fallback to polling of the pointer table in Cassandra)
- recover from Cassandra only

6 of 7 new or added lines in 3 files covered. (85.71%)

14 existing lines in 12 files now uncovered.

3164 of 3816 relevant lines covered (82.91%)

1.38 hits per line

New Missed Lines in Diff

Lines Coverage ∆ File
1
85.92
-2.66% replicator/src/main/scala/com/evolutiongaming/kafka/journal/replicator/Replicator.scala

Uncovered Existing Lines

Lines Coverage ∆ File
1
28.57
0.0% core/src/main/scala/com/evolutiongaming/kafka/journal/LogFromAkka.scala
1
85.92
-2.66% replicator/src/main/scala/com/evolutiongaming/kafka/journal/replicator/Replicator.scala
1
81.0
-1.0% journal/src/main/scala/com/evolutiongaming/kafka/journal/Journal.scala
1
81.82
-9.09% core/src/main/scala/com/evolutiongaming/kafka/journal/Key.scala
1
88.89
0.0% snapshot/src/main/scala/com/evolutiongaming/kafka/journal/BufferNr.scala
1
74.14
-1.72% journal/src/main/scala/com/evolutiongaming/kafka/journal/eventual/ReplicatedPartitionJournal.scala
1
75.0
-25.0% core/src/main/scala/com/evolutiongaming/kafka/journal/FromJsResult.scala
1
96.43
0.0% journal/src/main/scala/com/evolutiongaming/kafka/journal/HeadCacheConsumption.scala
1
90.0
-10.0% journal/src/main/scala/com/evolutiongaming/kafka/journal/Events.scala
1
92.31
-3.85% cassandra/src/main/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/CassandraSession.scala
2
76.67
-3.33% replicator/src/main/scala/com/evolutiongaming/kafka/journal/replicator/ReplicateRecords.scala
2
88.24
-11.76% core/src/main/scala/com/evolutiongaming/kafka/journal/DeleteTo.scala
Jobs
ID Job ID Ran Files Coverage
1 Scala 2.13.16 - 13242495144.1 10 Feb 2025 02:01PM UTC 183
82.91
Source Files on build 13242495144
  • Tree
  • List 183
  • Changed 43
  • Source Changed 2
  • Coverage Changed 17
Coverage ∆ File Lines Relevant Covered Missed Hits/Line
  • Back to Repo
  • ae4e14ab on github
  • Prev Build on master (#12985538510)
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2026 Coveralls, Inc