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

Metrics seem to be overengineered at this stage

Right now `Fold` contains a lot of custom code and syntax to make constructing and combining `Fold` instances easier. It may make understanding of the whole library harder, because one...

Currently, requirement to define `KeyStateOf` breaks a nice nesting pattern of flows: `KafkaFlow -> ConsumerFlow -> PartitionFlow -> KeyFlow`. I.e. there is `KeyState` instead of `KeyFlow` and `KeyFlow` is hidden...

## About this PR 📦 Updates [org.scalameta:munit](https://github.com/scalameta/munit) from `1.0.0-M10` to `1.0.1` 📜 [GitHub Release Notes](https://github.com/scalameta/munit/releases/tag/v1.0.1) - [Version Diff](https://github.com/scalameta/munit/compare/v1.0.0-M10...v1.0.1) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...

Resolves https://github.com/evolution-gaming/kafka-flow/issues/593

## About this PR 📦 Updates [org.typelevel:cats-mtl](https://github.com/typelevel/cats-mtl) from `1.3.1` to `1.5.0` 📜 [GitHub Release Notes](https://github.com/typelevel/cats-mtl/releases/tag/v1.5.0) - [Version Diff](https://github.com/typelevel/cats-mtl/compare/v1.3.1...v1.5.0) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...

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

## About this PR 📦 Updates [com.evolutiongaming:skafka](https://github.com/evolution-gaming/skafka) from `16.0.3` to `16.4.0` 📜 [GitHub Release Notes](https://github.com/evolution-gaming/skafka/releases/tag/v16.4.0) - [Version Diff](https://github.com/evolution-gaming/skafka/compare/v16.0.3...v16.4.0) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...

## About this PR 📦 Updates [org.scoverage:sbt-coveralls](https://github.com/scoverage/sbt-coveralls) from `1.3.11` to `1.3.13` 📜 [GitHub Release Notes](https://github.com/scoverage/sbt-coveralls/releases/tag/v1.3.13) - [Version Diff](https://github.com/scoverage/sbt-coveralls/compare/v1.3.11...v1.3.13) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...

## About this PR 📦 Updates [com.evolutiongaming:skafka](https://github.com/evolution-gaming/skafka) from `16.0.3` to `16.2.0` 📜 [GitHub Release Notes](https://github.com/evolution-gaming/skafka/releases/tag/v16.2.0) - [Version Diff](https://github.com/evolution-gaming/skafka/compare/v16.0.3...v16.2.0) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...