flink消费kafka里面的json数据 并统计出UV和PV 数据大概是一个id和time时间的json数据
已经做到连接kafka的数据 但不会解析json数据
flink消费kafka里面的json数据
- 写回答
- 好问题 0 提建议
- 关注问题
分享- 邀请回答
-
0条回答 默认 最新
- 2024-10-27 16:14小码农叔叔的博客 Flink + Kafka 实现通用流式数据处理详解
- 2023-03-21 00:01DanceDonkey的博客 消费flink计算后的数据，进行进一步存储或者计算等。
- 2025-02-11 14:13图苑的博客 这些传感器每秒钟都会产生大量的数据点，并通过网络实时发送到一个中心位置进行处理。我们的目标是构建一个系统，能够迅速地分析这些数据，计算出关键指标是否超出了预设的安全阈值，如果确实超过了，则立即发出警报...
- 2021-01-12 17:00weixin_42299310的博客 上篇博客写了Flink接入Kafka数据并实时写入数据库实时展示，这次利用Flink CEP进行实时监控。整体架构图如下:image实现目标如下：1.查看顾客是否点击之后立即购买，是的话输出用户id，购买商品，时间2.如果同一个...
- 2025-12-29 02:26SuperAGI架构师的AI实验室的博客 （Kafka解决）数据计算：如何精准处理有状态的实时流？（Flink解决）语义保证：如何确保数据处理的Exactly-Once？（Flink+Kafka协同解决）资源管理：如何平衡计算资源与处理性能？（架构设计与调优解决）
- 2021-12-09 01:02wudl5566的博客 通过flink 从kafka 中获取到数据， 然后在sink 到hbase 中 数据结构 {"address":"深圳","age":20,"createTime":"2021-12-08 22:30","id":1,"name":"hdfs"} 2.Hbase 建表 hbase(main):002:0> create 'wudluser',...
- 2025-09-05 09:45风亦辰739的博客 本文搭建了一个完整的实时大数据项目数据采集：Kafka实时计算：Flink存储分析：ClickHouse可视化：ECharts 大屏通过该项目，读者可以掌握实时数仓与大屏分析的核心思路。在实践中，可以继续扩展到多维度指标监控、...
- 2023-08-04 10:48青春不流名的博客 avro已avro格式保存数据到kafka 2.1.5、部署spring-boot的flink-do-doris 2.1.5.1、flink-do-doris主类 三、效果验证 3.1、发送syslog日志，syslog-kafka-es-avro监听处理，存储到kafka 3.2 、查看flink消费kafka ...
- 2025-10-29 00:41AI软件工程实践的博客 目的：帮你理解Kappa架构的设计思想，掌握用Flink+Kafka搭建实时数据平台的具体步骤，解决“实时数据延迟高”“批流结果不一致”“历史数据重新计算麻烦”的问题。范围：覆盖Kappa架构的核心概念、组件协作、实战...
- 2025-07-03 14:21showker的博客 当前我们仅实现了 DataStream API 风格的 Flink-ClickHouse Sink，随着 Flink 作业 SQL 化的大潮，在未来还计划实现 SQL 风格的 ClickHouse Sink，打磨健壮后会适时回馈给社区。因此，我们采用了一种比较曲折的方法...
- 没有解决我的问题, 去提问
问题事件
系统已结题
12月23日
创建了问题
12月15日