kotlin-kafka

kotlin-kafka copied to clipboard

This issue lists Renovate updates and detected dependencies. Read the [Dependency Dashboard](https://docs.renovatebot.com/key-concepts/dashboard/) docs to learn more. ## Edited/Blocked These updates have been manually edited so Renovate will no longer make...

renovate[bot]

nomisRev

defaultCoroutineExceptionHandler probably shouldn't catch kotlin.Error

3

The default CoroutineExceptionHandler in kotlin-kafka currently catches, logs, and then eats every exception that's thrown in background coroutines. Unfortunately, that includes things like OutOfMemoryError and other fatal errors that probably...

felixkrull-neuland

[0.4.0] Regression in receiver

3

When using 0.4.0, the Kafka receiver doesn't correctly connect to the Kafka cluster in certain situations. I've seen this in a test using a Kafka test container: the first test...

felixkrull-neuland

Exceptions are swallowed by KafkaProducer#sendAwait

5

Hi, there is a bug in the [KafkaProducer#sendAwait](https://github.com/nomisRev/kotlin-kafka/blob/main/src/main/kotlin/io/github/nomisRev/kafka/Producer.kt#L85). It checks whether the returned `RecordMetadata` is null and resumes the continuation with the exception if that is the case. But a...

fabiankluempers

Can't use `sendAwait` with Kafka's MockProducer

1

`sendAwait` is defined directly on [KafkaProducer](https://kafka.apache.org/36/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html). This makes it impossible to use with Kafka's own [MockProducer](https://kafka.apache.org/36/javadoc/org/apache/kafka/clients/producer/MockProducer.html). The method should be defined on the [Producer](https://kafka.apache.org/36/javadoc/org/apache/kafka/clients/producer/Producer.html) interface instead.

felixkrull-neuland

ProducerSettings should default to acks=All

1

Kafka's producer defaults to acks=all ([docs](https://kafka.apache.org/documentation.html#producerconfigs_acks)) but this library's ProducerSettings defaults to acks=1. In my opinion, this is an unexpected change in behaviour from Kafka's defaults which is not what...

felixkrull-neuland

nomisRev

Need to investigate how optional dependencies work in Gradle, and if we can include an optional dependency on micrometer to add an implementation for metrics directly in the main module.

nomisRev

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 }...

nomisRev