kafka-flow

kafka-flow copied to clipboard

## About this PR 📦 Updates * com.github.julien-truffaut:monocle-core * com.github.julien-truffaut:monocle-macro from `2.1.0` to `3.2.0` ⚠ ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve conflicts as long...

scala-steward

- allow specifying names of Cassandra tables for Cassandra-based persistence - remove deprecated factory methods

Z1kkurat

This is a back-port of https://github.com/evolution-gaming/kafka-flow/pull/463.

Z1kkurat

vilunov

vilunov

Here I'm outlining my thoughts on what we can change to improve readability, make introducing new features less complex, and ease the burden of maintenance of the library. ### Different...

Z1kkurat

edubrovski

edubrovski

Currently it persists the state without updating committable offsets, so after shutdown we have updated state in persistent storage but no committed offsets, which is not a critical issue by...

nikitapecasa

KafkaFlow may lose an error if retry strategy fails at the following line: https://github.com/evolution-gaming/kafka-flow/blob/master/core/src/main/scala/com/evolutiongaming/kafka/flow/KafkaFlow.scala#L81 The problem is that as the `join` is never called the, if fiber dies with an...

rtar