Simon Vergauwen

We should add a `TransactionManager` with following signatures, but ideally it should work through a Kotlin suspend DSL. Idea: ```kotlin manager.transaction { // abort(), if aborted it doesn't commit }...

```console javax.management.InstanceAlreadyExistsException: kafka.admin.client:type=app-info,id=test-kafka-admin-client at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324) at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522) at org.apache.kafka.common.utils.AppInfoParser.registerAppInfo(AppInfoParser.java:64) at org.apache.kafka.clients.admin.KafkaAdminClient.(KafkaAdminClient.java:602) at org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:544) at org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:488) at org.apache.kafka.clients.admin.Admin.create(Admin.java:134) at io.github.nomisRev.kafka.AdminKt.Admin(Admin.kt:43) at io.github.nomisrev.kafka.KafkaSpec.committedCount(KafkaSpec.kt:154) at...

Users have reported that in some cases you don't want `kotlin-kafka` to automatically pause the partitions in case the downstream cannot process the events fast enough but rather you want...

Attemp to publish alpha.4

3

We updated to using Gradle Maven Publish Plugin, but the `publish` command was not doing anything even though the build was green. Nothing showed up in Sonatype, nor in Maven...

Allow specifying a more concrete Throwable type for retrying

2

Small use-case I came across several times, and I stumbled across it again. This PR allows specifying concrete types for retrying. I.e. ```kotlin Schedule.exponential(...) .and(Schedule.recurs(5)) .doWhile { e: PSQLExeption, _...

Alias for List for Every

3

We've never added an `every()` aliases because we cannot define multiple (in the same package), but I think I am in favor of adding one for `List` now. We can...

Racing DSL

5

This PR proposes a small racing DSL, it comes up several times in discussions and comparison with different ecosystems. Racing and stopping at the first value is desired in many...

Hey @gvolpe, Would love to see Arrow-kt STM here as well 😁 If I find time to contribute this, I will comment on this issue first. https://apidocs.arrow-kt.io/arrow-fx-stm/arrow.fx.stm/index.html

Hey @deusaquilus, Thanks for this great library! I am working with a lot of data, that contains a lot of optional values. Whilst `pprint` is already much better than `toString`,...