@Override
  public Object toKsqlRow(final Schema connectSchema, final Object connectData) {
    if (connectData == null) {
      return null;
    }

    return toKsqlValue(schema, connectSchema, connectData, "");
  }
@Test
  public void shouldReturnTimeType() {
    // Given:
    final ConnectDataTranslator connectToKsqlTranslator = new ConnectDataTranslator(Time.SCHEMA);

    // When:
    final Object row = connectToKsqlTranslator.toKsqlRow(Time.SCHEMA, new Date(100L));

    // Then:
    assertTrue(row instanceof java.sql.Time);
    assertThat(((java.sql.Time) row).getTime(), is(100L));
  }