1、下载Kafka
下载地址：https://kafka.apache.org/downloads
1
2
3
| 1wget http://mirrors.hust.edu.cn/apache/kafka/2.0.0/kafka_2.11-2.0.0.tgz
2
3 |
解压：
1
2
3
4
5
| 1tar -zxvf kafka_2.11-2.0.0.tgz
2
3cd /usr/local/kafka_2.11-2.0.0/
4
5 |
2、修改配置
把config/server.properties中advertised.listeners设置为服务器的IP，可使用ping命令查看IP。
1
2
3
| 1advertised.listeners=PLAINTEXT://120.25.173.32:9092
2
3 |
3、启动
启动zookeeper
1
2
3
| 1bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
2
3 |
启动kafka
1
2
3
| 1bin/kafka-server-start.sh config/server.properties
2
3 |
4、创建TOPIC
1
2
3
| 1bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
2
3 |
查看 topic 列表：
1
2
3
| 1bin/kafka-topics.sh --list --zookeeper localhost:2181
2
3 |
5、发送消息
1
2
3
| 1bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
2
3 |
6、消费消息
1
2
3
| 1bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
2
3 |
大功告成！
