Flink数据源问题之自定义如何解决

问题一：请问下flinksql 使用ddl创建kafka数据源，format.type格式支持哪些啊？允许自定义吗？

请问下flinksql 使用ddl创建kafka数据源，format.type格式支持哪些啊？允许自定义吗？ #Flink

参考回答：

json csv，自定义就随意了

关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/296200?spm=a2c6h.14164896.0.0.6cb9d9dfb0yj4F

问题二：flink sql 空闲数据源场景如何配置？

在代码中可以通过 .withIdleness(Duration.ofMinutes(1)); 指定空闲数据源也触发水印，那么sql中怎么表示呢*来自志愿者整理的flink邮件归档

参考回答：

可参考 https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/config/#table-exec-source-idle-timeout

关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/361274?spm=a2c6h.14164896.0.0.6cb9d9dfb0yj4F

问题三：在flink作业中从kafka数据源获取数据，没有获取到oldest数据怎么办？

在flink作业中从kafka数据源获取数据，将 参数设置为'scan.startup.mode' = 'earliest-offset', 检测flink运行结果时，发现只抽取了kafka中的newest数据，没有获取到oldest数据。 不知道是不是我这里'scan.startup.mode' 参数用的不对。*来自志愿者整理的flink邮件归档

参考回答：

建议先不使用flink的Kafka来消费，先自己编码写一个kafka消费看是否还是有这个问题，作个对比，看是否是flink提供的kafka接口的问题。

关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/372552?spm=a2c6h.14164896.0.0.6cb9d9dfb0yj4F

问题四：flink如何读取redis数据并对数据源为kafka的数据进行校验呢？

请问flink如何读取redis数据，并对从kafka接收的数据做处理呢？工作需要将flink从kafka接收到的数据根据redis中的数据做比对，所以需要读取redis中的数据。

关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/271307?spm=a2c6h.14164896.0.0.3088d9dfv2rd2u

问题五：flink能接入开源kafka作数据源吗？

阿里云上的blink能接入开源kafka作数据源吗？#Flink

参考回答：

Kafka 都是对接开源的

关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/317166?spm=a2c6h.14164896.0.0.3088d9dfv2rd2u