分类:kafka - 搜索结果 - 查码网

更多分类...
搜索结果

24小时内最新kafka~消费群组如何重新消费

今天遇到一个问题,由于代码问题导致了很多kafka消息入到备用库,偏移量已经变成了最新;如何将偏移量重设到某个时间点,但消费群组重新去消费一次,是解决问题的关键,于是,使用了kafka/bin的sh程

2022-08-03 13:23:45

搜索结果

24小时内最新Kafka学习(三) 主题、分区与副本

主题、分区与副本 基本概念 主题、分区和副本的关系 主题是一个逻辑概念,代表了一类消息,实际工作中我们使用主题来区分业务,而主题之下并不是消息,而是分区,分区是一个物理概念,它是磁盘上的一个目录,目录

2022-07-23 23:20:55

搜索结果

24小时内最新Kafka学习(五) 消息分区

消息分区策略 这里不是说Kafka的主题为什么要分区,而是说在分区的结构下,如何让具有某种特点的消息发送到特定分区。 这里有一个很明显的问题,就是主题分区,那么生产者发送的消息到底被发送到了哪个分区呢

2022-07-23 23:20:48