zoukankan      html  css  js  c++  java
  • Kafka探究之路-命令小结

    操作kafka之前,要先启动安装好的zk ,因为kafka的数据都保存在zk中,zk相当于是kafka的数据库吧。

    安装的zk kafka 一定要按照书上,网上的教程,将相应的配置文件全部改成自己的,端口号,ip地址,文件目录都要一一确认无误

     在后台启动kafka

    ./kafka-server-start.sh -daemon ../config/server.properties

    关闭kafka
    kafka-server-stop.sh

    Kafka服务关闭失败 No kafka server to stop

    解决方法:进入kafka安装目录下的bin目录,编辑kafka-server-stop.sh脚本,修改以下内容
    编辑命令:vi kafka-server-stop.sh

    将 PIDS=$(ps ax | grep -i ‘kafka.Kafka’ | grep java | grep -v grep | awk ‘{print $1}’)
    修改为:PIDS=$(jps -lm | grep -i 'kafka.Kafka' | awk '{print $1}')

    命令作用:使用jps -lm命令列出所有的java进程,然后通过管道,利用grep -i 'kafka.Kafka’命令将kafka进程筛出来,最后再接一管道命令,利用awk将进程号取出来。



    创建topic 主题名为 first

    ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic first

    查看创建的Topic

    ./kafka-topics.sh --list(decribe) --zookeeper localhost:2181

    删除topic

    ./kafka-topics.sh --delete --zookeeper localhost:2181 --topic first


    #启动生产者
    ./kafka-console-producer.sh --broker-list localhost:9092 --topic test
    再打开一个窗口,登录,进入kafka启动目录,启动消费者 ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test

    在生产者
    窗口输入信息,在消费者窗口便会接受到生产者输入的消息

  • 相关阅读:
    C/C++编译过程
    Struts2入门01
    NET CORE 微软官方说明链接
    PL/SQL控制语句(二、循环控制语句)
    PL/SQL控制语句(一、分支控制语句)
    PL/SQL数据类型
    PL/SQL变量的作用域和可见性
    PL/SQL变量和类型
    CopyWebpackPlugin 的使用
    flex
  • 原文地址:https://www.cnblogs.com/txqx/p/14085028.html
Copyright © 2011-2022 走看看