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

开发者社区> 问答> 正文

flink 注册kafka得csv格式

2018-11-01 20:41:59 4940 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 14:25:41 139浏览量 回答数 1

1

回答

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

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

1

回答

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

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

1

回答

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

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

1

回答

如何用 Flink SQL 做简单的数据去重?

2021-12-07 17:22:10 369浏览量 回答数 1

1

回答

请教大神们关于flink-sql中数据赋值问题

2021-12-07 10:53:25 414浏览量 回答数 1

1

回答

flink sql实时计算分位数如何实现

2021-12-06 11:44:19 752浏览量 回答数 1

1

回答

Flink SQL读取复杂JSON格式

2021-12-06 12:16:54 566浏览量 回答数 1

1

回答

Flink SQL 中Format的作用是什么?

2021-11-17 17:55:30 341浏览量 回答数 1

1

回答

Flink SQL都有哪些应用场景?

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