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

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

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

    // Then:
    assertTrue(row instanceof Long);
    assertThat(row, is(100L));
  }