kafka-flow
kafka-flow copied to clipboard
library for reliable processing records received from kafka
## About this PR 📦 Updates [org.scalameta:sbt-mdoc](https://github.com/scalameta/mdoc) from `2.7.2` to `2.8.0` 📜 [GitHub Release Notes](https://github.com/scalameta/mdoc/releases/tag/v2.8.0) - [Version Diff](https://github.com/scalameta/mdoc/compare/v2.7.2...v2.8.0) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...
## About this PR 📦 Updates [org.scala-lang:scala-library](https://github.com/scala/scala) from `2.13.16` to `2.13.17` 📜 [GitHub Release Notes](https://github.com/scala/scala/releases/tag/v2.13.17) - [Version Diff](https://github.com/scala/scala/compare/v2.13.16...v2.13.17) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...
As mentioned in [#732 ](https://github.com/evolution-gaming/kafka-flow/issues/732), kafka-flow does not ensure single owner for a partition during specific rebalance scenarios caused by broker issues. This results in corrupted state snapshots. In general,...
### Description I have observed, that during unideal circumstances, like Kafka maintenance, network issues or many restarts during high load. There is a possiblity of having multiple activate `PartitionFlow` for...