Felix Krull

NullPointerException in MigrationScriptReaderImpl

2

When running tests that internally use ElasticsearchEvolutions (to set up indices for an integration test) with sbt, I get a NullPointerException while loading the migration scripts: ``` [info] java.lang.NullPointerException: [info]...

When comparing the local migration scripts with the record of already the executed scripts, the library should be able to detect if an already-executed script was modified afterwards, and raise...

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

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

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.

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