1.90版本的Flinksql相关使用问题

[往事Ψ随风]

关于FlinkSQL的相关问题：

1、请问使用Flink1.90版本的sql实现从Kafka读取数据，统计，输出数据到Kafka，数据格式是以csv形式的，kafka的format那块请问怎么写?

报错如下：

Caused by: org.apache.flink.table.api.ValidationException: Could not map the schema field 'fruit' to a field from source. Please specify the source field from which it can be derived.

请问format那块该怎么写才对? 谢谢！