你好，我是胡夕。今天我要和你讨论的主题是：Kafka的动态Broker参数配置。 什么是动态Broker参数配置？在开始今天的分享之前，我们先来复习一下设置Kafka参数，特别是Broker端参数的方法。 在Kafka安装目录的config路径下，有...

你好，我是胡夕。今天我想和你讨论一下Kafka中的主题管理，包括日常的主题管理、特殊主题的管理与运维以及常见的主题错误处理。 主题日常管理所谓的日常管理，无非就是主题的增删改查。你可能会觉得，这有什么好讨论的，官网上不都有命令吗？这部分内容的确比较简...

你好，我是胡夕。今天我要和你分享的主题是：Kafka中的高水位和Leader Epoch机制。 你可能听说过高水位（High Watermark），但不一定耳闻过Leader Epoch。前者是Kafka中非常重要的概念，而后者是社区在0.11版本中...

你好，我是胡夕。今天我要和你分享的主题是：Kafka中的控制器组件。 控制器组件（Controller），是Apache Kafka的核心组件。它的主要作用是在Apache ZooKeeper的帮助下管理和协调整个Kafka集群。集群中任意一台Bro...

你好，我是胡夕。今天我要和你分享的主题是：消费者组重平衡全流程解析。 之前我们聊到过消费者组的重平衡流程，它的作用是让组内所有的消费者实例就消费哪些主题分区达成一致。重平衡需要借助Kafka Broker端的Coordinator组件，在Coordi...