Rebalance 本质上是一种协议，规定了一个 Consumer Group 下的所有 Consumer 如何达成一致，来分配订阅 Topic 的每个分区。 在 Rebalance 过程中，所有 Consumer 实例都会停止消费，等待 Rebalance 完成。 Rebalance 的弊端 ...

博主个人独立站点开通啦！欢迎点击访问：https://shuyi.tech 文章首发于【陈树义的博客】，点击跳转到原文《线上Kafka突发rebalance异常，如何快速解决？》 Kafka 是我们最常用的消息队列，它那几万、甚至几十万的处理速度让我们为之欣喜若狂。但是随着使用场景的增加 ...

Kafka 2.6引入的新功能：消费者能够主动触发Rebalance。一直以来，Rebalance的触发都是由Coordinator来执行的，但有些场景下消费者端能够主动触发Rebalance会很有必要。举个例子，在ConsumerPartitionAssignor接口 ...

1、Kafka消息丢失的情况： （1）auto.commit.enable=true，消费端自动提交offersets设置为true，当消费者拉到消息之后，还没有处理完 commit interval 提交间隔就到了，提交了offersets。这时consummer又挂了，重启后，从下 ...

Kafka保证同一consumer group中只有一个consumer会消费某条消息，实际上，Kafka保证的是稳定状态下每一个consumer实例只会消费某一个或多个特定的数据，而某个partition的数据只会被某一个特定的consumer实例所消费。这样设计的劣势 ...

1 Rebalance时机 0.10kafka的rebalance条件 条件1：有新的consumer加入 条件2：旧的consumer挂了 条件3：coordinator挂了，集群选举出新的coordinator（0.10 特有的） 条件4：topic的partition新 ...

kafka 的心跳是 kafka consumer 和 broker 之间的健康检查，只有当 broker coordinator 正常时，consumer 才会发送心跳。 consumer 和 rebalance 相关的 2 个配置参数： broker 端 ...

我个人喜欢把所有引用文件全部放在打包文件src的同级文件static文件内部，方便整合。 提醒：vue项目中正常情况下图片是由 url-loader 处理，加入了hash值，如果放到static里面webpack打包后只会把资源复制到发布目录而不会把小图片优化为base64 ...