首页 笔记 图片 查字 
所属分类:Kafka
浏览:37
内容:

参考:
https://kafka.apache.org/downloads
https://kafka.apache.org/quickstart
https://blog.csdn.net/zhangjunli/article/details/133981972
https://www.cnblogs.com/ElEGenT/p/12891114.html

要点:
1、下载解压
wget  https://downloads.apache.org/kafka/3.6.1/kafka_2.12-3.6.1.tgz
tar -xzf kafka_2.13-3.6.1.tgz
cd kafka_2.13-3.6.1

2、检测端口是否被占用:
netstat -anp  | grep  9092

3、配置

kafka自带的zookeeper配置,这个配置可以不考虑。
vim  config/zookeeper.properties
修改
dataDir=/data/zk_data
clientPort=2182
admin.serverPort=8082

vim  config/server.properties
修改
broker.id=10
## 以下两个listeners的host配置一样
listeners=PLAINTEXT://127.10.10.123:9093
advertised.listeners=PLAINTEXT://127.10.10.123:9093
zookeeper.connect=127.0.0.1:2182
log.dirs=/data/kafka_data

4、启动
bin/kafka-server-start.sh  config/server.properties 
daemon启动命令:
bin/kafka-server-start.sh -daemon config/server.properties

5、停止
bin/kafka-server-stop.sh

6、列出所有主题
bin/kafka-topics.sh --list --bootstrap-server 127.0.0.1:9093

7、创建主题
bin/kafka-topics.sh --create --bootstrap-server 127.0.0.1:9093 --replication-factor 1 --partitions 1 --topic test

8、查看主题信息
bin/kafka-topics.sh --describe --bootstrap-server localhost:9093 --topic test