evolution-gaming / kafka-journal / 29844675163

push

github

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>

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