alpakka-kafka
alpakka-kafka copied to clipboard
akka
Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
Versions used Akka version: 2.6.19 Akka Stream Kafka version: 3.0.0 Questions: Since > The Alpakka Kafka [SendProducer](https://doc.akka.io/api/alpakka-kafka/4.0.0/akka/kafka/scaladsl/SendProducer.html) does not integrate with Akka Streams. Instead, it offers a wrapper of the...
The current reactive kafka consumer does not work with the resuming supervision strategy. If the stage fails, for instance as the result of the wake up timeout limit reached, then...
## About this PR 📦 Updates [io.confluent:kafka-avro-serializer](https://github.com/confluentinc/schema-registry) from `7.4.2` to `7.4.5` 📜 [GitHub Release Notes](https://github.com/confluentinc/schema-registry/releases/tag/v7.4.5) - [Version Diff](https://github.com/confluentinc/schema-registry/compare/v7.4.2...v7.4.5) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...
## About this PR 📦 Updates [com.google.protobuf:protobuf-java](https://github.com/protocolbuffers/protobuf) from `3.25.3` to `4.26.1` ⚠ ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve conflicts as long as you don't...
Added Scala 3 even for tests and testing. Scala 3 artefacts were published even before.
This is somewhat related to [this issue](https://github.com/akka/reactive-kafka/issues/248). For instance in the case of `Producer.flow`, is it possible to keep a `Flow[Message[K, V, P], Future[Result[K, V, P]], NotUsed]`, in order to...
Release Alpakka Kafka 6.0.0 ### Cutting the release - [x] Check that open PRs and issues assigned to the milestone are reasonable - [x] For minor or major versions, update...
Something dodgy with the CI tests, I've seen a couple of times now, one of them taking a long long while, looking at the logs tests are failing, looks like...
## About this PR 📦 Updates [io.dropwizard.metrics:metrics-core](https://github.com/dropwizard/metrics/) from `4.2.25` to `4.2.26` 📜 [GitHub Release Notes](https://github.com/dropwizard/metrics/releases/tag/v4.2.26) - [Version Diff](https://github.com/dropwizard/metrics/compare/v4.2.25...v4.2.26) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...
## About this PR 📦 Updates [com.thesamet.scalapb:scalapb-runtime](https://github.com/scalapb/ScalaPB) from `0.11.15` to `0.11.17` 📜 [GitHub Release Notes](https://github.com/scalapb/ScalaPB/releases/tag/v0.11.17) - [Changelog](https://github.com/scalapb/ScalaPB/blob/master/CHANGELOG.md) - [Version Diff](https://github.com/scalapb/ScalaPB/compare/v0.11.15...v0.11.17) ## Usage ✅ **Please merge!** I'll automatically update this PR...