高并发架构实战(十) Kafka的安装与使用

2018-01-10

架构高并发架构实战 Kafka

1、下载Kafka

1	wget http://mirrors.hust.edu.cn/apache/kafka/2.0.0/kafka_2.11-2.0.0.tgz

解压：

1
2
3

tar -zxvf kafka_2.11-2.0.0.tgz

cd /usr/local/kafka_2.11-2.0.0/

把config/server.properties中advertised.listeners设置为服务器的IP，可使用ping命令查看IP。

1	advertised.listeners=PLAINTEXT://120.25.173.32:9092

1	bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

1	bin/kafka-server-start.sh config/server.properties

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

查看 topic 列表：

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

1	bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

可以在另一台机子上，启动kafka后，执行消费消息的命令：

1	bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

–from-beginning 代表从头开始消费消息。
在生产端发送消息，可以在消费端收到消息。

大功告成！

本文由 lilyssh创作。可自由转载、引用，但需署名作者且注明文章出处。

能看到这的都是真爱，打个赏呗=。=