we are using avrodata.toConnectData(schema(has logical types),record)method , the returned object SchemaAndvalue has logical types (decimal,date,timestamp) decimal is converting from bytes to decimal value and int converting to date but long is not converting to timestamp ,also while writing to S3 in parquet format using ‘io.confluent.connect.s3.format.parquet.ParquetFormat’, date field is writing as int not as date(which was converted) and and long writing as long. what could be the reason. help is really appreciable.
This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.