solveretur

@Setter
@Accessors(chain = true)
@Slf4j
final class MyStreamBuilder {

    private StreamsBuilder streamsBuilder;
    private MyService myService;

    KStream<String, MyDataUpdate> build() {
        final KStream<String, MyDataUpdate> stream = streamsBuilder.stream(Topics.INPUT);