flink 注册kafka得csv格式-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

flink 注册kafka得csv格式

2018-11-01 20:41:59 5037 2

用flink注册kafka得消息源,format选择csv报错,选择avro可以。是不是kafka连接器不支持csv格式。
报错如下:Exception in thread "main" org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.DeserializationSchemaFactory' in
the classpath。

示例代码如下:

tableEnv.connect(
  new Kafka()
    .version("0.11")
      .topic("result_count")
    .property("bootstrap.servers", "**")
)
  .withFormat(
    new Csv().fieldDelimiter(",")
  )
  .withSchema(
    new Schema()
      .field("world", Types.STRING)
      .field("count", Types.INT)
  )
  .inAppendMode()
  .registerTableSource("result_count")
取消 提交回答
全部回答(2)
  • docete
    2019-07-17 23:11:45
    已采纳

    就是现在kafka connector不支持schema是 csv。仅支持 avro和json。
    以后提问能否提供一下flink版本和详细的异常栈信息,便于排查问题。

    0 0
  • 1714427697676270
    2019-07-17 23:11:45

    1

    0 0
添加回答
相关问答

1

回答

Flink 的 kafka 连接器有什么特别的地方呢?

2021-12-08 13:10:26 345浏览量 回答数 1

1

回答

Flink 中的 kafka 连接器有什么特别的地方吗?

2021-12-08 14:25:41 177浏览量 回答数 1

1

回答

Flink 的 kafka 连接器有什么特别的地方呀?

2021-12-08 14:22:08 232浏览量 回答数 1

1

回答

Flink 的 kafka 连接器有什么特别的地方?

2021-12-07 19:49:33 120浏览量 回答数 1

1

回答

flink cdc上游是不是不支持Hbase?

2022-07-09 20:42:01 282浏览量 回答数 1

1

回答

Flink CDC 入湖架构具有哪些优势?

2022-01-19 16:17:13 454浏览量 回答数 1

1

回答

Flink CDC 入湖架构图是什么?

2022-01-19 16:16:32 428浏览量 回答数 1

1

回答

Flink CDC 的上游支持了哪些数据源?

2022-01-19 16:08:57 686浏览量 回答数 1

1

回答

Flink CDC Connectors是什么技术?

2022-01-19 15:39:18 582浏览量 回答数 1

1

回答

Flink CDC connectors方案有哪些优点?

2022-01-19 15:51:23 599浏览量 回答数 1
+关注
0
文章
2
问答
问答排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载