解压

tar -xf kafka_2.11-2.0.0.tgz

修改配置文件

vi /kafka_2.11-2.0.0/config/server.properties

修改配置文件

advertised.listeners=PLAINTEXT://192.168.3.201:9092 # 公布访问地址和端口 192.168.3.201 是你安装kafka的主机地址
zookeeper.connect= 192.168.199.124:2181 #依赖的zookeeper的地址(在下安装的是192.168.199.124这台主机)
broker.id=  #订阅id
log.dir= #日志目录

启动kafka

/kafka_2.11-2.0.0/bin/kafka-server-start.sh /kafka_2.11-2.0.0/config/server.properties

检测是否启动

netstat -tunlp | egrep "(2181|9092)"

创建主题

/kafka_2.11-2.0.0/bin/kafka-topics.sh --create --zookeeper 192.168.199.124:2181 --replication-factor 1 --partitions 1 --topic test

创建生产者

/kafka_2.11-2.0.0/bin/kafka-console-producer.sh --broker-list 192.168.199.124:9092 --topic test

创建消费者

/kafka_2.11-2.0.0/bin/kafka-console-consumer.sh --bootstrap-server 192.168.199.124:9092 --topic test --from-beginning