public static <K> KStreamHolder<K> build(
      final KStreamHolder<K> stream,
      final StreamSelectKey<K> selectKey,
      final RuntimeBuildContext buildContext
  ) {
    return build(stream, selectKey, buildContext, PartitionByParamsFactory::build);
  }
@Test
  public void shouldUserMapperInMapCall() {
    // When:
    StreamSelectKeyBuilder
        .build(stream, selectKey, buildContext, paramBuilder);

    // Then:
    verify(kstream).map(mapperCaptor.capture(), any());

    final KeyValueMapper<GenericKey, GenericRow, KeyValue<GenericKey, GenericRow>> result =
        mapperCaptor.getValue();

    // When:
    result.apply(aKey, aValue);

    // Then:
    verify(mapper).apply(aKey, aValue);
  }