精华内容
下载资源
问答
  • 查看kafka是否启动
    万次阅读
    2018-03-20 10:24:10

    输入:jps

    显示的有进程号代表成功

    更多相关内容
  • 启动zookeeper(Kafka 0.5.x版本以上已经自带ZooKeper) 自测的话直接使用自带的zookeeper就行,要是生产的话,建议分离。 nohup ./zookeeper-server-start.sh ../config/zookeeper.properties & 启动kafka ...

     需要java环境,推荐1.8以上


    下载kafka,解压,进入kafka的bin目录

    wget http://archive.apache.org/dist/kafka/2.4.0/kafka_2.11-2.4.0.tgz 

    启动zookeeper(Kafka 0.5.x版本以上已经自带ZooKeper)

    nohup ./zookeeper-server-start.sh ../config/zookeeper.properties &

    备注:自测的话直接使用自带的zookeeper就行,要是生产的话,建议分离,另起一套。 

    启动kafka

    nohup ./kafka-server-start.sh ../config/server.properties > kafka.log 2>&1 &

    查看zookeeper和kafka是否启动

    netstat -tanlp | egrep "2181|9092"

    创建主题:test

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

    生产主题:test

    ./kafka-console-producer.sh --broker-list localhost:9092 --topic test

    消费主题:test

    ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test 

    查看所有主题

     ./kafka-topics.sh  --zookeeper localhost:2181 --list

    查看指定主题描述信息

    ./kafka-topics.sh --describe  --zookeeper localhost:2181  --topic test

    配置外网访问kafka

    修改server.properties的两行默认配置

    # 允许外部端口连接                                            
    listeners=PLAINTEXT://0.0.0.0:9092  
    # 外部代理地址                                                
    advertised.listeners=PLAINTEXT://192.168.23.143:9092
    

    展开全文
  • 检查kafka是否正常工作

    千次阅读 2021-12-09 09:12:49
    1.查看具体的程序是否启动 ps -ef |grep java 2.发布一条消息 随机登录一台机器,进入kafka安装程序的bin文件夹中 cd /opt/test/kafka_2.12-2.6.3/bin 创建主题 ./kafka-topics.sh --create --zookeeper 192.168....

    如何测试kafka集群能否正常工作?

    1.查看具体的程序是否启动
    ps -ef |grep java

    2.发布一条消息
    随机登录一台机器,进入kafka安装程序的bin文件夹中

    cd /opt/test/kafka_2.12-2.6.3/bin
    创建主题
    ./kafka-topics.sh --create --zookeeper 192.168.1.20:2181 --topic test --partitions 3 --replication-factor 1  #这个命令是否正确没有验证,只是做了结果验证
    

    向主题中写入内容

    ./kafka-console-producer.sh --broker-list 192.168.1.20:9092,192.168.1.21:9092,192.168.1.22:9092 --topic test
    

    在这里插入图片描述
    CTRL+D 退出来

    3.订阅消息
    随机登录一台机器,进入kafka安装程序的bin文件夹中

    cd /opt/test/kafka_2.12-2.6.3/bin
    
    ./kafka-console-consumer.sh --bootstrap-server 192.168.1.21:9092 --topic test --from-beginning
    

    在这里插入图片描述

    展开全文
  • centos7上查看kafka-常见命令

    千次阅读 2022-01-18 10:12:57
    启动和关闭zookeeper bin/zookeeper-server-start.sh -daemon config/zookeeper.properties bin/zookeeper-server-stop.sh ...centos7上查看kafka是否成功启动的命令(显示的有进程号代表成功) 输入:jps

    启动和关闭zookeeper

    bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
    bin/zookeeper-server-stop.sh 
    • 启动和关闭kafka
    bin/kafka-server-start.sh -daemon config/server.properties
    bin/kafka-server-stop.sh
    • centos7上查看kafka是否成功启动的命令(显示的有进程号代表成功)
    输入:jps

    • 查看kafka topic列表,使用–list参数
    bin/kafka-topics.sh --list --zookeeper localhost:2181
    bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list

    • 查看kafka特定topic的详情,使用–topic与–describe参数
    bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --topic test --describe

    • 创建一个测试的Topic
    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
    • 开启生产者
    kafka-console-producer.sh --broker-list localhost:9092 --topic test
    • 开启消费者
    kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
    • 删除topic
     ./kafka-topics.sh  --delete --zookeeper localhost:2181 --topic test

    展开全文
  • Kafka集群启动

    2022-05-23 10:48:45
    启动kafka集群 bin/kafka-server-start.sh config/server.properties & 创建topic bin/kafka-topics.sh --create --zookeeper 192.1.x.x:2181,192.1.x.1:2181,192.1.x.3:2181 --replication-f.
  •  结合前面博主分享给大家ZK的脚本,大家是不是也推断出我们也可以写一个Kafka的集群启动/关闭脚本呢?  这不就来了么~  来到Kafka的bin目录下.  cd /export/servers/kafka_2.11-1.0.0/bin 集群启动 vim kafka_...
  • 一键启动zookeeper_kafka服务,只需要设置安装路径。自备用!
  • Linux Kafka安装与启动

    千次阅读 2022-03-15 17:21:59
    启动命令:bin/kafka-server-start.sh -daemon config/server.properties server.properties配置中需要关注以下几个参数: broker.id=0 表示broker的编号,如果集群中有多个broker,则每个broker的编号需要设置 的...
  • kafka启动

    千次阅读 2022-04-07 15:47:23
    kafka 启动 .\bin\windows\kafka-server-start.bat .\config\server.properties # Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE ...
  • 测试kafka是否运行安装成功

    万次阅读 2019-05-08 15:39:46
    启动zookeeper 在 /usr/local/kafka目录下执行: ...启动kafka 打开另一个终端(之前的终端不要关闭,否则zookeeper会停止) bin/kafka-server-start.sh config/server.properties 测试命令 再...
  • linux下启动kafka

    万次阅读 多人点赞 2018-09-13 16:12:34
    记录下kafka启动过程,适合傻瓜新手,想弄明白原理的请绕到官网查看文档。 1、首先下载从github上下载 源码。如果机器上装有Git,直接clone更好,省的再解压。 解压命令:tar -zxvf librdkafka-master.tgz 2、...
  • KafKa 启动

    2021-03-13 05:08:20
    Zookeeper运行kafka需要使用Zookeeper,所以要先启动Zookeeper,如果没有Zookeeper,可以使用kafka自带打包和配置好的Zookeeper1、进入kafka的bin目录,输入以下命令:./zookeeper-server-start.sh ../config/...
  • Kafka启动

    千次阅读 2022-03-08 17:05:26
    windows系统 ...启动kafka bin\windows\kafka-server-start.bat config\server.properties Linux系统 启动zookeeper bin/zookeeper-server-start.sh -daemon config/zookeeper.properties 启动kafka no
  • 注意:启动kafka, 必须依赖于zookeeper先启动 一、linux启动kafka--单命令版 1. 首先启动 zookeeper (如果没有进行环境变量配置,需要进入zookeeper安装目录下的bin目录下) 启动 ./zkServer.sh start 停止 ...
  • Windows Kafka 启动教程 修改 boker.id 和 log.dirs 进入kafka目录下,新建文件夹 kafka-logs 与文件夹 zk-dir,进入config目录下,打开server.properties broker.id=1 log.dirs=../kafka-logs 修改 zookeeper....
  • 目录Kafka 的搭建1、上传、解压、配置环境变量2、修改配置文件3、同步到所有节点4、将master的环境变量同步到node1,node25、启动\停止 Kafka6、验证Kafka是否安装成功(Kafka基本操作)7、重置KafkaKafka 的搭建 ...
  • kafka启动命令

    千次阅读 2021-12-08 16:29:51
    进入kafka目录 cd /opt/kafka/kafka_2.11-1.0.0/bin 执行 ./kafka-server-start.sh -daemon ../config/server.properties
  • sh代码-Shell 脚本方式启动Kafka服务
  • kafka前台启动命令与后台启动命令

    千次阅读 2021-12-31 17:35:37
    1、前台启动命令: cd /export/servers/kafka_2.11-0.10.0.0 bin/kafka-server-start.sh config/server.properties 描述: 此种方式是窗口运行。一旦窗口关闭或者执行了CTR+C,那么kafka进程就被kill了,kafka...
  • windows 上 Kafka 启动

    千次阅读 2022-05-21 16:06:12
    1. 下载 Kafka 官网下载链接 本例 下载的是 kafka_2.12-3.1.0.tgz 下载后解压 2. 启动服务 需遵循以下几步, 依次打开新的命令行启动, 也不要关闭之前的命令行窗口 ...启动 Kafka 服务,默认端口 9092bin\wind
  • kafka集群启动脚本

    2020-09-11 09:11:49
    以/usr/bin 为例以kafka集群启动为例:5.给脚本赋予权限6.启动和停止 1.三台主机之间,需要先免密。 2.x x1 x2 修改为相应的主机名 3. source /etc/profile; (重要)Java环境所在地方 4. 为了命令能够找到我们创建...
  • kafka启动失败

    万次阅读 2021-05-25 16:09:48
    在学习搭建单机kafka的时候遇到kafka不能启动的错误。 在zookeeper可以正常running的前提下,启动kafka: bin/kafka-server-start.sh config/server.properties 结果启动失败,报如下错误: [2021-05-25 07:26:14,...
  • Kafka安装配置、快速启动及基本操作1、Kafka下载2、启动服务扩展知识:进程守护方法和前后台进程切换3、创建一个主题扩展知识:bootstrap-server和zookeeper使用区别4、删除主题5、发送消息6、消费消息7、设置多个...
  • Linux启动Kafka

    2022-07-05 00:18:12
    /opt/monitor/kafka/kafka_2.12-3.2.0
  • Kafka安装启动入门教程

    千次阅读 2021-01-14 12:29:32
    我的原创地址:Kafka安装启动入门教程​dongkelun.com前言本文讲如何安装启动kafka,并进行测试,其中zookeepr是kafka自带的,本文基本按照官网文档进行安装启动的,并提出可能会出现的问题。官方文档:...
  • kafka命令及启动

    千次阅读 2021-06-29 10:33:11
    默认内网访问,要在外网访问的话,需要在修改config/server.properties中的配置 将listeners和advertised.listeners的值用主机名进行替换,在外用使用java进行生产者...先启动zookeeper,默认自带的 bin/zookeeper-s
  • 一、kafka启动(linux环境)1、单节点启动(非集群)(1)下载kafka安装包http://kafka.apache.org/downloads,我这里下载的是kafka_2.11-2.3.0.tgz(2)解压(不需要安装,直接配置可用) tar -xzvfkafka_2.11-2.3.0.tgz(3)...
  • 解决启动kafka只能启动2个

    千次阅读 2022-01-19 14:44:51
    不知做了什么操作,当我启动kafka集群时,总是只能启动两个节点 1.最开始怀疑是server.properties或zookeeper.properties中配置有问题,检查一遍是没问题的 2.只能百度一下,看到可能是log.dir(我的默认/tmp/kafka-...
  • kafka后台启动

    2020-10-16 14:16:47
    1.启动zookeeper 1 nohupbin/zookeeper-server-start.sh config/zookeeper....启动kafka -server 1 nohupbin/kafka-server-start.sh config/server.properties > kafka_server_...

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 107,039
精华内容 42,815
关键字:

查看kafka是否启动