@Override
  public Object toKsqlRow(final Schema connectSchema, final Object connectObject) {
    final Object avroCompatibleRow = innerTranslator.toKsqlRow(connectSchema, connectObject);
    if (avroCompatibleRow == null) {
      return null;
    }

    return ConnectSchemas.withCompatibleSchema(ksqlSchema, avroCompatibleRow);
  }
@Test
  public void shouldReturnBytes() {
    // When:
    final AvroDataTranslator translator =
        new AvroDataTranslator(Schema.BYTES_SCHEMA, AvroProperties.DEFAULT_AVRO_SCHEMA_FULL_NAME);

    // Then:
    assertThat(
        translator.toKsqlRow(Schema.BYTES_SCHEMA, new byte[] {123}),
        is(ByteBuffer.wrap(new byte[] {123})));
  }