kafka单机部署

喜欢ヅ旅行 2021-10-14 05:52 425阅读 0赞

1、下载kafka  
下载地址：http://kafka.apache.org/downloads

2、解压

tar -zxvf kafka_2.12-0.11.0.3.tgz  -C  /local/sda/kafka

3、使用kafka自带的zookeeper, 修改zookeeper.properties

cd /local/sda/kafka/kafka_2.12-0.11.0.3  #进入kafka主目录
    mkdir -p zk/data   #创建zookeeper数据存放目录
    mkdir -p zk/logs    #创建zookeeperl存放日志目录
    cd config       #进入配置文件所在目录
    
    # vim 修改zookeeper.properties :
    tickTime=2000
    dataDir=/local/sda/kafka/kafka_2.12-0.11.0.3/zk/data
    dataLogDir=/local/sda/kafka/kafka_2.12-0.11.0.3/zk/logs
    clientPort=2181
    ####################

4、修改server.properties

# 本地试运行，修改这两个就行
    listeners=PLAINTEXT://localhost:9092
    zookeeper.connect=localhost:2181

5、启动和停止

# 启动：
    ./zookeeper-server-start.sh -daemon ../config/zookeeper.properties    #启动zookeeper
    ./kafka-server-start.sh -daemon ../config/server.properties           #启动kafka
    
    # 停止
    ./zookeeper-server-stop.sh    #停止zookeeper
    ./kafka-server-stop.sh        #停止kafka，centos7上可能关不了用kill -9直接杀掉
    
    # jps查看是否有zookeeper和kafka进程
    jps

6.测试是否可用  
创建topics：

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

在一台上创建生产者：

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

在另一台上创建消费者：

./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

正常的话，生产者中输入的内容，会在消费者端输出。

附上kafka命令大全：  
[https://www.orchome.com/454][https_www.orchome.com_454]

[https_www.orchome.com_454]: https://www.orchome.com/454