kafka-flow icon indicating copy to clipboard operation
kafka-flow copied to clipboard

library for reliable processing records received from kafka

Results 75 kafka-flow issues
Sort by recently updated
recently updated
newest added
trafficstars

## 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...