关于flink接收kafka消息的代码能不能用python写
1条回答 默认 最新
- 私信
码龄 粉丝数 影响力 0
- 被采纳
- 被点赞
- 采纳率
CSDN专家-微编程 2021-08-16 16:01已采纳 专家已采纳应该可以，不过通常使用scala语言进行编写
采纳该答案 已采纳该答案 专家已采纳该答案赞 踩 打赏 评论
微信扫一扫点击复制链接分享评论登录 后可回复...
报告相同问题？
提交
相关推荐 更多相似问题
- 2021-08-16 15:59回答 1 已采纳 应该可以，不过通常使用scala语言进行编写
- 2021-08-18 11:07回答 2 已采纳 你的包是不是导错了。删除你导入的包，把下面的包复制放你程序中。 import org.apache.flink.api.common.typeinfo.TypeInformation; import
- 2021-07-02 11:07回答 3 已采纳 对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说， 你只需要消费下一条就行了。至于偏移量， 你第一次消费的时候，是要发送偏移的，这个你消费者要本地
- 2020-10-26 14:10codragon的博客 目录Flink接收Kafka和JSON反序列化使用ObjectMapper反序列化接收Kfaka事件消息 Flink接收Kafka和JSON反序列化 使用ObjectMapper反序列化 import com.fasterxml.jackson.core.JsonProcessingException; import ...
- 2020-06-27 18:05dnc8371的博客 flink和kafka区别 介绍 Apache Flink是用于分布式流和批处理数据处理的开源平台。 Flink是具有多个API的流数据流引擎，用于创建面向数据流的应用程序。 Flink应用程序通常使用Apache Kafka进行数据输入和输出。 ...
- 2020-05-30 17:45dnc8371的博客 在元素中添加以下条目： org.apache.flink flink-connector-kafka-0.9_2.10 ${flink.version} 现在，Flink项目已准备就绪，可以通过Kafka连接器使用DataStream，因此您可以从Apache Kafka发送和接收消息。...
- 2021-07-13 21:54回答 1 已采纳 看你用的哪个版本，如果1.11.2以上，flink sql还可以
- 2021-07-08 17:53回答 1 已采纳 你的包导入错了。是这个import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
- 2021-07-05 16:53回答 1 已采纳 value的值为[B@1e1e585b这个明显是序列化后的Bytes字节类型嘛你反序列化成string就ok了
- 2021-03-20 00:17zhisheng_blog的博客 在某些场景中，比如GROUP BY聚合之后的结果，需要去更新之前的结果值。这个时候，需要将 Kafka 消息记录的 key 当成主键处理，用来确定一条数据是应该作为插入、删除还是更新记录来...
- 2020-03-26 11:51王树民的博客 最近有同学留言咨询，Flink消费Kafka的一些问题，今天笔者将用一个小案例来为大家介绍如何将Kafka中的数据，通过Flink任务来消费并存储到HDFS上。 2.内容 这里举个消费Kafka的数据的场景。比如，电商平台、游戏...
- 2019-01-09 20:24weixin_33709609的博客 2019独角兽企业重金招聘Python工程师标准>>> ...
- 2021-07-07 12:51回答 1 已采纳 看报错提示：No match found for function signature instr (, )你是不是用了中文下的逗号。
- 2021-07-04 18:40回答 2 已采纳 如果任务为多个，那么standalone模式下，资源隔离做的较差。
- 2021-09-02 17:59回答 2 已采纳 直接写消费者，行，也是实时计算。区别是spark这种功能比较多，比如多态机器分布部署，容错机制，故障恢复等。所以对于大型系统用spark这种更方便。如果系统的要求没那么高，那肯定是自己写比较方便了。
- 2020-06-26 23:17所念皆山海的博客 根据[3]中开始用flink消费kafka数据,发现啥也么有 调试办法如下: ①去$KAFKA/logs下面看了下,是有相关主题的文件夹生成的. ②/kafka-console-consumer.sh --bootstrap-server Desktop:9091,Laptop:9092,Laptop:...
- 2020-07-31 20:12赶路人儿的博客 flink内置了两种BucketAssigners： DateTimeBucketAssigner : 默认的分桶侧滤，基于系统时间(yyyy-MM-dd--HH)分桶 BasePathBucketAssigner : 不分桶，所有文件写到根目录； 除此之外，还可以实现BucketAssigner...
- 2020-07-19 16:49JasonLee-后厂村程序员的博客 上一篇文章主要介绍了Flink on zeppelin的安装和使用,配置了yarn的模式跑通了一个streaming wordcount的例子,本文主要介绍结合kafka的使用,实时计算...
- 2018-08-09 08:14回答 2 已采纳 自己回复一下 对于flink提交任务时 会将任务对应的jar文件上传至远程主机（如何上传因集群部署方式不同而不同），最终存储到hdfs上，然后taskmanager会去hdfs上下载此文件。 上传文
- 2020-09-13 02:41刘乘九的博客 数据源是从一个多台服务器提供的HA kafka集群中读取，在工作的时候部署了一个简单计算逻辑的flink job到flink服务器上，从kafka执行自带sh命令和查看原始数据文件发现数据都没有问题。但是最终输出的统计结果与真实...
- 没有解决我的问题, 去提问