主题

主题操作, sh 脚本(仅总结常用命令)

java 客户端

分区

kafka 为了可靠性, 那么就需要冗余副本. 对于每个分区, 有多个副本, 其中有一个 leader 副本进行读写, 剩下的 follower 副本只管同步数据. 如果 leader 所在 broker 挂掉, 则在其他 broker 的 follower 副本选出 leader. 在我们创建主题时, 会自动的将分区和分区副本平均到 broker 中.