查看主题的详细信息指令

./bin/kafka-topics.sh –zookeeper localhost:2181 –describe –topic 主题名称
修改主题的分区消息指令

./bin/kafka-topics.sh –alter  –zookeeper localhost:2181  –topic 主题名称  –partitions 分区数量
————————————————
版权声明:本文为CSDN博主「qq_1959227206」的原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/yjt520557/article/details/90719025

 

 

 

这个地址可以设置本地网卡和外网通的本地ip,也可以直接写外网ip或域名

[本地的ip好像不一定,外网ip和域名肯定是可以]

启动自带的zk

/usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties

启动broker

/usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties

生产者

/usr/local/kafka/bin/kafka-console-producer.sh –broker-list localhost:9092 –topic test

消费者

/usr/local/kafka/bin/kafka-console-consumer.sh –bootstrap-server localhost:9092 –from-beginning –topic test

外部访问

pykafka生产者

#! /usr/bin/python
import time
from kafka import KafkaProducer


producer = KafkaProducer(bootstrap_servers = ['192.168.4.31:9092'])
# Assign a topic
topic = 'test'

def test():
    print('begin')
    n = 1
    try:
        while (n<=100):
            producer.send(topic, str(n).encode())
            print("send" + str(n))
            n += 1
            time.sleep(0.5)
    except KafkaError as e:
        print(e)
    finally:
        producer.close()
        print('done')

if __name__ == '__main__':
        test()

告警媒介地方的参数,给python脚本接收

Parameter Action
先设置好告警。


结合zabbix告警测试
./zabbix_sender -z localhost -s "api6" -k key -o 41 -vv
./zabbix_sender -z localhost -s "api6" -k key -o 4 -vv
超过10会告警,然后发一条小于10的数据又会恢复正常。然后下一条立马又超过10又会进行告警。
同一个触发器,触发多条,发送消息按照告警先后顺序执行脚本的。


脚本执行100秒,然后之前脚本持续时间设置60秒,那么超过60秒脚本就会执行失败。


收到值以后会立马触发脚本,还是挺快的响应,不管是故障还是恢复时的响应。

告警内容

--------------出错的告警内容-------------------
root

Problem: test_api_trigger

Problem started at 03:04:43 on 2019.04.12
Problem name: test_api_trigger-
--问题是触发器名字(所以触发器名字最好和监控项名字相关,能一眼看出是哪个监控项的触发器)
结合下面的主机,就是哪台机器的哪个触发器报的警
Host: api6---------------------
------------这里主机根据hostname那里填写来的,所以最好以后这里还是写ip,不然这不知道是谁了
Severity: Average

Original problem ID: 35660



-------------恢复的告警内容-------------------------
root

Resolved: test_api_trigger

Problem has been resolved at 03:05:11 on 2019.04.12
Problem name: test_api_trigger
Host: api6
Severity: Average

Original problem ID: 35660

是有模板的

Problem started at {EVENT.TIME} on {EVENT.DATE}
Problem name: {EVENT.NAME}
Host: {HOST.NAME}
Severity: {EVENT.SEVERITY}

Original problem ID: {EVENT.ID}
{TRIGGER.URL}

告警变量—在actions动作,里面设置的

名称:Action-Email
默认接收人:故障{TRIGGER.STATUS},服务器:{HOSTNAME1}发生: {TRIGGER.NAME}故障!
默认信息:
告警主机:{HOSTNAME1}
告警时间:{EVENT.DATE} {EVENT.TIME}
告警等级:{TRIGGER.SEVERITY}
告警信息: {TRIGGER.NAME}
告警项目:{TRIGGER.KEY1}
问题详情:{ITEM.NAME}:{ITEM.VALUE}
当前状态:{TRIGGER.STATUS}:{ITEM.VALUE1}
事件ID:{EVENT.ID}
恢复信息:打钩
恢复主旨:恢复{TRIGGER.STATUS}, 服务器:{HOSTNAME1}: {TRIGGER.NAME}已恢复!


告警主机:{HOSTNAME}
告警时间:{EVENT.DATE} {EVENT.TIME}
告警等级:{TRIGGER.SEVERITY}
告警信息: {TRIGGER.NAME}
告警项目:{TRIGGER.KEY}
问题详情:{ITEM.NAME}:{ITEM.VALUE}
当前状态:{TRIGGER.STATUS}:{ITEM.VALUE}
事件ID:{EVENT.ID}

 

kafka-console-producer.sh –topic topic001 –broker-list zk01:9092,zk02:9092,zk03:9092


发表评论

您的电子邮箱地址不会被公开。 必填项已用*标注