zio/zio-kafka issues and pull requests

#1325 - Rename Serde operations for consistency with ZIO 2

Issue - State: closed - Opened by svroonland 2 months ago

#1324 - Bump peter-evans/create-pull-request from 6 to 7

Pull Request - State: closed - Opened by dependabot[bot] 2 months ago - 2 comments
Labels: dependency-update

#1324 - Bump peter-evans/create-pull-request from 6 to 7

Pull Request - State: closed - Opened by dependabot[bot] 2 months ago - 2 comments
Labels: dependency-update

#1323 - Bump scala-steward-org/scala-steward-action from 2.65.0 to 2.67.0

Pull Request - State: closed - Opened by dependabot[bot] 2 months ago - 1 comment
Labels: dependency-update

#1323 - Bump scala-steward-org/scala-steward-action from 2.65.0 to 2.67.0

Pull Request - State: closed - Opened by dependabot[bot] 2 months ago - 1 comment
Labels: dependency-update

#1322 - Update logback-classic to 1.5.8

Pull Request - State: closed - Opened by zio-scala-steward[bot] 2 months ago

#1321 - More precise batch publish errors

Pull Request - State: closed - Opened by ytalashko 3 months ago - 6 comments

#1321 - More precise batch publish errors

Pull Request - State: closed - Opened by ytalashko 3 months ago - 6 comments

#1320 - Update zio-streams, zio-test-sbt to 2.1.9

Pull Request - State: closed - Opened by zio-scala-steward[bot] 3 months ago

#1320 - Update zio-streams, zio-test-sbt to 2.1.9

Pull Request - State: closed - Opened by zio-scala-steward[bot] 3 months ago

#1319 - Fixes #1318 Adds documentation about auto commit behaviour

Pull Request - State: closed - Opened by ashwinbhaskar 3 months ago - 1 comment

#1319 - Fixes #1318 Adds documentation about auto commit behaviour

Pull Request - State: closed - Opened by ashwinbhaskar 3 months ago - 1 comment

#1318 - Documentation for default auto commit behaviour is missing.

Issue - State: closed - Opened by ashwinbhaskar 3 months ago

#1318 - Documentation for default auto commit behaviour is missing.

Issue - State: closed - Opened by ashwinbhaskar 3 months ago

#1317 - Update zio, zio-streams, zio-test, ... to 2.1.9

Pull Request - State: closed - Opened by zio-scala-steward[bot] 3 months ago

#1317 - Update zio, zio-streams, zio-test, ... to 2.1.9

Pull Request - State: closed - Opened by zio-scala-steward[bot] 3 months ago

#1316 - Update zio-streams, zio-test-sbt to 2.1.8

Pull Request - State: closed - Opened by zio-scala-steward[bot] 3 months ago

#1315 - Use AtomicInteger instead of AtomicLong inside Producer.sendFromQueue implementation

Pull Request - State: closed - Opened by ytalashko 3 months ago

#1315 - Use AtomicInteger instead of AtomicLong inside Producer.sendFromQueue implementation

Pull Request - State: closed - Opened by ytalashko 3 months ago

#1314 - Produce sequentially and in parallel in benchmark

Pull Request - State: closed - Opened by erikvanoosten 3 months ago

#1313 - Update to Kafka 3.8.0

Pull Request - State: closed - Opened by erikvanoosten 3 months ago - 1 comment

#1313 - Update to Kafka 3.8.0

Pull Request - State: closed - Opened by erikvanoosten 3 months ago - 1 comment

#1312 - Update zio, zio-streams, zio-test, ... to 2.1.8

Pull Request - State: closed - Opened by zio-scala-steward[bot] 3 months ago

#1312 - Update zio, zio-streams, zio-test, ... to 2.1.8

Pull Request - State: closed - Opened by zio-scala-steward[bot] 3 months ago

#1311 - Alternative producer implementation (again)

Pull Request - State: closed - Opened by erikvanoosten 3 months ago - 9 comments

#1311 - Alternative producer implementation (again)

Pull Request - State: closed - Opened by erikvanoosten 3 months ago - 9 comments

#1310 - Simple producer benchmark

Pull Request - State: closed - Opened by svroonland 3 months ago - 4 comments

#1309 - Update README.md

Pull Request - State: closed - Opened by zio-assistant[bot] 3 months ago

#1309 - Update README.md

Pull Request - State: closed - Opened by zio-assistant[bot] 3 months ago

#1308 - Update README.md

Pull Request - State: closed - Opened by zio-assistant[bot] 3 months ago

#1308 - Update README.md

Pull Request - State: closed - Opened by zio-assistant[bot] 3 months ago

#1307 - Update zio-logging-slf4j, ... to 2.3.1

Pull Request - State: closed - Opened by zio-scala-steward[bot] 3 months ago

#1307 - Update zio-logging-slf4j, ... to 2.3.1

Pull Request - State: closed - Opened by zio-scala-steward[bot] 3 months ago

#1306 - Update zio-kafka, zio-kafka-testkit to 2.8.2

Pull Request - State: closed - Opened by zio-scala-steward[bot] 3 months ago

#1304 - Revert back to 2.8.0 sendFromQueue implementation in producer

Pull Request - State: closed - Opened by ytalashko 3 months ago - 9 comments

#1303 - Update embedded-kafka to 3.8.0

Pull Request - State: closed - Opened by zio-scala-steward[bot] 3 months ago - 1 comment

#1296 - Update sbt-mima-plugin to 1.1.4

Pull Request - State: closed - Opened by zio-scala-steward[bot] 3 months ago

#1293 - Update sbt-native-packager to 1.10.4

Pull Request - State: closed - Opened by zio-scala-steward[bot] 4 months ago

#1293 - Update sbt-native-packager to 1.10.4

Pull Request - State: closed - Opened by zio-scala-steward[bot] 4 months ago

#1292 - Update kafka-clients to 3.8.0

Pull Request - State: closed - Opened by zio-scala-steward[bot] 4 months ago - 2 comments

#1288 - Consumer doesn't consume after `onLost`

Issue - State: closed - Opened by ya-at 4 months ago - 9 comments

#1287 - Alive checks

Pull Request - State: closed - Opened by domdorn 4 months ago - 4 comments

#1287 - Alive checks

Pull Request - State: closed - Opened by domdorn 4 months ago - 4 comments

#1282 - Bump scala-steward-org/scala-steward-action from 2.65.0 to 2.66.0

Pull Request - State: closed - Opened by dependabot[bot] 4 months ago - 1 comment
Labels: dependency-update

#1282 - Bump scala-steward-org/scala-steward-action from 2.65.0 to 2.66.0

Pull Request - State: closed - Opened by dependabot[bot] 4 months ago - 1 comment
Labels: dependency-update

#1276 - FromJavaConsumer: how to synchronize access to the java consumer

Issue - State: closed - Opened by tnielens 4 months ago - 5 comments

#1264 - Prevent compatibility problems without increasing minor version

Issue - State: closed - Opened by erikvanoosten 5 months ago - 1 comment

#1262 - Runaway stream when `max.poll.interval.ms` is exceeded

Issue - State: closed - Opened by myazinn 5 months ago - 6 comments

#1262 - Runaway stream when `max.poll.interval.ms` is exceeded

Issue - State: open - Opened by myazinn 5 months ago - 6 comments

#1258 - Document that the consumer stream fails when exception occurs in user code

Issue - State: open - Opened by svroonland 5 months ago

#1251 - Allow stream to be interrupted when there is no traffic

Pull Request - State: closed - Opened by erikvanoosten 5 months ago - 1 comment

#1250 - Partition lost not recovering, possible issue with `RunLoop`

Issue - State: closed - Opened by josdirksen 5 months ago - 2 comments

#1250 - Partition lost not recovering, possible issue with `RunLoop`

Issue - State: closed - Opened by josdirksen 5 months ago - 2 comments

#1238 - ConcurrentModificationException in the release effect

Issue - State: closed - Opened by TobiasPfeifer 6 months ago - 9 comments

#1233 - Consumer not reconnecting on lost session on proxy connectivity

Issue - State: open - Opened by fd8s0 7 months ago - 9 comments

#1233 - Consumer not reconnecting on lost session on proxy connectivity

Issue - State: open - Opened by fd8s0 7 months ago - 9 comments

#1201 - Graceful shutdown of a stream for a single subscription

Pull Request - State: open - Opened by svroonland 8 months ago - 18 comments

#1193 - Possible to use a Scala 3 version of embedded-kafka?

Issue - State: closed - Opened by bbarker 8 months ago - 8 comments

#1132 - Slow (timeout) shutdown and rebalancing with `withRebalanceSafeCommits `

Issue - State: open - Opened by jgordijn 12 months ago - 14 comments

#1132 - Slow (timeout) shutdown and rebalancing with `withRebalanceSafeCommits `

Issue - State: open - Opened by jgordijn 12 months ago - 14 comments

#1042 - [POC - 3] New commit interface

Pull Request - State: closed - Opened by guizmaii about 1 year ago - 1 comment

#1039 - Producer and consumer diagnostics

Issue - State: open - Opened by soujiro32167 about 1 year ago - 7 comments

#1039 - Producer and consumer diagnostics

Issue - State: open - Opened by soujiro32167 about 1 year ago - 7 comments

#1011 - Create Consumer and Producer from existing apache kafka Consumer/Producer

Pull Request - State: closed - Opened by svroonland over 1 year ago

#1011 - Create Consumer and Producer from existing apache kafka Consumer/Producer

Pull Request - State: closed - Opened by svroonland over 1 year ago

#987 - BindExceptions when testing multi-module projects using ZIO Kafka Testkit

Issue - State: open - Opened by mattdavpir over 1 year ago - 9 comments

#987 - BindExceptions when testing multi-module projects using ZIO Kafka Testkit

Issue - State: open - Opened by mattdavpir over 1 year ago - 9 comments

#986 - Fix: Runloop might be suspended when assigned with many partitions

Pull Request - State: closed - Opened by yaarix over 1 year ago - 7 comments

#970 - Add experimental alternative fetch strategies

Pull Request - State: closed - Opened by erikvanoosten over 1 year ago - 3 comments

#890 - Reproducer for #852

Pull Request - State: closed - Opened by guizmaii over 1 year ago - 1 comment

#865 - [Internal] Fix tests logging configuration

Pull Request - State: closed - Opened by guizmaii over 1 year ago

#864 - Put `Hub` back

Pull Request - State: closed - Opened by guizmaii over 1 year ago

#863 - [WIP] Remove `Hub`

Pull Request - State: closed - Opened by guizmaii over 1 year ago

#862 - WIP

Pull Request - State: closed - Opened by guizmaii over 1 year ago

#861 - [Internal] Simplify `Diagnostics` interface

Pull Request - State: closed - Opened by guizmaii over 1 year ago

#860 - [WIP] Fix race condition spotted thanks to the `ConsumerSpec` "running streams don't stall after a poll timeout" test and its logs in DEBUG mode

Pull Request - State: closed - Opened by guizmaii over 1 year ago

#845 - Rename the `zio-kafka-test-utils` module to `zio-kafka-testkit` && change its base package from `zio.kafka` to `zio.kafka.testkit`

Pull Request - State: closed - Opened by guizmaii over 1 year ago - 1 comment

GitHub / zio/zio-kafka issues and pull requests