public Command create(
      final ConfiguredStatement<? extends Statement> statement,
      final KsqlExecutionContext context) {
    return create(statement, context.getServiceContext(), context);
  }
@Test
  public void shouldThrowIfCommandCanNotBeDeserialized() {
    // Given:
    givenNonDeserializableCommand();

    // When:
    final Exception e = assertThrows(
        KsqlServerException.class,
        () -> commandFactory.create(configuredStatement, executionContext)
    );

    // Then:
    assertThat(e.getMessage(), containsString("Did not write the command to the command topic "
        + "as it could not be deserialized."));
  }