关于flink接收kafka消息的代码能不能用python写
关于flink接收kafka消息的代码能不能用python写
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
1条回答 默认 最新
- 2021-08-16 15:59回答 1 已采纳 应该可以，不过通常使用scala语言进行编写
- 2022-01-28 09:47回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
- 2021-08-18 11:07回答 2 已采纳 你的包是不是导错了。删除你导入的包，把下面的包复制放你程序中。 import org.apache.flink.api.common.typeinfo.TypeInformation; import
- 2020-12-29 07:31嘿bro的博客 How Apache Flink manages Kafka consumer offsetsStep 1：例子：一个kafka topic，有两个partition，每个含有"A,B,C,D,E"信息。offset从0开始。Step 1Step 2:第二步，kafka consumer开始从partition 0开始读取信息...
- 2021-07-02 11:07回答 2 已采纳 对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说， 你只需要消费下一条就行了。至于偏移量， 你第一次消费的时候，是要发送偏移的，这个你消费者要本地
- 2022-08-26 11:43回答 1 已采纳 不是大小写问题，你的json里面是大写，代码里面是小写，改一下试试
- 2022-07-13 20:33回答 3 已采纳 restclient异常，先看看taskmanager和jobmanager是否正常，然后你可以在jobmanager的节点上访问webUI查看job状态，又或者直接查看宿主机上的日志排查问题
- 2020-12-19 05:02weixin_39802055的博客 flink消费kafka数据，并不是完全通过跟踪kafka消费组的offset来实现去保证exactly-once的语义，而是flink内部去跟踪offset和做checkpoint去实现exactly-once的语义flink与kafka整合，相应版本对于的maven依赖如下表...
- 2019-10-30 14:39回答 1 已采纳 **DEMO** ``` def main(args: Array[String]): Unit = { val env = StreamExecutionEnviron
- 2023-03-07 15:49回答 4 已采纳 Flink 在启动任务的时候，创建输入分片时发生了错误，导致无法启动任务。你需要检查一下程序中读取文件的代码是否正确，文件路径是否正确，文件是否存在，并且当前用户是否有访问该文件的权限。如果需要，可以
- 2021-07-13 21:54回答 1 已采纳 看你用的哪个版本，如果1.11.2以上，flink sql还可以
- 2020-12-19 05:02weixin_39799825的博客 Kafka中的partition机制和Flink的并行度机制结合，实现数据恢复Kafka可以作为Flink的source和sink任务失败，通过设置kafka的offset来恢复应用kafka简单介绍关于kafka，我们会有专题文章介绍，这里简单介绍几个必须...
- 2021-11-16 11:15回答 1 已采纳 或者直接用Java纯代码替代，就是不想要flink这个软件部署下面这个链接讲的很详细，直接改造成spring boot项目https://blog.csdn.net/Vector97/article/
- 2020-12-29 07:30麒麟瑜的博客 在流式处理系统中，Flink和kafka的结合很是经典。我们可以通过Flink消费Kafka数据，层层处理后，丢到Kafka另一个Topic，下游再处理该Topic的数据。而对于OLAP查询需求，我们往往需要将数据输出到 Hive。一般的，我们...
- 2020-12-19 05:02weixin_39528366的博客 Apache Flink是新一代的分布式流式数据处理框架，它统一的处理引擎既可以处理批数据(batch data)也可以处理流式数据...1. 目标本例模拟中将集成Kafka与Flink：Flink实时从Kafka中获取消息，每隔10秒去统计机器当...
- 没有解决我的问题, 去提问
问题事件
系统已结题
8月24日
已采纳回答
8月16日-
创建了问题
8月16日
悬赏问题
- ¥15 c程序不知道为什么得不到结果
- ¥40 复杂的限制性的商函数处理
- ¥15 程序不包含适用于入口点的静态Main方法
- ¥15 素材场景中光线烘焙后灯光失效
- ¥15 请教一下各位，为什么我这个没有实现模拟点击
- ¥15 执行 virtuoso 命令后，界面没有，cadence 启动不起来
- ¥50 comfyui下连接animatediff节点生成视频质量非常差的原因
- ¥20 有关区间dp的问题求解
- ¥15 多电路系统共用电源的串扰问题
- ¥15 slam rangenet++配置