@Test
public void bytesToConnect() throws UnsupportedEncodingException {

    ByteBuffer reference = ByteBuffer.wrap("test-string".getBytes("UTF-8"));
    String msg = "{ \"schema\": { \"type\": \"bytes\" }, \"payload\": \"dGVzdC1zdHJpbmc=\" }";
    SchemaAndValue schemaAndValue = converter.toConnectData(TOPIC, msg.getBytes());
    ByteBuffer converted = ByteBuffer.wrap((byte[]) schemaAndValue.value());
    assertEquals(reference, converted);
}