public synchronized KsqlScalarFunction getFunction(final List<SqlArgument> argTypes) {
    return udfIndex.getFunction(argTypes);
  }
@Test
  public void shouldThrowIfNoVariantFoundThatAcceptsSuppliedParamTypes() {
    // When:
    final Exception e = assertThrows(
        KafkaException.class,
        () -> factory.getFunction(of(SqlArgument.of(STRING), SqlArgument.of(BIGINT)))
    );

    // Then:
    assertThat(e.getMessage(), containsString(
        "Function 'TestFunc' does not accept parameters (STRING, BIGINT)"));
  }