kafka的一些命令在不同版本已经不一样了 至少是在2.12-3.0.1这个版本创建一些东西已经不依赖zookeeper参数 所以要慢慢自己学习
下载kafka
wget https://archive.apache.org/dist/kafka/2.5.0/kafka_2.12-2.5.0.tgz
我自己放在了目录
/usr/local/kafka_2.12-2.5.0
修改配置文件 配置文件路径 /usr/local/kafka_2.12-2.5.0/config/server.properties
修改的配置是，192.168.145.135 修改成你自己机器的ip地址
advertised.listeners=PLAINTEXT://192.168.145.135:9092
&符号表示后台运行
启动zookeeper 进入/usr/local/kafka_2.12-2.5.0/bin
./zookeeper-server-start.sh ../config/zookeeper.properties &
启动kafka 进入/usr/local/kafka_2.12-2.5.0/bin
./kafka-server-start.sh ../config/server.properties &
创建一个topic
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic gpsbus
查看topic创建的结果
./kafka-topics.sh --list --zookeeper localhost:2181
