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.
Updates [com.thesamet.scalapb:scalapb-runtime](https://github.com/scalapb/ScalaPB) from 0.10.11 to 0.11.11. [GitHub Release Notes](https://github.com/scalapb/ScalaPB/releases/tag/v0.11.11) - [Changelog](https://github.com/scalapb/ScalaPB/blob/master/CHANGELOG.md) - [Version Diff](https://github.com/scalapb/ScalaPB/compare/v0.10.11...v0.11.11) I'll automatically update this PR to resolve conflicts as long as you don't change it yourself....
Updates [org.junit.jupiter:junit-jupiter-api](https://github.com/junit-team/junit5) from 5.8.2 to 5.9.0. I'll automatically update this PR to resolve conflicts as long as you don't change it yourself. If you'd like to skip this version, you...
Updates * net.aichler:jupiter-interface * net.aichler:sbt-jupiter-interface from 0.9.1 to 0.11.0. I'll automatically update this PR to resolve conflicts as long as you don't change it yourself. If you'd like to skip...
### Short description The use case is a Kafka event-sourced setup with periodic partition snapshot storing In this case when a partition is assigned you have the following steps: 1....
Updates [org.testcontainers:kafka](https://github.com/testcontainers/testcontainers-java/) from 1.16.3 to 1.17.3. [GitHub Release Notes](https://github.com/testcontainers/testcontainers-java/releases/tag/1.17.3) - [Changelog](https://github.com/testcontainers/testcontainers-java/blob/master/CHANGELOG.md) - [Version Diff](https://github.com/testcontainers/testcontainers-java/compare/1.16.3...1.17.3) I'll automatically update this PR to resolve conflicts as long as you don't change it yourself....
Updates com.fasterxml.jackson.core:jackson-databind from 2.13.2.2 to 2.13.3. I'll automatically update this PR to resolve conflicts as long as you don't change it yourself. If you'd like to skip this version, you...
kafka consumer is stucked saying like "Consumer clientId=consumer-A-1, groupId=A] Adding newly assigned partitions:"
* Adapt `onDownstreamFinish` with cause (by Akka 2.6) * Delay consumer actor stop only for non-failure cancellations References #1228
Closes #1424 I don't know if this is the best solution, but since some people might want to use a custom tag (like building a `cp-kafka` image on M1), a...
### Short description Kafka Cluster Sharding is really useful to reduce the amount inter shard messaging but at the moment it is only doing a modulo operation over the entityId,...
