zoukankan      html  css  js  c++  java
  • kafka安装配置

    ### 下载KAFKA
    ```
    http://kafka.apache.org/downloads
    ```
    <hr><br>

    ### 解压并修改配置文件
    * vim config/server.properties

    ```
    #broker的全局唯一编号,不能重复
    broker.id=0

    #用来监听链接的端口,producer或consumer将在此端口建立链接
    port=9092

    #处理网络请求的线程数量
    num.network.threads=3

    #用来处理磁盘IO的线程数量
    num.io.threads=8

    #发送套接字的缓冲区大小
    socket.send.buffer.bytes=102400

    #接收套接字的缓冲区大小
    socket.receive.buffer.bytes=102400

    #请求套接字的缓冲区大小
    socket.request.max.bytes=104857600

    #日志存放路径
    log.dirs=/home/hadoop/logs/kafka

    #topic在当前broker上的分片数量
    num.partitions=2

    #恢复和清理data下数据的线程数量
    num.recovery.threads.per.data.dir=1

    #segment文件保留的最长时间(超时将被删除)
    log.retention.hours=168

    #滚动生成新segment文件的最大时间
    log.roll.hours=168

    ```

    ### 分发文件,修改配置文件
    * 依次修改各服务器上配置文件的的broker.id,不可重复

    ### 启动KAFKA
    ```
    ./bin/kafka-server-start.sh config/server.properties
    ```

    ### 异常
    * 下错KAFKA文件。如果下载的是src文件会报该异常

    ```
    [hadoop@slave2 kafka-0.10.2.0-src]$ ./bin/kafka-server-start.sh config/server.properties
    Error: Could not find or load main class config.server.properties

    ```

  • 相关阅读:
    java数据类型
    如何判断数组
    git 常用命令
    如何配置 ESLint 工作流
    Lambda表达式和函数式接口
    面向对象(多态与内部类)
    面向对象(封装与继承)
    面相对像(基础)
    break;怎么跳出外部循环
    面向对象(类与对象)
  • 原文地址:https://www.cnblogs.com/0xcafedaddy/p/6753209.html
Copyright © 2011-2022 走看看