diff --git a/vividus-plugin-kafka/src/main/java/org/vividus/steps/kafka/KafkaSteps.java b/vividus-plugin-kafka/src/main/java/org/vividus/steps/kafka/KafkaSteps.java
index 51a4219525..406034d3ba 100644
--- a/vividus-plugin-kafka/src/main/java/org/vividus/steps/kafka/KafkaSteps.java
+++ b/vividus-plugin-kafka/src/main/java/org/vividus/steps/kafka/KafkaSteps.java
@@ -179,7 +179,7 @@ public void sendEvent(String value, String producerKey, String topic)
     public void sendEventWithKey(String key, String value, String producerKey, String topic)
             throws InterruptedException, ExecutionException, TimeoutException
     {
-        ProducerRecord record = new ProducerRecord(topic, 0, 0L, key, value,
+        ProducerRecord<String, String> record = new ProducerRecord<>(topic, null, key, value,
                 testContext.remove(HEADERS_KEY));
         kafkaTemplates.get(producerKey).send(record).get(WAIT_TIMEOUT_IN_MINUTES, TimeUnit.MINUTES);
     }