关注
码龄
粉丝数
原力等级 --
被采纳
被点赞
采纳率
只吃零食的猫丶
2022-08-29 08:39
采纳率: 0%
浏览 14
首页
后端
已结题
kafka消费不到消息
后端
集群部署下,多个topic,
每个topic对应一个消费组,每个组一个消费者,每个消费组的组ID相同。导致只有三个消费端消费到了消息,其余均没有消费到。
收起
写回答
好问题
0
提建议
关注问题
微信扫一扫
点击复制链接
分享
邀请回答
编辑
收藏
删除
收藏
举报
1
条回答
默认
最新
关注
码龄
粉丝数
原力等级 --
被采纳
被点赞
采纳率
「已注销」
2022-08-29 09:20
关注
重新安装一下kafka
本回答被题主选为最佳回答
, 对您是否有帮助呢?
本回答被专家选为最佳回答
, 对您是否有帮助呢?
本回答被题主和专家选为最佳回答
, 对您是否有帮助呢?
解决
无用
1
评论
打赏
微信扫一扫
点击复制链接
分享
举报
评论
按下Enter换行,Ctrl+Enter发表内容
查看更多回答(0条)
向“C知道”追问
报告相同问题?
提交
关注问题
Kafka
如何保证不重复
消费
2025-05-31 11:24
shangjg3的博客
Kafka
避免
消息
重复
消费
的关键策略:生产者端开启幂等性(单分区)或事务机制(跨分区)防止重复发送;
消费
者端采用手动提交偏移量确保
消息
处理完成后再提交;业务层可添加唯一标识或数据库去重逻辑作为最后保障。这...
【
后端
】
消息
队列--
Kafka
篇
2022-04-02 00:22
curd_boy的博客
parition中的
消息
采用多个小文件段的方式存储,很容易实现
消息
定期清除或删除已经
消费
完的文件。通过索引文件可以快速定位message在日志文件中的位置。索引文件通过Mmap技术直接映射到内存中,这样对索引的操作就不...
基于 Go 的
kafka
消息
消费
者.zip
2025-08-24 20:54
本项目“基于Go的
Kafka
消息
消费
者”主要解决的是如何使用Go语言高效地从
Kafka
集群中
消费
消息
的问题。在该项目中,开发者们通常会利用Go语言的并发特性,结合
Kafka
客户端库来实现
消息
的订阅、
消费
与处理。这些客户端...
kafka
的个人理解
后端
2025-02-27 14:33
萧兮丶的博客
kafka
是一个分布式流处理平台,被设计用于高吞吐量、相对低延迟的实时数据流处理。
kafka
的核心包含Broker、Topic、Partition、Producer、...生产者将
消息
发送到特定的Topic,
消费
者从Topic中读取
消息
。Partition。
SpringBoot项目如何
消费
Kafka
数据
2025-01-13 18:09
布朗克168的博客
springboot项目
消费
Kafka
数据
后端
——springboot+
kafka
定时拉取
消息
(方案二)(批量
消费
、多线程)
2024-10-31 17:36
罗帅·迪克劳纳的博客
物联网系统,使用TDengine+
kafka
存储实时数据,上千台设备每3秒发送过来的数据存储到
kafka
,再从
kafka
拉取
消息
消费
,把数据写入...使用springboot 监听器自动创建
kafka
消费
者,然后通过定时任务控制监听器的启停。
后端
学习 - Zookeeper &
Kafka
2022-11-23 19:30
MONA ODYSSEY的博客
消息
不丢失 (acks = -1) && (replication.factor>=2) && (min.insync.replicas>=2)
Kafka
消息
丢失与重复
消费
的解决方案
2025-03-31 13:14
后端扫地僧的博客
通过上述方法,可以有效减少
Kafka
中
消息
丢失和重复
消费
的问题。在实际应用中,还需要根据具体场景进行调整和优化。希望本文能帮助您更好地理解和解决
Kafka
中的这些常见问题。如果您有其他关于
Kafka
的问题或...
使用
Kafka
保证
消息
不丢失的策略及原理解析
2024-07-13 20:01
喔的嘛呀的博客
综上所述,
消息
队列通过持久化存储、
消息
确认机制、事务机制、数据备份与复制以及
消息
过期机制等手段,保证了
消息
在传递过程中不丢失。在设计分布式系统时,合理选择并配置这些机制可以有效地提高
消息
队列的可靠性和...
Kafka
在
后端
开发中的应用场景是什么?
2024-11-07 08:54
破碎的天堂鸟的博客
Kafka
可以用于异步处理
消息
,使得各个模块之间的处理流程可以独立进行,不需要等待前一个流程完成即可开始下一个流程。:
Kafka
可以替代传统的
消息
代理,用于解耦生产者和
消费
者之间的关系,缓冲未处理的
消息
,并支持...
没有解决我的问题,
去提问
向专家提问
向AI提问
付费问答(悬赏)服务下线公告
◇ 用户帮助中心
◇ 新手如何提问
◇ 奖惩公告
问题事件
关注
码龄
粉丝数
原力等级 --
被采纳
被点赞
采纳率
已结题
(查看结题原因)
5月8日
关注
码龄
粉丝数
原力等级 --
被采纳
被点赞
采纳率
创建了问题
8月29日