@Override
  public Serde<GenericKey> create(
      final FormatInfo format,
      final PersistenceSchema schema,
      final KsqlConfig ksqlConfig,
      final Supplier<SchemaRegistryClient> schemaRegistryClientFactory,
      final String loggerNamePrefix,
      final ProcessingLogContext processingLogContext,
      final Optional<TrackedCallback> tracker
  ) {
    return createInner(
        format,
        schema,
        ksqlConfig,
        schemaRegistryClientFactory,
        loggerNamePrefix,
        processingLogContext,
        tracker
    );
  }
@Test
  public void shouldReturnLoggingSerdeNonWindowed() {
    // When:
    final Serde<GenericKey> result = factory
        .create(format, schema, config, srClientFactory, LOGGER_PREFIX, processingLogCxt,
            Optional.empty());

    // Then:
    assertThat(result, is(sameInstance(loggingSerde)));
  }