1、監聽kafka訊息：
export JMX_PORT=9945(未被占用的埠號即可)
/opt/kafka_2.12-2.4.0/bin/kafka-console-consumer.sh
./kafka-console-consumer.sh --bootstrap-server kafka-svc-0:9093,kafka-svc-1:9093,kafka-svc-2:9093 --topic T_iMC_5_Trap
2、查看topic健康狀態：
bin/kafka-topics.sh --zookeeper zk-1:2181 --describe --topic T_iMC_5_Trap
./kafka-topics.sh --bootstrap-server kafka-svc-0:9093,kafka-svc-1:9093,kafka-svc-2:9093 --describe --topic T_iMC_5_Trap
3、增加加partition
export JMX_PORT=9998
./kafka-topics.sh --alter --zookeeper zk-1 :2181 --topic T_iMC_5_Trap --partitions 15
4、查看所有topic
[root@env221 ~]# kubectl exec -it kafka-0-65f97778b6-frh27 /bin/bash
Defaulting container name to kafka-0.
Use 'kubectl describe pod/kafka-0-65f97778b6-frh27 -n service-software' to see all of the containers in thi
bash-4.4# export JMX_PORT=9997
bash-4.4# cd /opt/kafka
bash-4.4# bin/kafka-topics.sh --zookeeper zk-1:2181 --list
4、重啟kakfa并清理歷史資料
[root@master1 ~]# kubectl scale deployment kafka-0 --replicas=0
deployment.extensions/kafka-0 scaled
[root@master1 ~]# kubectl scale deployment kafka-1 --replicas=0
deployment.extensions/kafka-1 scaled
[root@master1 ~]# kubectl scale deployment kafka-2 --replicas=0
deployment.extensions/kafka-2 scaled
[root@master1 ~]# kubectl delete pod kafka-0-6494bbfb5f-cdrmf kafka-1-8697f44957-t8prh kafka-2-785897f455-t8rrz --force --grace-period=0
warning: Immediate deletion does not wait for confirmation that the running resource has been terminated. The resource may continue to run on the cluster indefinitely.
Error from server (NotFound): pods "kafka-0-6494bbfb5f-cdrmf" not found
Error from server (NotFound): pods "kafka-1-8697f44957-t8prh" not found
Error from server (NotFound): pods "kafka-2-785897f455-t8rrz" not found
[root@master1 ~]# kubectl get pod -o wide | grep kafka
[root@master1 ~]# cd /var/lib/ssdata/kafka
[root@master1 kafka]# ls
broker0 broker1 broker2
[root@master1 kafka]# rm -rf *
[root@master1 kafka]# kubectl scale deployment kafka-0 --replicas=1
deployment.extensions/kafka-0 scaled
[root@master1 kafka]# kubectl scale deployment kafka-1 --replicas=1
[root@master1 kafka]# kubectl scale deployment kafka-2 --replicas=1
deployment.extensions/kafka-2 scaled
5、查看group下偏移量資訊
./kafka-consumer-groups.sh --bootstrap-server kafka-svc-0:9093,kafka-svc-1:9093,kafka-svc-2:9093 --describe --group Kafka_Alarm
6、構造kafka訊息到指定topic：
bash-4.4# ./kafka-console-producer.sh --broker-list kafka-svc-0:9093,kafka-svc-1:9093,kafka-svc-2:9093 --topic T_iMC_5_Trap
>{"nGenericID":4,"nSpecificID":0,"nTrapVersion":0,"strEnterpriseID":"1.3.6.1.4.1.2011.1.2.1.12","strTrapIP":"10.66.60.13","vbInfo":null}
{"nGenericID":4,"nSpecificID":0,"nTrapVersion":0,"strEnterpriseID":"1.3.6.1.4.1.2011.1.2.1.12","strTrapIP":"10.66.60.13","vbInfo":null}為輸入的訊息
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/244946.html
標籤：C++ 語言
上一篇：第一次發帖，如圖問一下兄弟們那個return回傳0 1為什么可以這樣用
下一篇：makefile撰寫樣例