Changed to latest KIP-470 changes

jukkakarvanen · Oct 19, 2019 · da6e5ac · da6e5ac
1 parent c3513f5
commit da6e5ac
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/pom.xml b/pom.xml
@@ -221,10 +221,10 @@
             <scope>test</scope>
         </dependency>
         <dependency>
-            <!-- This is needed until KIP-470 included to kafka-streams-test-utils -->
+            <!-- This is needed until KIP-470 included to kafka-streams-test-utils with Kafka 2.4.0-->
             <groupId>com.github.jukkakarvanen</groupId>
             <artifactId>kafka-streams-test-topics</artifactId>
-            <version>0.0.1-beta3</version>
+            <version>1.0.0</version>
             <scope>test</scope>
         </dependency>
         <dependency>

diff --git a/src/test/java/io/confluent/examples/streams/WordCountLambdaExampleTest.java b/src/test/java/io/confluent/examples/streams/WordCountLambdaExampleTest.java
@@ -17,11 +17,11 @@
 import com.github.jukkakarvanen.kafka.streams.test.TestInputTopic;
 import com.github.jukkakarvanen.kafka.streams.test.TestOutputTopic;
 import com.github.jukkakarvanen.kafka.streams.test.TopologyTestDriver;
-import org.apache.kafka.clients.producer.ProducerRecord;
-import org.apache.kafka.common.serialization.Serdes;
+import org.apache.kafka.common.serialization.StringDeserializer;
+import org.apache.kafka.common.serialization.StringSerializer;
+import org.apache.kafka.common.serialization.LongDeserializer;
 import org.apache.kafka.streams.KeyValue;
 import org.apache.kafka.streams.StreamsBuilder;
-import org.apache.kafka.streams.test.OutputVerifier;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
@@ -50,8 +50,8 @@ public void setup() {
     //Create Actual Stream Processing pipeline
     WordCountLambdaExample.createWordCountStream(builder);
     testDriver = new TopologyTestDriver(builder.build(), WordCountLambdaExample.getStreamsConfiguration("localhost:9092"));
-    inputTopic = testDriver.createInputTopic(WordCountLambdaExample.inputTopic, new Serdes.StringSerde(), new Serdes.StringSerde());
-    outputTopic = testDriver.createOutputTopic(WordCountLambdaExample.outputTopic, new Serdes.StringSerde(), new Serdes.LongSerde());
+    inputTopic = testDriver.createInputTopic(WordCountLambdaExample.inputTopic, new StringSerializer(), new StringSerializer());
+    outputTopic = testDriver.createOutputTopic(WordCountLambdaExample.outputTopic, new StringDeserializer(), new LongDeserializer());
   }
 
   @After