svroonland

Graceful shutdown of a single subscription

13

Implements functionality for gracefully stopping a stream for a single subscription: stop fetching records for the assigned topic-partitions but keep being subscribed so that offsets can still be committed. Intended...

Avoid orDie's in transactional producer

1

Because it's in a finalizer, we cannot handle errors and can only use orDie or ignore. Find a way to be able to express these kinds of errors in the...

In eager rebalancing, we get `onRevoked` and `onAssigned` calls in which we can commit in progress messages. But in cooperative rebalancing we may only get `onRevoked`, at which point we...

Leases for shards that have been fully processed (= shard has ended and checkpoint `SHARD_END` is set) should be cleaned periodically. There should be some interval between shard end checkpoint...

Producer throughput regression

2

The latest ZIO 2 compatible release has a Producer throughput regression from about 57K records/s to about 46K records/s in the `ProducerTest` `produce records to Kinesis successfully and efficiently` test....