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

开发者社区> 问答> 正文

flink 注册kafka得csv格式

2018-11-01 20:41:59 4752 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
添加回答
相关问答

5

回答

Spark 【问答合集】

社区小助手 2019-05-29 14:13:40 129522浏览量 回答数 5

37

回答

ISV接入钉钉详细示例以及代码(JAVA版本)  --服务窗代码部分放出

蛋蛋oo蛋蛋 2016-08-13 16:22:00 56090浏览量 回答数 37

17

回答

【精品问答】Java技术1000问(1)

问问小秘 2019-11-15 11:24:15 58394浏览量 回答数 17

38

回答

阿里官方Java代码规范标准《阿里巴巴Java开发手册》下载

管理贝贝 2017-02-10 15:14:36 79472浏览量 回答数 38

3

回答

Kafka、ActiveMQ、RabbitMQ、RocketMQ的区别?【Java问答学堂】19期

剑曼红尘 2020-05-15 11:24:19 37187浏览量 回答数 3

1

回答

在flink集群模式下,能不能指定某个节点的solt来执行一个task?

孙goku 2019-07-01 15:19:09 116625浏览量 回答数 1

8

回答

flink sql 支持checkpoints吗?

游客izljdlkgbdwfc 2019-07-10 17:46:37 125695浏览量 回答数 8

11

回答

一小时入门阿里云IoT套件

三野 2016-11-18 11:37:24 33718浏览量 回答数 11

2

回答

Apache Flink常见问题汇总【精品问答】

黄一刀 2020-05-19 17:51:47 51081浏览量 回答数 2

56

回答

Flink Forward Asia 2021 有奖问答

阿里云实时计算Flink 2021-12-29 17:30:44 468612浏览量 回答数 56
+关注
0
文章
2
问答
问答排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载