精华内容
下载资源
问答
  • kafka启动命令

    2021-01-04 21:32:38
    kafka生产者端启动命令 kafka-console-producer.sh --broker-list localhost:9092 --topic kafka_streaming_topic kafka消费者端启动命令 kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic ...

    kafka启动命令

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

    kafka生产者端启动命令

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

    kafka消费者端启动命令

    kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic kafka_streaming_topic --from-beginning

    kafka查看topic命令

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

    kafka创建topic命令

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

     

    展开全文
  • Kafka 启动命令

    千次阅读 2018-08-14 18:03:08
    1 .启动zookeeper bin/zookeeper-server-start.sh config/zookeeper.properties bin/zookeeper-server-stop.sh config/zookeeper....2.启动停止kafka bin/kafka-server-start.sh config/server.properties bi...

    linux 环境启动
    1 .启动zookeeper

    bin/zookeeper-server-start.sh config/zookeeper.properties
    bin/zookeeper-server-stop.sh config/zookeeper.properties

    2.启动停止kafka

    bin/kafka-server-start.sh config/server.properties
    bin/kafka-server-stop.sh config/server.properties

    3.查看主题:

    bin/kafka-topics.sh --list --zookeeper 10.10.0.94:2181

    4.创建主题

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

    5.发送消息 product

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

    6.接受消息

    bin/kafka-console-consumer.sh --bootstrap-server 10.10.0.94:9092 --topic test --from-beginning
    

    .
    .
    .

    .
    windows 本地启动

    1.window下启动zookeeper

    bin\windows\zookeeper-server-start.bat config/zookeeper.properties

    2.window下启动kafka

    bin\windows\kafka-server-start.bat config\server.properties
    

    3.windows下启动kafka consumer

    bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
    

    4.windows下启动kafka product

    bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
    
    展开全文
  • filebeat+kafka 启动命令

    2021-02-02 14:52:03
    filebeat+kafka 启动命令 先配置好相关配置 filebeat https://blog.csdn.net/haozhuxuan/article/details/79753599 kafka https://blog.csdn.net/weixin_38004638/article/details/91893910 elasticsearch 启动 双击...

    filebeat+kafka 启动命令

    先配置好相关配置
    filebeat
    https://blog.csdn.net/haozhuxuan/article/details/79753599
    kafka
    https://blog.csdn.net/weixin_38004638/article/details/91893910

    elasticsearch 启动 双击bin目录下.bat

    Windows filebeat启动.\filebeat -e -c filebeat.yml

    zk启动 双击bin目录下的zkServer.cmd
    Windows kafka启动:
    .\bin\windows\kafka-server-start.bat .\config\server.properties

    .\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
    生产者启动

    .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
    消费者启动

    展开全文
  • kafka启动命令,与BUG

    2020-06-26 21:50:12
    首先启动Zookeeper 三台机器启动zookeeper服务 三台机器启动zookeeper服务 这个命令三台机器都要执行 ...1、kafka启动命令-前台启动 hadoop01服务器执行以下命令来启动kafka集群 cd /export/servers/kafka_2.11-0.

    首先启动Zookeeper

    三台机器启动zookeeper服务

    三台机器启动zookeeper服务
    这个命令三台机器都要执行

    /export/install/zookeeper-3.4.9/bin/zkServer.sh start

    查看启动状态

    /export/install/zookeeper-3.4.9/bin/zkServer.sh status

    1、kafka启动命令-前台启动

    hadoop01服务器执行以下命令来启动kafka集群

    cd /export/servers/kafka_2.11-0.10.0.0

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

    2、kafka启动命令-后台启动

    hadoop01执行以下命令将kafka进程启动在后台

    cd /export/servers/kafka_2.11-0.10.0.0

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

    3、kafka停止命令

    hadoop01执行以下命令便可以停止kakfa进程

    cd /export/servers/kafka_2.11-0.10.0.0

    bin/kafka-server-stop.sh

    5、查看kafka启动进程

    通过jps命令来查看进程是否存在

    [root@node01 ~]# jps

    2276 QuorumPeerMain

    2687 Jps#输入jps

    3056 Kafka

    查看进程 ps -ef | grep kafka

    source /etc/profile 更新环境变量

    1、kafka-eagle概述

    为了简化开发者和服务工程师维护Kafka集群的工作有一个监控管理工具,叫做 Kafka-eagle。这个管理工具可以很容易地发现分布在集群中的哪些topic分布不均匀,或者是分区在整个集群分布不均匀的的情况。它支持管理多个集群、选择副本、副本重新分配以及创建Topic。同时,这个管理工具也是一个非常好的可以快速浏览这个集群的工具,

    2、环境和安装

    1、环境要求

    需要安装jdk,启动zk以及kafka的服务

    2、安装步骤

    1、下载源码包

    kafka-eagle官网:

    http://download.kafka-eagle.org/

    我们可以从官网上面直接下载最细的安装包即可kafka-eagle-bin-1.3.2.tar.gz这个版本即可

    代码托管地址:

    https://github.com/smartloli/kafka-eagle/releases

    2、解压

    这里我们选择将kafak-eagle安装在第三台

    直接将kafka-eagle安装包上传到hadoop03服务器的/export/softwares路径下,然后进行解压

    hadoop03服务器执行一下命令进行解压

    cd /export/softwares/

    tar -zxvf kafka-eagle-bin-1.3.2.tar.gz -C /export/servers/

    cd /export/servers/kafka-eagle-bin-1.3.2

    tar -zxvf kafka-eagle-web-1.3.2-bin.tar.gz

    3、准备数据库

    kafka-eagle需要使用一个数据库来保存一些元数据信息,我们这里直接使用msyql数据库来保存即可,在hadoop03服务器执行以下命令创建一个mysql数据库即可

    进入mysql客户端

    mysql -uroot -p

    create database eagle;

    4、修改kafak-eagle配置文件

    hadoop03执行以下命令修改kafak-eagle配置文件

    cd /export/servers/kafka-eagle-bin-1.3.2/kafka-eagle-web-1.3.2/conf

    vim system-config.properties

    kafka.eagle.zk.cluster.alias=cluster1,cluster2

    cluster1.zk.list=hadoop01:2181,hadoop02:2181,hadoop03:2181

    cluster2.zk.list=hadoop01:2181,hadoop02:2181,hadoop03:2181

    kafka.eagle.driver=com.mysql.jdbc.Driver

    kafka.eagle.url=jdbc:mysql://hadoop03:3306/eagle

    kafka.eagle.username=root

    kafka.eagle.password=123456

    5、配置环境变量

    kafka-eagle必须配置环境变量,hadoop03服务器执行以下命令来进行配置环境变量

    vim /etc/profile

    export KE_HOME=/export/servers/kafka-eagle-bin-1.3.2/kafka-eagle-web-1.3.2

    export PATH=:KEHOME/bin:KE_HOME/bin:PATH

    6、启动kafka-eagle

    cd /export/servers/kafka-eagle-bin-1.3.2/kafka-eagle-web-1.3.2/

    bin/ke.sh start

    访问kafka-eagle

    http://hadoop03:8048/ke/

    用户名:admin

    密码:123456

    出bug原因:

    1.改了配置没保存,导致端口有问题

    2.改了环境变量需要刷新环境变量配置文件:

    source /etc/profile 更新环境变量

    3.改了kafka配置文件需要重启kafka,才能导致配置文件生效

    展开全文
  • Kafka是一个高性能分布式消息系统,今天就简单介绍下基础入门吧。一、下载安装可以访问... cd kafka_2.12-2.2.0二、启动服务器Kafka使用z...
  • 安装Zookeeper 下载地址:https://zookeeper.apache.org/releases.html 下载后,解压放在目录D:bigdata(本文所用的目录)下,关于zookeeper以及kafka的目录,路径中最好不要出现空格,比如D:Program Files,尽量...
  • 使用java -version命令来查看当前JDK的版本,示例如下:C:甥敳獲hidden> java -versionjava version "1.8.0_112"Java(TM) SE Runtime Environment (build 1.8.0_112-b15)Java HotSpot(TM) 64-Bit Se...
  • I 概述kafka名字由来:Franz Kafka 弗兰兹·卡夫卡,奥匈帝国作家,西方现代主义文学先驱和大师。最初由Linkedin公司开发,是一个分布式、支持分区的(partition)、多副本的(replica),基于zookeeper协调的流处理平台...
  • Kafka是一种高吞吐量的分布式发布订阅消息系统,从本章开始我们先极速体验,再实战docker下搭建kafka环境,最后开发一个java web应用来体验kafka服务。我们一起用最快的速度体验kafka的消息发布订阅功能:新建一个...
  • 本文主要是描述Kafka如何安装以及集群如何配置,主要分为两部分:Kafka的单机是如何安装的;ZooKeeper集群如何配置;Kafka的集群是如何配置的。第一、Kafka单机的安装。1、从apache官网下载Kafka安装包。2、打开准备...
  • 搭建Kafka 首先在官网下载安装包: 解压,打开/config/server.properties配置文件,修改日志目录: log.dirs=./logs 首先启动ZooKeeper,我用的是3.6.1版本: 接着再启动Kafka,在Kafka的bin目录下打开cmd,输入命令:...
  • 后台挂载启动kafka命令 nohup bin/kafka-server-start.sh config/server.properties 1>/dev/null 2>&1 & kafka配置文件:server.properties 有可能要修改ip地址(host.name) ------------------------------------...
  • Kafka启动关闭及其相关命令

    万次阅读 2018-09-26 09:24:56
    开启zookeeper命令(备注:先进入zookeeper的bin目录) ./zkServer.sh start 关闭zookeeper命令(备注:先进入...Kafka启动命令(备注:先进入kafka目录) 常规模式启动kafka bin/kafka-server-start.sh config/serve...
  • Kafka启动命令 注:先进入kafka目录 1)常规模式启动kafka bin/kafka-server-start.sh config/server.properties 2)进程守护模式启动kafka nohup bin/kafka-server-start.sh config/server.properties >/dev...
  • Kafka常用命令

    千次阅读 2018-07-14 19:05:53
    kafka启动命令 # 指定对应的配置文件启动 kafka-server-start.sh /hadoop/kafka/config/server.properties # -daemon 以后台的方式启动 kafka-server-start.sh -daemon /hadoop/kafka/config/server.properties ...
  • kafka 常用命令

    2021-03-09 10:31:35
    开启zookeeper命令(备注:先进入...Kafka启动命令(备注:先进入kafka目录) 常规模式启动kafka bin/kafka-server-start.sh config/server.properties 进程守护模式启动kafka nohup bin/kafka-server-start.sh c

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 1,262
精华内容 504
关键字:

kafka启动命令