Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
We should add a RFC 4180 compliant CSV table format factory to read and write data into Kafka and other connectors. This requires a SerializationSchemaFactory and DeserializationSchemaFactory. How we want to represent all data types and nested types is still up for discussion. For example, we could flatten and deflatten nested types as it is done here. We can also have a look how tools such as the Avro to CSV tool perform the conversion.