24-Kafka命令
本章节下载: 24-Kafka命令 (148.51 KB)
broker命令用来配置Kafka服务实例绑定的Kafka Broker。
undo broker命令用来取消Kafka服务实例和Kafka Broker的绑定。
【命令】
broker [ vpn-instance vpn-instance-name ] { host-name | ipv4-address | ipv6 ipv6-address } port port-number
undo broker [ vpn-instance vpn-instance-name ] { host-name | ipv4-address | ipv6 ipv6-address }
【缺省情况】
Kafka服务实例未绑定Kafka Broker。
【视图】
Kafka服务实例视图
【缺省用户角色】
network-admin
【参数】
vpn-instance vpn-instance-name:指定Kafka Broker所属的VPN。vpn-instance-name表示MPLS L3VPN的VPN实例名称,为1~31个字符的字符串,区分大小写。如果未指定本参数,则表示Kafka Broker位于公网中。
host-name:Kafka Broker的主机名,为1~253个字符的字符串,不区分大小写。
ipv4-address:指定Kafka Broker的IPv4地址。
ipv6 ipv6-address:指定Kafka Broker的IPv6地址。
port port-number:指定Kafka Broker的消息接收端口号,取值范围为1~65535。该参数的值需要和Kafka Broker上的配置一致,否则Kafka Broker接收不到设备产生的Kafka消息。
【使用指导】
本命令用来指定Kafka服务器,即设备发布的Kafka消息的接收者和存储者。
Kafka集群包含一个或多个Kafka服务器,这种服务器被称为Kafka Broker。
多次执行本命令,可以绑定多个Kafka Broker。设备将作为Kafka消息生产者,将生成的消息按照指定的格式和主题,同时发送给这些Kafka Broker。
设备支持发送的Kafka消息例如:
· CPU利用率超阈值告警和恢复消息
· 空闲内存低于阈值告警和恢复消息
· 接口状态由up变为down告警和恢复消息
· 基础License过期告警和恢复消息
· 路由表超阈值告警和恢复消息
· ARP表超阈值告警和恢复消息
· BGP邻居断开告警和恢复消息
【举例】
# 配置Kafka服务实例绑定的Kafka Broker的IP地址为1.1.1.1,端口号为5145。
<Sysname> system-view
[Sysname] kafka-service suyan
[Sysname-kafka-service-suyan] broker 1.1.1.1 port 5145
【相关命令】
· kafka-service
· format
· topic
format命令用来配置发送给Kafka Broker的消息格式。
undo format命令用来恢复缺省情况。
【命令】
format string
undo format
【缺省情况】
未配置发送给Kafka Broker的消息格式。
【视图】
Kafka服务实例视图
【缺省用户角色】
network-admin
【参数】
string:指定消息格式,目前支持的取值为suyan-cloud。
【使用指导】
配置本命令后,设备将作为Kafka消息生产者,将生成的消息按照指定的格式发送给指定的Kafka Broker。
【举例】
# 配置发送给Kafka Broker的消息格式为suyan-cloud。
<Sysname> system-view
[Sysname] kafka-service suyan
[Sysname-kafka-service-suyan] format suyan-cloud
【相关命令】
· kafka-service
· broker
· topic
kafka-service命令用来创建Kafka服务实例,并进入Kafka服务实例视图。如果指定的Kafka服务实例已经创建,则直接进入Kafka服务实例视图。
undo kafka-service命令用来删除Kafka服务实例。
【命令】
kafka-service service-name
undo kafka-service service-name
【缺省情况】
不存在Kafka服务实例。
【视图】
系统视图
【缺省用户角色】
network-admin
【参数】
service-name:指定Kafka服务实例的名称,为1~15个字符的字符串,以英文字母[a-z,A-Z]开始,不区分大小写。
【使用指导】
Kafka服务实例用于管理和配置Kafka服务。在Kafka服务实例视图下,可以绑定Kafka Broker(Kafka服务器)、配置消息的主题和格式。完成配置后,设备作为Kafka消息生产者,将生成的消息按照指定的格式和主题,发送给指定的Kafka Broker。
多次执行本命令,可以创建多个Kafka服务实例,用于定制不同的参数,给不同的Kafka Broker发送信息。设备目前最多可配置的Kafka服务实例的个数为1。
【举例】
# 创建Kafka服务实例suyan。
<Sysname> system-view
[Sysname] kafka-service suyan
[Sysname-kafka-service-suyan]
【相关命令】
· broker
· format
· topic
topic命令用来配置Kafka消息的主题。
undo topic命令用来删除配置的Kafka消息主题。
【命令】
topic module topic-name
undo topic module
【缺省情况】
未配置Kafka消息的主题。
【视图】
Kafka服务实例视图
【缺省用户角色】
network-admin
【参数】
module:表示设备上支持向Kafka Broker发送消息的业务模块的名称,目前支持的取值为alarm。
topic-name:表示业务模块向Kafka Broker发送消息时使用的主题,为1~249个字符的字符串,不区分大小写,字符串中可以包含字母、数字、“-”和“_”,不能为空。
【使用指导】
主题是Kafka消息必不可少的组成部分,网络管理员可以使用主题将设备生成的消息按照自己的习惯进行分类,以便对消息进行管理。
配置本命令后,设备将作为Kafka消息生产者,自动将指定业务模块生成的消息添加对应的主题后,发送给Kafka Broker。
对同一个模块多次执行本命令时,最后一次配置生效。目前只支持alarm一个模块。
【举例】
# 配置alarm模块发送消息的主题名为suyan-alarm。
<Sysname> system-view
[Sysname] kafka-service suyan
[Sysname-kafka-service-suyan] topic alarm suyan-alarm
【相关命令】
· kafka-service
· broker
· format
不同款型规格的资料略有差异, 详细信息请向具体销售和400咨询。H3C保留在没有任何通知或提示的情况下对资料内容进行修改的权利!