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

    千次阅读 2019-12-29 19:48:33
    1、启动zookeeper docker run -d -p 2181:2181 --name zk ...2、启动kafka docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.0.131:2181 -e KAFKA_ADVERTISED_L...

    1、启动zookeeper

    docker run -d -p 2181:2181 --name zk zookeeper
    

    2、启动kafka

    docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.0.131:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.0.131:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -v /etc/localtime:/etc/localtime wurstmeister/kafka
    

    2.1 创建主题

    # 首先进入kafka容器
    docker exec -it kafka bash
    
    # 切换到kafka所在的目录
    cd cd /opt/kafka_2.12-2.4.0/
    
    # 创建topic
    bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
    
    展开全文
  • 后台启动kafka

    万次阅读 2017-06-08 10:22:05
    前台启动kafka: ./kafka-server-start.sh ../config/server.properties 后台启动kafka: ./kafka-server-start.sh ../config/server.properties 1>/dev/null 2>&1 &
    前台启动kafka:

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


    后台启动kafka:

    ./kafka-server-start.sh ../config/server.properties 1>/dev/null 2>&1 &
    
    
    指定监听端口
    JMX_PORT=2898 ./
    kafka-server-start.sh ../config/server.properties 1>/dev/null 2>&1 &

    展开全文
  • 使用kafka内置的zookeeper启动kafka –打开zookeeper D:\tool\kafka\kafka_2.12-2.3.0\bin\windows\zookeeper-server-start.bat D:\tool\kafka\kafka_2.12-2.3.0\config\zookeeper.properties –打开kafka D:\...

    使用kafka内置的zookeeper启动kafka命令

    windows系统启动kafka的命令
    1.打开zookeeper

    D:\tool\kafka\kafka_2.12-2.3.0\bin\windows\zookeeper-server-start.bat D:\tool\kafka\kafka_2.12-2.3.0\config\zookeeper.properties

    2.打开kafka

    D:\tool\kafka\kafka_2.12-2.3.0\bin\windows\kafka-server-start.bat D:\tool\kafka\kafka_2.12-2.3.0\config\server.properties

    3.创建主题topic

    D:\tool\kafka\kafka_2.12-2.3.0\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

    4.验证主题topic

    D:\tool\kafka\kafka_2.12-2.3.0\bin\windows\kafka-topics.bat --zookeeper localhost:2181 --describe --topic test

    5.查看主题

    D:\tool\kafka\kafka_2.12-2.3.0\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

    6.运行生产者

    D:\tool\kafka\kafka_2.12-2.3.0\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

    7.启动消费者

    D:\tool\kafka\kafka_2.12-2.3.0\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

    展开全文
  • windows 启动kafka

    千次阅读 2017-11-21 18:28:45
    不提供 zookeeper 和 kafka 安装过程  启动 zookeeper 之后  进入 kafka安装目录 右键 打开... 1. 启动kafka 服务:.\bin\windows\kafka-server-start.bat .\config\server.properties   

      不提供  zookeeper 和 kafka 安装过程



      启动  zookeeper 之后


      进入  kafka安装目录  右键 打开命令行:


       下面四个需要四个命令窗口打开


     1. 启动kafka 服务:.\bin\windows\kafka-server-start.bat .\config\server.properties 

     2.  创建一个topic :  .\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic xxx

    3. 创建一个生产者:.\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic xxx

    4. 创建一个消费者: .\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic xxx


    5: 在生产者窗口  填写信息回车,回在 消费者窗口看到


    展开全文
  • 通过docker启动kafka

    2020-09-24 14:58:11
    我们知道kafka对zk有强依赖,所以要启动kafka镜像,除了kafka的image外,还要准备zookeeper镜像哦,通过pull拉去吧 正式开始 拉去的两个镜像文件如下 启动zk docker run -d -p 2181:2181 --name zk zookeeper ...
  • 启动kafka报错

    千次阅读 2019-07-28 22:47:00
    执行启动kafka服务的命令时报错:nohup bin/kafka-server-start.sh config/server.properties 2>&1 & [2019-07-28 12:58:44,760] ERROR [ReplicaManager broker=1] Error while making broker the ...
  • 从新使用以下命令启动kafka docker run -d --name kafka --publish 9092:9092 --link zookeeper --env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 --env KAFKA_ADVERTISED_HOST_NAME=localhost --env KAFKA_...
  • 设置开机启动Kafka

    千次阅读 2019-01-04 13:21:34
    设置开机启动Kafka 1)在/etc/rc.d/init.d自己新建一个kafka文件,内容如下(将下列文件的地址改为自己的地址) #!/bin/bash chkconfig: 2345 10 90 description: kafkaService … export JRE_HOME=/usr/java/...
  • 3.启动Kafka步骤

    2018-12-11 22:44:28
    1.启动zk cd zookeeper-3.4.10/ ...2.启动kafka cd kafka_2.11-0.9.0.1/ kafka-server-start.sh $KAFKA_HOME/config/server.properties 3.创建topic bin/kafka-topics.sh --create --zookeeper lo...
  • Linux启动Kafka

    2020-12-06 14:58:04
    1.下载Kafka到本地 https://kafka.apache.org/downloads 一定要下载Binary downloads: 版本 src还要你编译,别了吧 2.解压kafka tar -zxvf kafka的压缩包.tar.gz 3.修改配置文件(可选) ...4.启动Kafk
  • 问题 kafka-server-start.sh config/...启动kafka时报如下错误: /usr/local/kafka/kafka_2.11-1.1.0/bin/kafka-run-class.sh:行271: /usr/lib/jvm/java-1.8.0-openjdk-1.8.0.151-5.b12.el7_4.x86_64//bin/j...
  • 在自己电脑上跑了单台kafka, 之后尝试启动kafka connect,会启动失败, 因为启动的时候会创建config.storage.topic, offset.storage.topic, status.storage.topic相应的Topic; 默认创建这3个Topic时, 副本个数都为3, ...
  • 这是因为kafka logs目录下的meta.properties文件中的broker.id与server.properties中的broker.id不一致所导致,只需把两者改为一致启动kafka后就不会自动挂掉了
  • windows下启动kafka

    2020-08-14 17:56:21
    kafka 与zookeeper 对应版本 kafka版本 springboot版本 kafka_2.12-2.4.0 zookeeper-3.5.6.jar kafka_2.12-2.3.1 zookeeper-3.4.14.jar springboot2.2.2 kafka_2.12-2.3.0 zookeeper-3.4.14.jar ...
  • 启动kafka秒退

    千次阅读 2018-08-11 23:08:15
    (2) kafka需要大量内存,磁盘内存不足,kafka无法启动,默认启动为1G 解决: (1)free -h 查看内存使用率 如果free不够1G,就需要更改kafka启动参数 (2)进到kafka的bin目录下修改kafka-server-start.sh ...
  • intellij启动kafka失败

    2017-06-18 03:05:04
    Exception in thread "main" java.lang.NoClassDefFoundError: Kafka/Kafka (wrong name: kafka/Kafka)
  • kafka 使用kerberos协议的时候,启动kakfa的时候报zookeeper校验不通过。 错误信息如下:![图片说明](https://img-ask.csdn.net/upload/201902/02/1549098295_69981.png) kerberos的用户密钥:![图片说明]...
  • Linux下启动kafka时失败,提示错误为: Java OpenJDK(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x000000c0000000, 4096, 0) failed; error='Cannot allocate memory' (errno=12) 网上查找原因为:...
  • kafka单机集群,在kafka-server-start.sh文件中添加export JMX_PORT="9999"这种方法不适用 因为这样只会启动一个kafka,可以通过 ps -ef|grep kafka 命令看到只有一个kafka进程 ...
  • 启动kafka的时候报错:count not reserve enough space for 1048576KB object heap 原因是:kafka启动需要占用大量jvm堆内存。 解决办法: 1.查看下本机的JDK版本,cmd 下运行 java -version 2.找到使用的jdk...
  • 1 后台启动Kafka: $ nohup kafka-server-start.sh /home/espai/kafka/config/server.properties 1>/dev/null 2>&1 & 2 后台启动Flume: 首位也要加上nohup  ...
  • 背景 在学习Flink的流处理API...在启动Kafka的服务器时,报了一堆错误,关键的错误如下 java.io.IOException: Map failed at sun.nio.ch.FileChannelImpl.map(FileChannelImpl.java:944) at kafka.log.Abstract...
  • 启动kafka保错:命令过长语法不正确

    千次阅读 2019-11-07 10:16:49
    这个问题的解决方法就是:把kafka的目录从桌面移到别处,因为目录层级太深或者是目录名字太长导致的。比如放到D盘根目录下,这样就OK了。...在启动kafka kafka-server-start.bat ../../config/server.p...
  • 先说问题,前段时间用到消息队列kafka, win10下在首次启动kafka: .\bin\windows\kafka-server-start.bat .\config\server.properties 过程中遇到一个问题:系统找不到指定文件. 解决办法: 遇到这个问题一般是...
  • 1. 下载KafkaKafka官网下载最新的Kafka,目前我下载的版本为kafka_2.10-0.8.1.1.tgz ...3. 修改Zookeeper服务器配置,并启动 cd kafka_2.10-0.8.1.1 vi config/zookeeper.properties #修改ZooKe
  • linux下启动kafka

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

    千次阅读 2018-05-09 17:43:28
    ./bin/kafka-server-start.sh -daemon config/server.properties &我尝试过这样./bin/kafka-server-start.sh config...启动kafka,这样nohup ./bin/kafka-server-start.sh config/server.properties &...
  • Linux下安装并(单节点)配置启动Kafka genuinecx关注0人评论9838人阅读2016-04-08 11:21:58 1. 从Kafka官网下载最新的Kafka,目前最新版本为0.9.0.1   2. 下载完毕后,上传到Linux服务器,并解压 tar -xvzf ...

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 84,627
精华内容 33,850
关键字:

如何启动kafka