Skip to content

Tags: zio/zio-kafka

Tags

v3.7.1

Toggle v3.7.1's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
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`

v3.7.0

Toggle v3.7.0's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
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>

v3.6.0

Toggle v3.6.0's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
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.

v3.5.0

Toggle v3.5.0's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
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]>

v3.4.0

Toggle v3.4.0's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
Reduce concurrent admin operations (#1697)

Reduce the default number of concurrent admin operations from 5 to 1 for
all admin clients.

This is a follow-up of #1667.

v3.3.0

Toggle v3.3.0's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
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]>

v3.2.0

Toggle v3.2.0's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
Update kafka-clients to 4.1.1 (#1608)

📦 Updates [org.apache.kafka:kafka-clients](https://kafka.apache.org)
from `4.1.0` to `4.1.1`

v3.1.0

Toggle v3.1.0's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
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`

v3.1.0-rc1

Toggle v3.1.0-rc1's commit message

Verified

This commit was signed with the committer’s verified signature.
erikvanoosten Erik van Oosten
Remove lost

v3.0.0-18-ca7f289b

Toggle v3.0.0-18-ca7f289b's commit message

Verified

This commit was signed with the committer’s verified signature.
erikvanoosten Erik van Oosten
Avoid scaladoc issues.