Tags: zio/zio-kafka
Tags
Update sbt, scripted-plugin to 1.12.15 (#1752) 📦 Updates * [org.scala-sbt:sbt](https://github.com/sbt/sbt) * [org.scala-sbt:scripted-plugin](https://github.com/sbt/sbt) from `1.12.14` to `1.12.15`
Update README.md (#1738) Autogenerated changes after running the `sbt docs/generateReadme` command of the [zio-sbt-website](https://zio.dev/zio-sbt) plugin. I will automatically update the README.md file whenever there is new change for README.md, e.g. - After each release, I will update the version in the installation section. - After any changes to the "docs/index.md" file, I will update the README.md file accordingly. Co-authored-by: ZIO Assistant <zio-assistant[bot]@users.noreply.github.com>
Fix consumer hang when Runloop crashes with empty dataQueue (#1707) As reported by @acrow in #1705. When the internal Runloop crashes with a fatal exception (e.g. `TopicAuthorizationException` after `authErrorRetrySchedule` is exhausted), consumers are supposed to fail with that exception so the user's `.retry(...)` can decide what to do. This works on the first occurrence of the exception because records are typically in flight: the per-partition stream pulls a chunk, then sees `interruptionPromise` or hub failure and propagates the error. But on the second occurrence (right after a retry with the same denied ACL), no records ever arrive. Every per-partition stream is parked on `dataQueue.take.raceFirst(interruptionPromise.await)` (PartitionStreamControl.scala:161). When the Runloop dies, it does `partitionsHub.offer(Take.failCause(cause))` (Runloop.scala:560) — but per-partition streams do not subscribe to the hub. Nothing fails `interruptionPromise`, nothing offers `EndOfStream` to `dataQueue`, so the partition stream fibers hang forever, hanging the consumer as well. The fix is to explicitly halt the active per-partition streams when the runloop crashes. Fixes #1705.
Update kafka-clients to 4.3.0 (#1700) 📦 Updates [org.apache.kafka:kafka-clients](https://kafka.apache.org) from `4.2.0` to `4.3.0` Also: - Use hard coded compression names and defaults to prevent a runtime dependency on classes moving around in the kafka library. Co-authored-by: zio-scala-steward[bot] <145262613+zio-scala-steward[bot]@users.noreply.github.com> Co-authored-by: Erik van Oosten <[email protected]>
Update kafka-clients to 4.2.0 (#1654) ## About this PR 📦 Updates [org.apache.kafka:kafka-clients](https://kafka.apache.org) from `4.1.1` to `4.2.0` ## Usage ✅ **Please merge!** 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 can just close this PR. If you have any feedback, just mention me in the comments below. Configure Scala Steward for your repository with a [`.scala-steward.conf`](https://github.com/scala-steward-org/scala-steward/blob/eaf4ea2f476b6b4988670d6cb6d9f9355e58780e/docs/repo-specific-configuration.md) file. _Have a fantastic day writing Scala!_ <details> <summary>⚙ Adjust future updates</summary> Add this to your `.scala-steward.conf` file to ignore future updates of this dependency: ``` updates.ignore = [ { groupId = "org.apache.kafka", artifactId = "kafka-clients" } ] ``` Or, add this to slow down future updates of this dependency: ``` dependencyOverrides = [{ pullRequests = { frequency = "30 days" }, dependency = { groupId = "org.apache.kafka", artifactId = "kafka-clients" } }] ``` </details> <sup> labels: library-update, early-semver-minor, semver-spec-minor, commit-count:1 </sup> <!-- scala-steward = { "Update" : { "ForArtifactId" : { "crossDependency" : [ { "groupId" : "org.apache.kafka", "artifactId" : { "name" : "kafka-clients", "maybeCrossName" : null }, "version" : "4.1.1", "sbtVersion" : null, "scalaVersion" : null, "configurations" : null } ], "newerVersions" : [ "4.2.0" ], "newerGroupId" : null, "newerArtifactId" : null } }, "Labels" : [ "library-update", "early-semver-minor", "semver-spec-minor", "commit-count:1" ] } --> Co-authored-by: zio-scala-steward[bot] <145262613+zio-scala-steward[bot]@users.noreply.github.com> Co-authored-by: Jules Ivanic <[email protected]>
Update zio-sbt-ci, zio-sbt-ecosystem, ... to 0.4.0-alpha.35 (#1582) 📦 Updates * [dev.zio:zio-sbt-ci](https://github.com/zio/zio-sbt) * [dev.zio:zio-sbt-ecosystem](https://github.com/zio/zio-sbt) * [dev.zio:zio-sbt-website](https://github.com/zio/zio-sbt) from `0.4.0-alpha.34` to `0.4.0-alpha.35`
PreviousNext