From 9b0eabf8f210ed8b1f74ee5a8e48a0bcec930c79 Mon Sep 17 00:00:00 2001
From: Philipp Schirmer <philipp.schirmer@bakdata.com>
Date: Thu, 4 Apr 2024 12:36:54 +0200
Subject: [PATCH] Create v3

---
 .../com/bakdata/kafka/integration/RunProducerAppTest.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/RunProducerAppTest.java b/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/RunProducerAppTest.java
index 18721ce4..70357e57 100644
--- a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/RunProducerAppTest.java
+++ b/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/RunProducerAppTest.java
@@ -42,7 +42,7 @@
 import net.mguenther.kafka.junit.ReadKeyValues;
 import net.mguenther.kafka.junit.TopicConfig;
 import org.apache.kafka.clients.consumer.ConsumerConfig;
-import org.apache.kafka.clients.producer.KafkaProducer;
+import org.apache.kafka.clients.producer.Producer;
 import org.apache.kafka.clients.producer.ProducerConfig;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.StringDeserializer;
@@ -72,7 +72,7 @@ void shouldRunApp() throws InterruptedException {
         final KafkaProducerApplication app = new SimpleKafkaProducerApplication(() -> new ProducerApp() {
             @Override
             public void run(final ProducerBuilder builder) {
-                try (final KafkaProducer<String, TestRecord> producer = builder.createProducer()) {
+                try (final Producer<String, TestRecord> producer = builder.createProducer()) {
                     final TestRecord record = TestRecord.newBuilder().setContent("bar").build();
                     producer.send(new ProducerRecord<>(builder.getTopics().getOutputTopic(), "foo", record));
                 }