zoukankan      html  css  js  c++  java
  • kafka、zookeeper相关命令

    查看防火墙状态
    firewall-cmd --state
    
    开放端口
    firewall-cmd --zone=public --add-port=2181/tcp --permanent
    firewall-cmd --zone=public --add-port=9092/tcp --permanent
    firewall-cmd --reload
    firewall-cmd --zone=public --list-ports
    
    开启关闭防火墙
    systemctl start firewalld.service
    systemctl stop firewalld.service
    
    关闭防火墙开机启动
    systemctl disable firewalld.service
    开启防火墙开机启动
    systemctl enable firewalld.service
    
    启动
    ./zkServer.sh start
    bin/kafka-server-start.sh config/server.properties &
    
    后台启动
    bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
    bin/kafka-server-start.sh -daemon config/server.properties
    
    停止
    bin/kafka-server-stop.sh  config/server.properties
    ./zkServer.sh stop
    
    
    创建topic
    bin/kafka-topics.sh --create --zookeeper 192.168.137.128:2181 --topic topic-test1 --replication-factor 1 --partitions 3 
    查看topic
    ./kafka-topics.sh --list --zookeeper 192.168.137.128:2181
    ./kafka-topics.sh --describe --zookeeper 192.168.137.128:2181 --topic topic-test1
    启动消息生产者
    ./kafka-console-producer.sh --broker-list 192.168.137.128:9092 --topic topic-test1
    启动消息消费者
    ./kafka-console-consumer.sh --bootstrap-server 192.168.137.128:9092 --from-beginning --topic topic-test1
    删除topic
    kafka-topics.sh --zookeeper 192.168.137.128:2181  --delete --topic topic-test1
    

      

  • 相关阅读:
    软件测试
    python学习之路
    好用的在线画图工具processon
    spring-boot集成dubbo
    公众号开放,关注软件开发过程中的哪些坑
    crontab 中curl命令无法正常执行
    近一月翻阅资料小结
    nginx+tomat8负载后,利用redis实现tomcat8的session共享
    centos7 安装nginx
    centos 上安装redis 3.0.5
  • 原文地址:https://www.cnblogs.com/jf8710/p/13261674.html
Copyright © 2011-2022 走看看