本应Kafka一秒推送一次数据，java这边一秒计算入库一次。可是发现如果有延迟，Kafka一秒钟推送了两次数据，大批量的数据下，java计算数据存在个别误差，请问java这边该怎么处理。双十一大屏滚动这种。
1条回答
- 2022-02-16 19:32回答 4 已采纳 重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
- 2021-09-14 10:43回答 3 已采纳 先不论用什么来实现，我们先评估业务。 1、你用消息，你要明白，你这个消息，消费的时候需要不需要回复已已消费？2、你能不能重复消费消息？3、如果消息丢失了怎么办？4、另外，这些消息是怎么一个消费规律？一
- 2021-04-20 10:49回答 3 已采纳 https://gewu.pcwanli.com/front/article/10619.html
- 2022-05-06 15:53die_job的博客 文章目录一、kafka API简介二、引入kafka java客户端依赖三、发送消息 ...Connect API 用来实现连接器，持续的从数据源或应用程序推送数据到kafka，或从kafka中拉取数据。 AdminClient API用来管理
- 2022-12-21 00:45回答 1 已采纳 这篇博客也许可以解决你的问题👉 ：kafka消费者从kafka读取信息
- 2022-08-23 10:01回答 1 已采纳 同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
- 2021-07-22 08:54回答 4 已采纳 用@Scheduledhttps://blog.csdn.net/limingcai168/article/details/103394041
- 2021-03-25 10:37Java程序员廖志伟的博客 HashMap底层原理，扩容机制，jdk8以后会使用红黑树优化？红黑树和二叉平衡树的区别，...HashMap是Map的一个实现类，它是以键值对存储数据的，Key-Value都是Map.Entry中的属性。当我们向HashMap中存放一个元素(k1,v1)
- 2021-08-16 15:59回答 1 已采纳 应该可以，不过通常使用scala语言进行编写
- 2021-07-27 10:36回答 1 已采纳 kafka调用send方法发送数据后 会返回一个ListenableFuture 这个ListenableFuture可以添加callback进行监听d
- 2022-10-25 09:26回答 5 已采纳 感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
- 2024-01-25 01:01存在morning的博客 从Kafka的基本定义和应用场景等说起Kafka 是一个分布式流式处理平台，它被设计用于构建实时的数据管道和流应用程序。Kafka 主要用于处理高吞吐量的数据流，并支持容错处理。流平台具有三个关键功能：Kafka 主要有两...
- 2023-02-02 16:54回答 4 已采纳 ''该回答引用ChatGPT''如对你的问题有帮助，请点击右侧采纳即可！没有使用ZooKeeper的话，一种可行的方案是利用ClickHouse的复制功能实现双机数据同步。ClickHouse的复制功
- 2022-05-23 09:33000X000的博客 Kafka 万亿级消息实践之资源组流量掉零故障排查分析
- 2022-10-24 10:26xushiyu1996818的博客 可以通过实现 org.apache.kafka.clients.consumer.internals.PartitionAssignor 接口来实现。
- 没有解决我的问题, 去提问
