public static <T> Serializer<T> serializer() {
    return new InternalTopicSerializer<>();
  }
@Test
  public void shouldUsePlanMapperForSerialize() {
    // When:
    final byte[] serialized = InternalTopicSerdes.serializer().serialize("", EXPRESSION);

    // Then:
    assertThat(new String(serialized, Charsets.UTF_8), equalTo("\"(123 + 456)\""));
  }