linux 安装kafka

linux 安装kafka

一、下载

地址：http://kafka.apache.org/downloads

二、安装

2.1解压

tar -xzvf 刚刚下载的包

2.2 修改config 目录下的server.properties文件

broker.id=0

port=9092 #端口号

host.name=localhost #单机可直接用localhost 如果要外网连接得改为Linux的ip

log.dirs=/日志存放路径 #日志存放路径可修改可不修改

zookeeper.connect=localhost:2181 #zookeeper地址和端口，单机配置部署，localhost:2181

2.3修改zookeeper.properties文件

dataDir=/数据目录  #zookeeper数据目录  (可以修改可以不修改)

dataLogDir=/日志目录 #zookeeper日志目录 （可以修改可以不修改）

clientPort=2181

maxClientCnxns=100

tickTime=2000

initLimit=10

三、启动

编写一个.sh文件来启动

#!/bin/bash

#启动zookeeper

/kafka的目录/bin/zookeeper-server-start.sh /kafka的目录/config/zookeeper.properties &

sleep 3  #默默等3秒后执行

#启动kafka

/kafka的目录/bin/kafka-server-start.sh /kafka的目录/config/server.properties &

设置可以执行权限

chmod +x（启动脚本名称）

启动kafka 先启动zookeeper

四、topic

4.1创建 topic

命令：在kafka 目录下bin目录下执行：

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

4.2查询创建的top主题

命令：在kafka 目录下bin目录下执行：

./kafka-topics.sh --list --zookeeper localhost:2181

4.3删除创建的topic

命令：在kafka 目录下bin目录下执行：

./kafka-topics.sh --delete --zookeeper localhost:2181 --topic   要删除的topic名称

五、测试

5.1 开启生产者

命令：在kafka 目录下bin目录下执行：

./kafka-console-producer.sh --broker-list localhost:9092 --topic test（要启动生成者的topic名称）

5.2开启消费者

命令：在kafka 目录下bin目录下执行：

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

 （要启动生成者的topic名称）

生产者 输入字符，消费者会显示

linux 安装kafka

原文：https://www.cnblogs.com/kali5k/p/13553294.html