使用Site24x7插件进行Kafka监控

使用Site24x7插件监控Apache Kafka服务器的性能指标

安装和配置Kafka插件以监控容错的高容量消息传递中间件Kafka。通过跟踪关键指标（如连接计数，传入和传出字节速率等）来做出明智的故障排除决策。

本文档详细介绍了如何配置Apache Kafka插件和监控指标，以深入了解Kafka服务器的性能，可用性和使用情况统计信息。

Apache Kafka性能监控指标：

使用我们广泛的指标，并获得需要您注意的危险错误的通知。通过我们的指标图表跟踪意外趋势，并尽快排除故障。我们支持的各种开箱即用指标包括：

连接数

connection_count给出了kafka集群的当前活动连接数

传入/传出字节速率

incoming_byte_rate和outgoing_byte_rate分别给出每秒接收的平均传入字节数和每秒发送的传出字节数。

平均请求延迟

生产者发送的请求到从代理接收的响应之间的时间量度被视为avg_request_latency

网络操作数

每秒所有连接上的平均网络操作数（读取或写入）数量为network_io_rate

要求率

生产者向经纪人发送数据的速率由度量request_rate计算

反应速度

response_rate显示从经纪人处收到的回复率

输入/输出线程花费的时间

io_time_ns_avg给出输入/输出线程在等待套接字时花费的平均时间长度（以ns为单位）

这个怎么运作？

先决条件：

如何安装kafka-python模块

Kafka插件安装：

  • 在Site24x7 Linux代理插件目录下创建一个名为“kafka_producer”的目录 - / opt / site24x7 / monagent / plugins /
    • sudo mkdir kafka_producer
  • 从我们的GitHub存储库下载“ kafka_producer.py”并将其放在“kafka_producer”目录下
  • 插件脚本中给出的默认python路径是＃！/ usr / bin / python。如果您希望提供备用python路径，请替换前面带有shebang字符“＃！”的现有路径。
    • 例如：＃！/ usr / local / bin / python3
  • 更改BROKER_NAME和PORT的值以匹配您的配置
  • 服务器代理将在Site24x7 Web客户端的“插件”选项卡下报表Kafka性能的统计信息。如果该插件未在Site24x7 Web客户端中列出，请重新启动该代理。
    • sudo /etc/init.d/site24x7monagent restart

监控其他指标：

  • 要监控其他指标，请编辑“kafka_producer.py”文件并添加需要监控的新指标
  • 增加文件“kafka_producer.py”中的插件版本值以查看新添加的度量标准（例如，将默认插件版本从PLUGIN_VERSION =“1”更改为“PLUGIN_VERSION =”2“）

相关插件：

故障排除提示

可信

世界领先的公司

客户

没有Site24x7帐户？立即注册！