关注
码龄
粉丝数
原力等级 --
被采纳
被点赞
采纳率
天天一个BUG
2021-01-19 18:52
采纳率: 0%
浏览 8
首页
Java
kafka消费完当前数据后,后面生产的数据无法消费或只消费一小部分
spring
java
大佬们,kafka消费完当前数据后,过了10几秒后生产的数据无法消费或只消费一小部分,请问这个是什么情况,怎么解决,版本0.8.1
收起
写回答
好问题
0
提建议
关注问题
微信扫一扫
点击复制链接
分享
邀请回答
编辑
收藏
删除
结题
收藏
举报
4
条回答
默认
最新
关注
码龄
粉丝数
原力等级 --
被采纳
被点赞
采纳率
纯白微风
2021-01-20 16:53
关注
分区有几个,是不是消费端消费了固定的分区
本回答被题主选为最佳回答
, 对您是否有帮助呢?
本回答被专家选为最佳回答
, 对您是否有帮助呢?
本回答被题主和专家选为最佳回答
, 对您是否有帮助呢?
解决
无用
评论
打赏
微信扫一扫
点击复制链接
分享
举报
评论
按下Enter换行,Ctrl+Enter发表内容
查看更多回答(3条)
向“C知道”追问
报告相同问题?
提交
关注问题
Kafka
丢
数据
、重复
消费
、顺序
消费
的问题
2021-10-27 08:21
Java3y的博客
将消息与DB进行对比,如果发现
数据
不一致,再重新发送消息至主进程处理 候选者:还有部分场景,可能我们只需要把相同userId/orderId发送到相同的partition(因为一个partition由一个Consumer
消费
),又能解决大部分...
kafka
怎么保证
数据
消费
一次且仅
消费
一次?使用消息队列如何保证幂等性?
2021-03-21 11:36
程序员光剑的博客
精确一次处理语义(exactly onece semantic–EOS),
Kafka
的EOS主要体现在3个方面:1)幂等producer 保证单个分区的只会发送一次,不会出现重复消息2)事务(transation):保证原子性的写入多个分区,即写入到多个分区的...
Kafka
(三、
Kafka
消费
者 - 从
Kafka
读取
数据
)
2019-11-07 18:14
都让你们叫老了的博客
Kakfa
消费
者配置 同样由于配置太多,在此不一一列举,只显示使用率最高的几个配置,其他配置请参考官网。 http://
kafka
.apache.org/documentation/#consumerconfigs NAME DESCRIPTION TYPE DEFAULT VALID ...
kafka
发送json
数据
_
Kafka
的
生产
者案例和
消费
者详细解析
2020-11-26 17:09
weixin_39559071的博客
一、
Kafka
的Producer小案例假设我们现在有一个电商系统,凡是能登录系统的用户都是会员,会员的价值体现在,
消费
了多少钱,就会累计相应的积分。积分可以兑换礼品包,优惠券···等等。又到了我们的画图时间?。首先...
07 |
Kafka
消费
消息
2025-06-02 11:46
走过冬季的博客
不过这么做有一个问题,就是每一个
消费
者是独立,那么一个
消费
者就不能
消费
主题中的全部
数据
,简单来讲,就是对于某一个
消费
者个体来讲,主题中的部分
数据
是没有
消费
到的,也就会认为
数据
丢了,这个该如何解决呢?
【大
数据
】Flink +
Kafka
实现通用流式
数据
处理详解
2024-10-27 16:14
小码农叔叔的博客
Flink +
Kafka
实现通用流式
数据
处理详解
kafka
发送json
数据
_
Kafka
的
生产
者案例和
消费
者原理解析—你了解多少?
2020-11-26 17:09
QualcommPolicy的博客
引言一、
Kafka
的Producer小案例假设我们现在有一个电商系统,凡是能登录系统的用户都是会员,会员的价值体现在,
消费
了多少钱,就会累计相应的积分。积分可以兑换礼品包,优惠券···等等。又到了我们的画图时间。...
kafka
消费
者:从
kafka
读取
数据
(性能提升、
JAVA
示例)
2023-01-16 15:45
墨痕诉清风的博客
以第三章中的序列化器示例...在又许多
消费
者和
生产
者共享
数据
访问权限的大型组织中,这可能会非常有挑战性。反序列化器只是颠倒了了序列化器的逻辑,从字节数字中将Customer对象的ID和名称获取出来,重新构造一个对象。
五、
Kafka
生产
者 、
Kafka
消费
者与
kafka
事务
2022-06-09 19:19
努力的布布的博客
1.方便在集群中扩展,提高负载能力,每个 Partition 可以通过调整以适应它所在的机器,而一个 topic又可以有多个 Partition 组成,因此整个集群就可以适应任意大小的
数据
了; 2.可以提高并发读写,因为可以以 ...
高性能
kafka
消费
2024-08-25 20:36
田老师的架构人生的博客
在进行spring-
kafka
消费
的过程中,大部分人可能都遇到过
kafka
消息堆积的情况,尤其是大
数据
处理的场景,这时候就要想办法提高
消费
能力。
没有解决我的问题,
去提问
向专家提问
向AI提问
付费问答(悬赏)服务下线公告
◇ 用户帮助中心
◇ 新手如何提问
◇ 奖惩公告