Skip to content

Commit 733db37

Browse files
committed
Small refactor
1 parent b7fd563 commit 733db37

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

kcommand-kafka-transport/src/main/kotlin/io/github/theunic/kcommand/transport/kafka/KafkaStreamsTransportConfig.kt

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,10 +33,8 @@ data class KafkaStreamsTransportConfig<M : Any, TOPIC : Enum<TOPIC>>(
3333
put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.StringSerde::class.java.name)
3434
}
3535

36-
val finalProps = propertiesModifier.invoke(props)
37-
3836
return KafkaStreamsTransportConfig(
39-
streamsProperties = finalProps,
37+
streamsProperties = propertiesModifier.invoke(props),
4038
topicResolver = topicResolver,
4139
inputTopics = inputTopics,
4240
)

0 commit comments

Comments
 (0)