消息中间件-kafka实战-第四章-kafkaUI

参考

消息中间件-kafka实战-第二章-安装
kafka笔记4–安装kafka ui

登录

登录地址：192.168.0.44:8080

这里可以看到在线的kafka实例

主题管理

查看

新建主题

主题命名规则，采用小驼峰的命名规则，比如iotMessagePush
由于度量名称的限制，带有句点（“.”）或下划线（“_”）的主题可能会发生冲突
每个主题最好定义多个多个分区，至少一个备份。
分区数量可以跟结合SpringBoot实例定义或者kafka集群数量定义，比如kafka集群有3个，则分区可以定义三个，分区完全用来物理存储消息。

• 场景1：如果定义三个分区，但是SpringBoot实例只有一个，则这个实例可以消费3个分区；如果SpringBoot启动了两个实例，kafka会自动分配比如实例1消费0分区，实例2消费1,2分区
• 场景2：如果定义1个分区，但是SpringBoot实例有多个，则只会有一个实例可以消费

查看主题详情

查看主题中具体消息

查看每个主题的消费组

消费组

查看消费组消费的主题列表

查看每个消费组中Consumer 信息

可以看到如下，每个主题有三个分区，然后SpringBoot启动了两个实例，则其中一个消费者会消费两个分区

此时，如果再启动一个SpringBoot实例，则三个分区会被分配到三个实例