@Override
  public KeyValue<KOutT, GenericRow> transform(final KInT key, final GenericRow value) {
    return KeyValue.pair(
        keyDelegate.transform(
            key,
            value,
            context.orElseThrow(() -> new IllegalStateException("Not initialized"))
        ),
        valueDelegate.transform(
            key,
            value,
            context.orElseThrow(() -> new IllegalStateException("Not initialized"))
        )
    );
  }
@Test
  public void shouldInvokeInnerTransformers() {
    // When:
    ksTransformer.transform(KEY, VALUE);

    // Then:
    verify(ksqlKeyTransformer).transform(
        eq(KEY),
        eq(VALUE),
        any()
    );
    verify(ksqlValueTransformer).transform(
        eq(KEY),
        eq(VALUE),
        any()
    );
  }