@Test
public void shouldConvertFromConnectData() {

    byte[] bytes = converter.fromConnectData(TOPIC, Schema.BYTES_SCHEMA, ByteBuffer.wrap(SAMPLE_BYTES));
    assertThat(bytes).isEqualTo(SAMPLE_BYTES);
}