From d218462b45c5a2fc0a0ea133e2e636e81e404b9d Mon Sep 17 00:00:00 2001 From: Jendrik Poloczek Date: Fri, 10 Aug 2018 16:11:16 +0200 Subject: [PATCH] small refactor changes :lipstick: --- src/main/scala/MockedStreams.scala | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/src/main/scala/MockedStreams.scala b/src/main/scala/MockedStreams.scala index 6c2e1be..0d1cb7a 100644 --- a/src/main/scala/MockedStreams.scala +++ b/src/main/scala/MockedStreams.scala @@ -103,10 +103,7 @@ object MockedStreams { props.put(StreamsConfig.APPLICATION_ID_CONFIG, s"mocked-${UUID.randomUUID().toString}") props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092") props.putAll(configuration) - - val t: () => Topology = topology.getOrElse(throw new NoTopologySpecified) - - new Driver(t(), props) + new Driver(topology.getOrElse(throw new NoTopologySpecified)(), props) } private def produce(driver: Driver): Unit =