v2.1.0

gradle.properties

@@ -3,7 +3,7 @@ github.repository.name=extra-ktor-plugins
 kotlin.native.cacheKind.linuxX64=none
 kotlin.native.ignoreDisabledTargets=true
 gradle.publish.enable.module-metadata=true
-version=2.0.1
+version=2.1.0
 gpr.user=flaxoos
 org.gradle.jvmargs=-Xmx2g -XX:MaxMetaspaceSize=2g
 kotlin.mpp.applyDefaultHierarchyTemplate=false

ktor-server-kafka/src/jvmTest/kotlin/io/github/flaxoos/ktor/server/plugins/kafka/BaseKafkaIntegrationTest.kt

@@ -42,6 +42,7 @@ import org.apache.kafka.clients.producer.ProducerRecord
 import org.apache.kafka.common.serialization.StringSerializer
 import java.io.File
 import java.util.Properties
+import java.util.concurrent.TimeUnit
 import kotlin.time.Duration
 import kotlin.time.Duration.Companion.milliseconds
 import kotlin.time.Duration.Companion.seconds
@@ -267,7 +268,7 @@ abstract class BaseKafkaIntegrationTest : FunSpec() {
                                 TestRecord(topicIdCounters[topic]?.inc() ?: error("topic not counted"), topic.value)
                             val genericRecord = testRecord.toRecord()
                             val record = ProducerRecord(topic.value, "testKey", genericRecord)
-                            with(call.application.kafkaProducer.shouldNotBeNull()) { send(record) }
+                            with(call.application.kafkaProducer.shouldNotBeNull()) { send(record).get(100, TimeUnit.MILLISECONDS) }
                             logger.debug("Produced record: {}", record)
                             call.respond(testRecord)
                         }