kotlin-kafka

kotlin-kafka copied to clipboard

I use this library in my Ktor project, and runs the `KafkaReceiver` with IO dispatcher, and sets `commitStrategy = CommitStrategy.BySize(100)`, it throws `java.util.ConcurrentModificationException`. The full stacktrace is ``` java.util.ConcurrentModificationException: KafkaConsumer...

winkey728

This PR reintroduces the `schedulePoll` method from `0.3.1` fixes #199 also potentially fixes #195 and #198

tKe

This PR contains the following updates: | Package | Type | Update | Change | Age | Confidence | |---|---|---|---|---|---| | [actions/checkout](https://redirect.github.com/actions/checkout) | action | major | `v4` -> `v5`...

renovate[bot]

Move repository to a separate organisation so responsibility could be shared

5

@nomisRev As briefly mentioned here: https://github.com/nomisRev/kotlin-kafka/issues/203 > Side-note: I would be more than happy to move this project to a separate organisation such as to share responsibility between other contributors....

kfh

The `ReceiverSettings` defaults to `AutoOffsetReset.Earliest` but default in Kafka is `latest` as per: https://kafka.apache.org/documentation/#consumerconfigs_auto.offset.reset This should probably be aligned unless there is a specific reason do default to `AutoOffsetReset.Earliest`.

kfh

chore(deps): bump dependencies for kotlin-2.1

2

tKe

Updating the Kafka version to v3.9.1 are fixing CVE issues we have in production: - CVE-2025-27817 - CVE-2025-27819 - CVE-2025-27818 Also for some reason this points to `org.apache.kafka:[email protected]`. But in...

mjovanc

## 📌 Hey! This PR was made for you with Junie, the coding agent by JetBrains **Early Access Preview** It's still learning, developing, and might make mistakes. Please make sure...

jetbrains-junie[bot]