关于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 ETLCloud 处理json多层级问题
- ¥15 matlab中使用gurobi时报错
- ¥15 这个主板怎么能扩出一两个sata口
- ¥15 不是，这到底错哪儿了😭
- ¥15 2020长安杯与连接网探
- ¥15 关于#matlab#的问题：在模糊控制器中选出线路信息，在simulink中根据线路信息生成速度时间目标曲线（初速度为20m/s，15秒后减为0的速度时间图像）我想问线路信息是什么
- ¥15 banner广告展示设置多少时间不怎么会消耗用户价值
- ¥16 mybatis的代理对象无法通过@Autowired装填
- ¥15 可见光定位matlab仿真
- ¥15 arduino 四自由度机械臂