请问flink cdc 有没有办法,通过sql的方式,将整库的binlog写到kafka呢?
请问flink cdc 有没有办法,通过sql的方式,将整库的binlog写到kafka呢?
请问dataworks odps sql中能创建向kafka中写数据的external外表吗?
请问dataworks odps sql中能创建向kafka中写数据的external外表吗?
Canal同步到Kafka的FlatMessage数据转换成sql语句,是否有现成的工具进行转换
如题,是否有现成的工具进行转换 原提问者GitHub用户young138120
除了kafka,flink 可以将数据写到 RabbitMQ吗?FLINK SQL模式
除了kafka,flink 可以将数据写到 RabbitMQ吗?FLINK SQL模式
有使用过flink sql 消费kafka avro格式的消息吗?怎么指定反序列化啊?
有使用过flink sql 消费kafka avro格式的消息吗?怎么指定反序列化啊?现在不指定反序列化,消费的消息不对 就两个字段 name address 后缀的数字应该是一样的,但是消费到的数据很乱
有使用过flink sql 消费kafka avro格式的消息吗?怎么指定反序列化啊?
有使用过flink sql 消费kafka avro格式的消息吗?怎么指定反序列化啊?现在不指定反序列化,消费的消息不对

kafka sql入门
KSQL,一个用于Apache Kafka流的SQL 引擎。 KSQL降低了流处理的入口,提供了一个简单而完整的交互式SQL接口,用于处理Kafka中的数据。 不再需要编写Java或Python代码! KSQL是开源的(Apache 2.0许可),分布式,可扩展,可靠且实...
flink sql connector kafka报的这个错误怎么解决呀?
flink sql connector kafka报的这个错误怎么解决呀?
我用运行flink sql作业:flink kafka conector->hudi->hive,对
我用运行flink sql作业:flink kafka conector->hudi->hive,对于同一个topic里的数据,为何多次启动这个flink作业,最后hive count出来的数据条数每次都不一样(少于topic里的实际数据量)?
请问如果kafka topic收到与kafka connector sql字段不符的记录,导致fli
请问如果kafka topic收到与kafka connector sql字段不符的记录,导致flink sql作业反序列化报错,该怎么办呢?
更新时间 2023-09-07 03:56:15
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。
社区圈子