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

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

Build:
Build:
LAST BUILD BRANCH: update/logback-classic-1.5.24
DEFAULT BRANCH: master
Ran 07 Feb 2025 01:15PM UTC
Jobs 1
Files 183
Run time 1min
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

07 Feb 2025 01:04PM UTC coverage: 83.255% (+0.1%) from 83.115%
13200507137

Pull #720

migesok
Add ReplicatedOffsetNotifier callback

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
Pull Request #720: Add ReplicatedOffsetNotifier callback

5 of 5 new or added lines in 3 files covered. (100.0%)

3 existing lines in 3 files now uncovered.

3177 of 3816 relevant lines covered (83.25%)

1.41 hits per line

Uncovered Existing Lines

Lines Coverage ∆ File
1
78.33
-1.67% replicator/src/main/scala/com/evolutiongaming/kafka/journal/replicator/ReplicateRecords.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
Jobs
ID Job ID Ran Files Coverage
1 Scala 2.13.16 - 13200507137.1 07 Feb 2025 01:15PM UTC 183
83.25
Source Files on build 13200507137
  • Tree
  • List 183
  • Changed 38
  • Source Changed 2
  • Coverage Changed 13
Coverage ∆ File Lines Relevant Covered Missed Hits/Line
  • Back to Repo
  • Pull Request #720
  • PR Base - 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