@Test
public void shouldConvertToConnectData() {

    SchemaAndValue schemaAndValue = converter.toConnectData(TOPIC, SAMPLE_BYTES);
    assertThat(schemaAndValue.schema()).isEqualTo(Schema.OPTIONAL_BYTES_SCHEMA);
    assertThat(schemaAndValue.value()).isEqualTo(ByteBuffer.wrap(SAMPLE_BYTES));
}