个人空间 - OSCHINA - 中文开源技术交流社区

连击天

fork: star:

加载中

最近在排查一个sparkstreaming在操作kafka时，rebalance触发了一个异常引起任务失败，而组内小伙伴对消费者组的一些基本知识不是很了解，所以抽了些时间进行相关原理的整理。本文就来聊聊相关...

kafka fetch support 消息推送 zookeeper sticky topic leader broker rebalance groupcoordinator

2023/01/13 23:51

894

最近排查kafka的问题，涉及到了kafka的消息存储，本文就相关内容进行总结。我们都知道，topic是有分区（partition）的概念的，生产者往同一个topic发送的消息最终是发送到了不同的分区里面...

segment kafka index support magic epoch loglog topic leader partition broker batch recordcount dirs

2023/01/03 23:22

684

没有更多内容

加载失败，请刷新页面

没有更多内容

©OSCHINA(OSChina.NET)

工信部

开源软件推进联盟

指定官方社区

社区规范

北京奥思研工智能科技有限公司版权所有

京ICP备2025119063号

顶部