class AvroDataTranslator implements DataTranslator {

  @Override
  public Object toConnectRow(final Object ksqlData) {
    final Object compatible = replaceSchema(avroCompatibleSchema, ksqlData);
    return innerTranslator.toConnectRow(compatible);
  }

    AvroDataTranslator(
      final Schema schema,
      final String schemaFullName
  );

}