用finksql查询kafka的数据做count(distinct id),汇总的数据少了怎么回事

用finksql查询kafka的数据做count(distinct id),汇总的数据少了。有人遇到过吗?

blink 版本 消费kafka 看不到group id

现象 使用这个pom ,在kafka 里看不到group id com.alibaba.blink flink-streaming-scala_2.11 blink-3.2.2 org.slf4j slf4j-api ...

消息队列Kafka入门课程

4 课时 |
3098 人已学 |
免费

分布式消息系统 Kafka 快速入门

24 课时 |
640 人已学 |
免费
开发者课程背景图

kafka部署出现The VSwitch ID are not valid.

求助! kafka VPC实例部署时输入vpc信息点部署提示: The VSwitch ID are not valid. 但是我已经有一个专有网络了 如图: 

kafka的topic和分区策略——log entry和消息id索引文件

Topic在逻辑上可以被认为是一个在的queue,每条消费都必须指定它的topic,可以简单理解为必须指明把这条消息放进哪个queue里。 为了使得Kafka的吞吐率可以水平扩展,物理上把topic分成一个或多个partition,每个partition在物理上对应一个文件夹,该文件 夹下存储这个p...

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

社区圈子

消息队列
消息队列
消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。
20+人已加入
加入
相关电子书
更多
任庆盛|Flink CDC + Kafka 加速业务实时化
消息队列 Kafka 版差异化特性
2019大数据技术公开课第五季—kafka 数据如何同步到 MaxCompute
立即下载 立即下载 立即下载