- in = testDriver.createInputTopic(IN, serializer(), serializer());
- out = testDriver.createOutputTopic(OUT, keyDeserializer(), valueDeserializer());
- }
-
+ TestInputTopic<TestInputUser, TestInputWord> in =
+ testDriver.createInputTopic(IN, serializer(), serializer());
+ TestOutputTopic<TestOutputWord, TestOutputWordCounter> out =
+ testDriver.createOutputTopic(OUT, keyDeserializer(), valueDeserializer());