zoukankan      html  css  js  c++  java
  • kafka单机部署文档

    单机Kafka部署文档

    最简单的使用方式,单机,使用自带的zookeeper

    1.解压

    tar –zxvf kafka_2.10-0.10.0.1.tgz

    2.修改配置

    vim config/server.properties
    修改项如下(有则修改,无则添加):
    host.name=你的ip
    listeners=PLAINTEXT://你的ip:9092
    advertised.listeners=PLAINTEXT://你的ip:9092
    zookeeper.connect=你的ip:2181

    3.启动 (nohub 和 最后的 &都是为了后台启动,避免ctrl+c 或者关闭链接而kill)

    启动zookeeper:nohup bin/zookeeper-server-start.sh config/zookeeper.properties 1>zookeeper.log 2>zookeeper.err &
    启动kafka:nohup bin/kafka-server-start.sh config/server.properties &

    4.创建topic 并查看

    创建topic:bin/kafka-topics.sh --create --topic test --replication-factor 1 --partitions 1 --zookeeper Slave1:2181
    查看list:bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list

    5.验证(收发消息)

    发:bin/kafka-console-producer.sh --broker-list 你的IP:9092 –topic test
    收:bin/kafka-console-consumer.sh --zookeeper  127.0.0.1:2181  --from-beginning --topic test

    6.可能存在的问题

    启动失败
    1. 报错说没有log.dirs=/tmp/kafka-logs,这个目录没有写权限,这时就得ll检查一下权限了,比如我用root安装,用work启动,就会遇到此问题
    2. 收不到消息:连不上zookeeper,但是zookeeper进程在,可能是因为 步骤2 没有修改IP,原因是kafk会自动获取,可能会获取出错。
    3. 假死:进程在,但是无法使用,或者调用 bin/zookeeper-server-stop.sh 和bin/kafka-server-stop.sh后进程依然在,就ps –ef | grep kafka , ps –ef | grep zookeeper手动kill -9 一下
  • 相关阅读:
    函数与导数部分的题型梳理
    构造函数习题1
    破解构造函数问题
    函数的值域
    函数的定义域
    高三数学微课堂
    Redux Todos Example
    Linux下查看Nginx安装目录、版本号信息及当前运行的配置文件
    antd的Tree控件实现点击展开功能
    Redux Counter example
  • 原文地址:https://www.cnblogs.com/peak-c/p/7097908.html
Copyright © 2011-2022 走看看