diff --git a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsRunner.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsRunner.java index 3b528c53..ce11a30b 100644 --- a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsRunner.java +++ b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsRunner.java @@ -48,7 +48,6 @@ public final class StreamsRunner implements Runner { /** * Create a {@code StreamsRunner} with default {@link StreamsExecutionOptions} - * * @param topology topology to be executed * @param config streams configuration */ @@ -58,7 +57,6 @@ public StreamsRunner(final @NonNull Topology topology, final @NonNull StreamsCon /** * Create a {@code StreamsRunner} - * * @param topology topology to be executed * @param config streams configuration * @param options options to customize {@link KafkaStreams} behavior @@ -129,4 +127,5 @@ private void awaitStreamsShutdown() { throw new StreamsApplicationException("Error awaiting Streams shutdown", e); } } + }