diff --git a/test-suite-kotlin/src/test/kotlin/io/micronaut/kafka/docs/quickstart/ProductListener.kt b/test-suite-kotlin/src/test/kotlin/io/micronaut/kafka/docs/quickstart/ProductListener.kt
index 01c5da6b4..c1f62d464 100644
--- a/test-suite-kotlin/src/test/kotlin/io/micronaut/kafka/docs/quickstart/ProductListener.kt
+++ b/test-suite-kotlin/src/test/kotlin/io/micronaut/kafka/docs/quickstart/ProductListener.kt
@@ -18,7 +18,7 @@ class ProductListener {
     }
 
     @Topic("my-products") // <2>
-    fun receive(@KafkaKey brand: String?, name: String?) { // <3>
+    fun receive(@KafkaKey brand: String, name: String) { // <3>
         LOG.info("Got Product - {} by {}", name, brand)
     }
 }