From 1f8e5322af3cb81f53832a7adc2635a6bd9cff7e Mon Sep 17 00:00:00 2001
From: Valery Yatsynovich <valery_yatsynovich@epam.com>
Date: Fri, 21 Jun 2024 12:39:34 +0300
Subject: [PATCH] [plugin-kafka] Use default partition and timestamp for
 sending events (#5144)

---
 .../src/main/java/org/vividus/steps/kafka/KafkaSteps.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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);
     }