本应Kafka一秒推送一次数据，java这边一秒计算入库一次。可是发现如果有延迟，Kafka一秒钟推送了两次数据，大批量的数据下，java计算数据存在个别误差，请问java这边该怎么处理。双十一大屏滚动这种。
1条回答 默认 最新
- 2022-05-06 15:53die_job的博客 文章目录一、kafka API简介二、引入kafka java客户端依赖三、发送消息 ...Connect API 用来实现连接器，持续的从数据源或应用程序推送数据到kafka，或从kafka中拉取数据。 AdminClient API用来管理
- 2025-07-18 17:54大雨淅淅的博客 Kafka是一个高性能分布式流处理平台，主要用于实时数据处理。本文系统介绍了Kafka的核心概念、安装配置、使用方法和企业应用案例。Kafka通过主题(Topic)、分区(Partition)和副本(Replica)机制实现高吞吐量和可靠性，...
- 2024-12-27 17:20正在绘制中的博客 整理java重要面试名词
- 2023-02-28 20:17Generalzy的博客 Kafka传统定义： Kafka是一个分布式的基于发布/订阅模式的...Kafka最新定义：Kafka是一个开源的分布式事件流平台（Event Streaming Platform），被数千家公司用于高性能的数据管道、流分析、数据集成和关键任务应用。
- 2021-03-25 10:37Java程序员廖志伟的博客 HashMap底层原理，扩容机制，jdk8以后会使用红黑树优化？红黑树和二叉平衡树的区别，...HashMap是Map的一个实现类，它是以键值对存储数据的，Key-Value都是Map.Entry中的属性。当我们向HashMap中存放一个元素(k1,v1)
- 2024-01-25 01:01存在morning的博客 从Kafka的基本定义和应用场景等说起Kafka 是一个分布式流式处理平台，它被设计用于构建实时的数据管道和流应用程序。Kafka 主要用于处理高吞吐量的数据流，并支持容错处理。流平台具有三个关键功能：Kafka 主要有两...
- 2019-03-22 10:20- **Git+Jenkins实现自动化构建**：使用Git推送代码触发Jenkins构建流程。 **7.3 NoSQL专题-Redis高性能缓存** - **Redis使用入门**：了解Redis的基本特性和使用方法。 - **Redis高可用集群搭建**：搭建Redis集群...
- 2022-05-23 09:33000X000的博客 Kafka 万亿级消息实践之资源组流量掉零故障排查分析
- 2022-10-06 10:19各个方面都自在的博客 1 ：人脸识别系统被调失败，导致图片上传失败 2 ：延迟高，需要人脸识别系统处理完成后，再返回给客户端，即使用户并不需要立即知道结果 3 ：图片上传系统与人脸识别系统之间互相调用，需要做耦合192.168 .164.11 ...
- 2025-05-08 17:41敲代码的乐悠的博客 Kafka万字详解
- 没有解决我的问题, 去提问
