Merge pull request #184 from nomisRev/renovate/all

Update all dependencies

Author: nomisRev

Diff for: gradle/libs.versions.toml

@@ -1,15 +1,15 @@
 [versions]
-kotest = "5.8.0"
-kafka = "3.6.1"
-kotlin = "1.9.22"
+kotest = "5.8.1"
+kafka = "3.7.0"
+kotlin = "1.9.23"
 kotlinx-coroutines = "1.8.0"
-dokka = "1.9.10"
+dokka = "1.9.20"
 knit = "0.5.0"
 kover = "0.7.6"
-testcontainers-kafka = "1.19.6"
+testcontainers-kafka = "1.19.7"
 slf4j = "2.0.12"
 spotless="6.25.0"
-publish="0.27.0"
+publish="0.28.0"
 power-assert="0.13.0"
 
 [libraries]

Diff for: gradle/wrapper/gradle-wrapper.properties

@@ -1,6 +1,6 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-8.6-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.7-bin.zip
 networkTimeout=10000
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists

Diff for: src/main/kotlin/io/github/nomisRev/kafka/Consumer.kt

@@ -64,7 +64,6 @@ import org.apache.kafka.clients.consumer.ConsumerRecords
 import org.apache.kafka.clients.consumer.KafkaConsumer
 import org.apache.kafka.clients.consumer.OffsetAndMetadata
 import org.apache.kafka.clients.consumer.RangeAssignor
-import org.apache.kafka.clients.consumer.internals.NoOpConsumerRebalanceListener
 import org.apache.kafka.common.metrics.Sensor
 import org.apache.kafka.common.serialization.Deserializer
 import org.apache.kafka.common.TopicPartition
@@ -195,7 +194,7 @@ public fun <K, V> List<ConsumerRecords<K, V>>.offsets(
 public fun <K, V> Flow<KafkaConsumer<K, V>>.subscribeTo(
   name: String,
   dispatcher: CoroutineDispatcher = IO,
-  listener: ConsumerRebalanceListener = NoOpConsumerRebalanceListener(),
+  listener: ConsumerRebalanceListener = NoOpConsumerRebalanceListener,
   timeout: kotlin.time.Duration = 500.milliseconds,
 ): Flow<ConsumerRecord<K, V>> = flatMapConcat { consumer ->
   consumer.subscribeTo(name, dispatcher, listener, timeout)
@@ -212,7 +211,7 @@ public fun <K, V> Flow<KafkaConsumer<K, V>>.subscribeTo(
 public fun <K, V> KafkaConsumer<K, V>.subscribeTo(
   name: String,
   dispatcher: CoroutineDispatcher = IO,
-  listener: ConsumerRebalanceListener = NoOpConsumerRebalanceListener(),
+  listener: ConsumerRebalanceListener = NoOpConsumerRebalanceListener,
   timeout: kotlin.time.Duration = 500.milliseconds,
 ): Flow<ConsumerRecord<K, V>> = flow {
   subscribe(listOf(name), listener)
@@ -365,3 +364,8 @@ public data class ConsumerSettings<K, V>(
     put(EXCLUDE_INTERNAL_TOPICS_CONFIG, excludeInternalTopics)
   }
 }
+
+private object NoOpConsumerRebalanceListener : ConsumerRebalanceListener {
+  override fun onPartitionsRevoked(partitions: MutableCollection<TopicPartition>?) {}
+  override fun onPartitionsAssigned(partitions: MutableCollection<TopicPartition>?) {}
+}

Diff for: src/test/kotlin/io/github/nomisrev/kafka/KafkaSpec.kt

@@ -34,6 +34,7 @@ import org.apache.kafka.common.Metric
 import org.apache.kafka.common.MetricName
 import org.apache.kafka.common.PartitionInfo
 import org.apache.kafka.common.TopicPartition
+import org.apache.kafka.common.Uuid
 import org.apache.kafka.common.serialization.StringDeserializer
 import org.apache.kafka.common.serialization.StringSerializer
 import org.junit.jupiter.api.AfterAll
@@ -295,6 +296,8 @@ abstract class KafkaSpec {
     {
       val producer = KafkaProducer(it.properties(), it.keySerializer, it.valueSerializer)
       object : Producer<String, String> {
+        override fun clientInstanceId(p0: Duration?): Uuid =
+          producer.clientInstanceId(p0)
         override fun close() {}
 
         override fun close(timeout: Duration?) {}