@Override
  public Serializer<T> serializer() {
    final Serializer<T> serializer = delegate.serializer();
    return (topic, data) -> serializer.serialize(this.topic, data);
  }
@Test
  public void shouldUseDelegateSerializerWithStaticTopic() {
    // When:
    final byte[] serialized = staticSerde.serializer().serialize(SOURCE_TOPIC, SOME_OBJECT);

    // Then:
    verify(delegateS).serialize(STATIC_TOPIC, SOME_OBJECT);
    assertThat(serialized, is(SOME_BYTES));
    verifyNoMoreInteractions(callback);
  }