public Command create(
      final ConfiguredStatement<? extends Statement> statement,
      final KsqlExecutionContext context) {
    return create(statement, context.getServiceContext(), context);
  }
@Test
  public void shouldNotRaiseExceptionWhenPrefixIsAdded() {
    configuredStatement = configuredStatement("ALTER SYSTEM 'TEST'='TEST';" , alterSystemProperty);
    when(alterSystemProperty.getPropertyName()).thenReturn("TEST");
    when(alterSystemProperty.getPropertyValue()).thenReturn("TEST");
    when(config.getBoolean(KsqlConfig.KSQL_SHARED_RUNTIME_ENABLED)).thenReturn(true);

    assertThrows(ConfigException.class,
        () -> commandFactory.create(configuredStatement, executionContext));
  }