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

    千次阅读 2017-08-23 23:23:03
    KAFKA启动配置

    这里推荐一个讲解十分通俗易懂的KAFKA中文教程orchome.com/6
    按照教程逐步操作基本不会遇见什么问题,但是作为一个小白还是会犯各种低级的错误,先记录如下:

    未识别主机名

    运行kafka需要使用Zookeeper,所以你需要先启动Zookeeper

    运行语句:
    sudo bin/zookeeper-server-start.sh config/zookeeper.properties
    

    启动zookeeper后,启动KAFKA服务

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

    这个时候报错,因为未识别主机名,KAFKA服务被迫停止

    问题表现:localhost识别出的主机名为登录名,但是这个登录名系统识别不出。
    
    问题分析:既然系统识别不出主机名,说明这个主机名映射不出对应IP。查看/etc/hosts,结果如下:
    127.0.0.1 localhost localhost.localhostadmin ....
    : : : 1 localhost localhost.localhostadmin...
    
    文件内容结构分为三部分:IP + 主机名 + 别名
    
    修改内容为:127.0.0.1 localhost 未识别主机名
    

    再次启动,成功!!!


    设置多个broker集群时,报错Configured brokerID 2 doesn’t match stored brokerID 1 in meta.properties

    问题分析:这个问题发生在创建第二个broker时,与已经启动的第一个broker发生冲突,初步判断是配置问题,而且必定从meta.properties入手
    
    问题解决:首先逐步排查配置文件,目前涉及到的配置文件有:server.properties, server-1.properties, server-2.properties
    果然其中server-1.properties配置错误,修改过来之后,还要对报错信息中对应的meta.properties文件进行brokerID的修改,这个文件位于配置的log.dir路径下。
    

    再次启动,成功!!!

    展开全文
  • Kafka启动

    2021-01-18 11:51:31
    1.启动zk D:\>cd D:\Java\Kafka\apache-zookeeper-3.6.2-bin\bin D:\Java\Kafka\apache-zookeeper-3.6.2-bin\bin>zkServer.cmd 2.进入D:\Java\Kafka\kafka_2.13-2.6.0目录 kafka根目录下打开powershell 输入...

    1.启动zk
    D:\>cd D:\Java\Kafka\apache-zookeeper-3.6.2-bin\bin
    D:\Java\Kafka\apache-zookeeper-3.6.2-bin\bin>zkServer.cmd


    2.进入D:\Java\Kafka\kafka_2.13-2.6.0目录
    kafka根目录下打开powershell 输入.\bin\windows\kafka-server-start.bat .\config\server.properties

    启动/关闭kafka(D:\Java\Kafka\kafka_2.13-2.6.0\bin)

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

    .\windows\kafka-server-stop.bat ..\config\server.properties
     

    展开全文
  • KafKa 启动

    千次阅读 2019-03-25 10:02:00
    运行kafka需要使用Zookeeper,所以要先启动Zookeeper,如果没有Zookeeper,可以使用kafka自带打包和配置好的Zookeeper 1、进入kafka的bin目录,输入以下命令: ./zookeeper-server-start.sh ../config/zookeeper...

     

    Zookeeper

    运行kafka需要使用Zookeeper,所以要先启动Zookeeper,如果没有Zookeeper,可以使用kafka自带打包和配置好的Zookeeper

    1、进入kafka的bin目录,输入以下命令:

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

     

    Kafka

    1、进入bin目录,录入以下命令:

    ./kafka-server-start.sh ../config/server.properties
    --后台启动
    nohup ./kafka-server-start.sh ../config/server.properties &

     2、启动成功后,会输出以下信息:

     

    Kafka-Manager

    1、进入bin目录,录入以下命令:

    ./kafka-manager -Dconfig.file=../conf/application.conf


    --后台启动
    nohup ./kafka-manager -Dconfig.file=../conf/application.conf &

    2、启动成功后,会输出以下信息:

    kafka manger  默认端口9000,kafka-manager程序依赖的是play framework框架。程序启动后,会在主目录生成一个RUNNING_PID文件(程序的pid),重启时,需要删删掉这个文件。

     

    3、访问地址:http://172.xx.xx.61:9000/

    4、kafka manger 中管理kafka

      进入kafka manager 页面,点击cluster > add cluster 

      name 输入如:pet_kafka_trace_cluster

      Cluster Zookeeper Hosts输入:172.xx.xx.68:2182,172.xx.xx.68:2182

     

      

     

    转载于:https://www.cnblogs.com/caoweixiong/p/10592134.html

    展开全文
  • kafka启动

    2017-01-20 15:32:12
    [root@localhost kafka_2.10-0.9.0.1]# cat kafkaCommand #zoopkeeper start ./bin/zookeeper-server-start.sh config/zookeeper.properties& #kafka start ./bin/kafka-server-start.sh config/server.propertie
    ./bin/kafka-topics  --delete --zookeeper 【zookeeper server】  --topic 【topic name】[root@localhost kafka_2.10-0.9.0.1]# cat kafkaCommand 
    #zoopkeeper start
    
    ./bin/zookeeper-server-start.sh config/zookeeper.properties&
    
    #kafka start
    ./bin/kafka-server-start.sh config/server.properties&
    
    #create topic
    ./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
    
    #show topic
    ./bin/kafka-topics.sh --list --zookeeper localhost:2181
    
    #send message 
    ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
    
    #rev message
    ./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
    
    #delete topic
    ./bin/kafka-topics  --delete --zookeeper localhost:2181  --topic test
    
    

    展开全文
  • 安装在mac上可以使用brew install kafka进行kafka的安装...启动kafka启动kafka,首先要确保启动zookpeer.进入kafka安装目录的bin目录下执行 ./zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &a...
  • KafKa启动报错

    2021-02-23 22:19:49
    KafKa 启动报错 报错信息: os::commit_memory(0x00000000c0000000, 1073741824, 0) failed; error='Cannot allocate memory' 查询原因: 内存不够, 修改配置的内存 # 查看kafka配置信息 vim kafka-server-start.sh ...
  • 自启动kafka,kafka启动是真的很麻烦。 所以 它 来了!! 第一步还是在 / 跟目录下 touch kf.sh创建一个脚本 然后 vim kf.sh修改脚本 添加内容代码如下: #! /bin/bash case $1 in "start"){ #这里是遍历你配置...
  • kafka启动报错&问题解决一早上班,就收到运维同事通知说有一台物理机宕机,导致虚拟机挂了。只得重启kafka服务器。1.启动启动zookeeperbin/zkServer.sh start conf/zoo.cfg &启动kafkabin/kafka-server-...
  • 一、kafka启动(linux环境) 1、单节点启动(非集群) (1)下载kafka安装包http://kafka.apache.org/downloads,我这里下载的是kafka_2.11-2.3.0.tgz (2)解压(不需要安装,直接配置可用) tar -xzvfkafka_...
  • kafka启动方式

    万次阅读 2018-12-19 15:35:03
    bin/kafka-server-start.sh -daemon config/server.properties 加守护进程启动 方法二: 在bin的上一级目录执行命令: nohup bin/kafka-server-start.sh config/server.properties & 通过后台来启动 ...
  • kafka启动不了,报错 Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) org.apache.kafka.common.errors.CorruptRecordException: Found record size 0 smaller than ...
  • Kafka启动错误

    2020-07-31 14:13:27
    Kafka启动错误:Socket server failed to bind to 49.234.143.64:9092: Cannot assign requested address. 在kafka的配置文件server.propertis里有这样一行属性: listeners=PLAINTEXT://localhost:9092 如果你这里...
  • kafka启动异常

    千次阅读 2019-07-26 22:32:31
    kafka启动异常 一、描述 由于在安装时有重装过,启动kafka时报broker的id对不上。 二、图解 三、问题解决思路 由于当时只是报了启动失败。。。。 1.查看启动日志,发现日志中报了一个broker的id对不上错误 四、实际...
  • 开始:首先在windows下启动kafka启动方法如下:首先下载kafka,zookeeper安装包:修改下为你配置的文件路径修改如图文件zookeeper启动:复制下面那个配置文件,重命名为zoo.cnf,然后启动就可以了在启动kafka不知道为什么...
  • 如图,点击kafka ,配置----KafkaMirrorMaker ,现在Topic Whiltelist白名单 重启kafka启动,解决无法启动MirrorMaker 的问题
  • kafka 启动失败

    千次阅读 2017-02-06 17:21:00
    单机版kafka 启动之后退出再次启动如遇到启动失败,可尝试将 /tmp 下对应的kafka-logsXXX文件删除 以下引用他人博客: Kafka重启的情况下会发生相应的错误,或者zookeeper之前上有kafka相应的数据。查看zookeeper...
  • ZooKeeper和Kafka 启动顺序
  • 通过Kafka启动命令启动Kafka无响应,每台机器的Zookeeper都已启动,但是Kafka无响应。或者出现 命令刚启动的时候jps可见kafka进程,但是过一点时间后又消失不见。 总是会报出Exit错误。 经过排查Kafka启动日志,...
  • Kafka启动脚本

    千次阅读 2016-08-15 15:52:11
    Kafka启动脚本./zookeeper-server-start.sh [-deamon] zookeeper.properties路径参数配置文件zookeeper.properties路径可选参数[-deamon]正常情况下启动kafka会有控制台输出,ctrl+c之后kafka就会停止带上此参数相当...
  • 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启动源码记录

    2019-06-21 12:16:07
    kafka启动命令: bin/kafka-server-start.sh -daemon config/server.properties 主要用到kafka-server-start.sh脚本和server.properties配置文件 查看kafka-server-start.sh寻找入口,可看到最后一行,猜测kafka....
  • kafka启动报错: FATAL Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) kafka.common.InconsistentBrokerIdException: Configured broker.id 1 doesn't match stored ...
  • kafka 启动的时候报错

    千次阅读 2018-03-10 22:48:38
    1. kafka 启动的时候报错了,生成了一个类似这样的日志文件hs_err_pid4301.log 主要原因原因:kafka启动脚本kafka-server-start.sh中指定了kafka启动时需要的最小内存,默认为1G export KAFKA_HEAP_OPTS="...
  • 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 启动 双击...
  • kafka启动停止脚本

    2018-11-24 19:52:34
    linux常见文件 cat>...kafka启动脚本 #!/bin/bash echo "start kafka>>>" #cd /home/software/kafka_2.11-0.11.0.3 bin/zookeeper-server-start.sh -daemon config/zookeeper.properti...
  • 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启动错误解决方案

    千次阅读 2019-08-16 17:16:34
    Kafka启动错误解决方案 Can't convert value of class com.alibaba.fastjson.JSONObject to class org.apache.kafka.common.serialization.StringSerializer specified in value.serializer 如下图所示: 这是...
  • kafka 启动报错 missingTopicsFatal is true

    千次阅读 2019-10-25 11:00:56
    kafka 启动报错:missingTopicsFatal is true 报错信息 org.springframework.context.ApplicationContextException: Failed to start bean 'org.springframework.kafka.config....
  • kafka启动命令,与BUG

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

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 7,460
精华内容 2,984
关键字:

kafka启动