问答 2023-12-01 来自:开发者社区

flniksql(flink版本是1.17)读取kafka的数据,这种问题大家有碰到过不?

flniksql(flink版本是1.17)读取kafka的数据,发现读出来字段都是null,但是原来kafka的字都是有值的,这种问题大家有碰到过不?用streamapi读取整张表字段都正常显示

问答 2023-08-29 来自:开发者社区

flink1.15.4版本在使用Kafka Source时,为什么找不到KafkaSource呢?

1.15.4版本在使用Kafka Source时,引入了flink-connector-base依赖,为什么找不到 KafkaSource呢?

问答 2023-08-20 来自:开发者社区

各位大佬,请教个问题,刚开始用flink1.17.1版本,写入到测试环境自建的kafka,数据能写?

各位大佬,请教个问题,刚开始用flink1.17.1版本,写入到测试环境自建的kafka,数据能写入。写入到阿里云的kafka实例,数据无法写入。之前使用1.13.6往阿里云kafka可以正常写?

问答 2023-08-16 来自:开发者社区

有个问题请教下大家,我这边用的flink版本是1.13.2的,需要对接kafka的数据写入到多张hi

有个问题请教下大家,我这边用的flink版本是1.13.2的,需要对接kafka的数据写入到多张hive数据表,在使用tableapi的时候发现会启动多个job,请问下是否能只启动一个job的情况下写入多张hive数据表? 提交的时候只有一段flink run,但是从接下来的提示及yarn都显示出其实是提交了多个application

问答 2023-08-08 来自:开发者社区

pyflink 1.13.3版本,接受kafka消息,流处理,然后写入数据库

每次接受到kafka消息后,处理结果写入数据库,但是我就想要最后的结果,比如计数,最后结果为20,我只想把最后一条数据写入数据库,而不是要把流处理的整个过程写入数据库。

文章 2023-07-25 来自:开发者社区

springboot 连接 kafka集群(kafka版本 2.13-3.4.0)

一、环境搭建1.1 springboot 环境JDK 11+Maven 3.8.x+springboot 2.5.4 +1.2 kafka 依赖springboot的pom文件导入 <dependency> <groupId>org.springframework.kafka</groupId> &l...

springboot 连接 kafka集群(kafka版本 2.13-3.4.0)
问答 2023-07-13 来自:开发者社区

flink1.13.5 用mongodbcdc使用什么版本的?我就采集mysql中的数据到kafka

flink1.13.5 用mongodbcdc使用什么版本的?我就采集mysql中的数据到kafka,但是在cdh中我没有设置安全认证,是的,但是这个怎么整哦,不知道在哪配置,网上没找到

问答 2023-07-02 来自:开发者社区

有大佬知道 flink-cdc 2.3用的kafka得版本吗?

有大佬知道 flink-cdc 2.3用的kafka得版本吗?

问答 2023-06-29 来自:开发者社区

问一下各位大佬,在使用flinkcdc 同步 oceanbase(企业版本)数据到kafka时,?

问一下各位大佬,在使用flinkcdc 同步 oceanbase(企业版本)数据到kafka时,logproxy.host 参数怎么获取?

问答 2023-06-24 来自:开发者社区

Flink1.17.1版本,连接Kafka,总是报告错误,这个问题怎么解决呀?

Flink1.17.1版本,连接Kafka,总是报告错误,这个问题怎么解决呀?在Flink1.16.1中,可以成功。

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注