@Override
  public Object toConnectRow(final Object ksqlData) {
    final Object compatible = objectWithSchema(protoCompatibleSchema, ksqlData);
    return innerTranslator.toConnectRow(compatible);
  }
@Test
  public void shouldUseExplicitSchemaName() {
    // Given:
    final Schema schema = SchemaBuilder.struct()
        .field("COLUMN_NAME", Schema.OPTIONAL_INT64_SCHEMA)
        .optional()
        .build();

    final String schemaFullName = "com.custom.schema";

    final ProtobufDataTranslator dataTranslator = new ProtobufDataTranslator(schema, schemaFullName);
    final Struct ksqlRow = new Struct(schema)
        .put("COLUMN_NAME", 123L);

    // When:
    final Struct struct = (Struct)dataTranslator.toConnectRow(ksqlRow);

    // Then:
    assertThat(struct.schema().name(), equalTo(schemaFullName));
  }