场景描述

Kafka主题监控是指对Kafka消息队列中的主题进行实时监控和分析。

实时消息流监控：监控Kafka主题的消息流量，包括消息的产生速率、消费速率、延迟等指标。这可以帮助管理员了解消息队列的负载情况，及时发现异常或瓶颈。

操作步骤

（1）登录管理控制台。

（2）进入Kafka管理控制台。

（3）在实例列表页在操作列，目标实例行点击“管理”。

（4）点击“监控信息”后，点击“主题监控”。

（5）可以快速查询最近1小时、3小时、6小时、12小时、1天、3天、7天、14天内的监控信息，也可以自定义时间查询，最大支持14天内的监控数据查询。

（6）支持的监控指标有：Topic消息生产流量(bytes/s)、Topic消息消费流量(bytes/s)、Topic消息生产条数(条/秒)、Topic消息发送次数(次/秒)

• Topic消息生产流量(bytes/s)是指在Kafka消息队列中特定主题的消息产生速率，以每秒传输的字节数来衡量。它表示在特定时间段内，该主题接收到的消息的总字节数。Topic消息生产流量(bytes/s)的指标可以用于评估消息队列的负载情况和性能状况。通过监控该指标，可以了解消息产生的速率，判断是否存在消息过载或拥塞的情况。如果消息生产流量过高，可能会导致消息堆积、延迟增加或系统资源紧张等问题。相反，如果消息生产流量过低，可能表示系统负载较轻或存在生产者的性能问题。监控Topic消息生产流量(bytes/s)可以帮助管理员及时发现异常情况，并采取相应的措施，如优化生产者的性能、扩展Kafka集群的规模或调整消息传输策略，以确保消息的正常传递和系统的高效运行。

• Topic消息消费流量(bytes/s)是指在Kafka消息队列中特定主题的消息消费速率，以每秒传输的字节数来衡量。它表示在特定时间段内，该主题消费的消息的总字节数。Topic消息消费流量(bytes/s)的指标可以用于评估消息队列的消费负载情况和性能状况。通过监控该指标，可以了解消息消费的速率，判断是否存在消费者处理能力不足的情况。如果消息消费流量过高，可能会导致消费者无法及时处理消息，从而导致消息堆积或延迟增加。相反，如果消息消费流量过低，可能表示消费者的负载较轻或存在消费者的性能问题。监控Topic消息消费流量(bytes/s)可以帮助管理员及时发现消费问题，并采取相应的措施，如增加消费者的数量或调整消费者的处理能力，以确保消息的及时消费和系统的高效运行。
• Topic消息生产条数(条/秒)是指在Kafka消息队列中特定主题的消息产生速率，以每秒产生的消息条数来衡量。它表示在特定时间段内，该主题接收到的消息的总数量。Topic消息生产条数(条/秒)的指标可以用于评估消息队列的负载情况和性能状况。通过监控该指标，可以了解消息产生的速率，判断是否存在消息过载或拥塞的情况。如果消息生产条数过高，可能会导致消息堆积、延迟增加或系统资源紧张等问题。相反，如果消息生产条数过低，可能表示系统负载较轻或存在生产者的性能问题。监控Topic消息生产条数(条/秒)可以帮助管理员及时发现异常情况，并采取相应的措施，如优化生产者的性能、扩展Kafka集群的规模或调整消息传输策略，以确保消息的正常传递和系统的高效运行。

• Topic消息发送次数(次/秒)是指在Kafka消息队列中特定主题的消息发送速率，以每秒发送的消息次数来衡量。它表示在特定时间段内，该主题发送的消息的总次数。Topic消息发送次数(次/秒)的指标可以用于评估消息队列的发送负载情况和性能状况。通过监控该指标，可以了解消息发送的速率，判断是否存在发送者过载或拥塞的情况。如果消息发送次数过高，可能会导致发送者无法及时发送消息，从而导致消息堆积或延迟增加。相反，如果消息发送次数过低，可能表示发送者的负载较轻或存在发送者的性能问题。监控Topic消息发送次数(次/秒)可以帮助管理员及时发现发送问题，并采取相应的措施，如增加发送者的数量或调整发送者的处理能力，以确保消息的及时发送和系统的高效运行。