linux安装kafka

一、下载KAFKA安装包

Apache官网 http://kafka.apache.org/downloads.html



二、上传并且解压KAFKA安装包

tar -xzf kafka_2.10-0.8.2.2.tgz

cd kafka_2.10-0.8.2.2


三、启动服务

KAFKA需要启动两个服务:

1,启动zookeeper:bin/zookeeper-server-start.sh config/zookeeper.properties & (&能在执行指令时退出操作)

2,启动kafka:bin/kafka-server-start.sh config/server.properties &



四、测试

1,创建topic

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

创建一个名为test的topic,只有一个副本,一个分区。

2,创建生产者,启动producer

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

topic要对应之前创建的topic

之后便可以发送消息

3,创建消费者,启动consumer

bin/kafka-console-consumer.sh --zookeeper 10.202.4.179:2181 --topic test --from-beginning

topic要对应之前创建的topic

在生产者发送消息后,消费者便可以收到对应的消息了


五、server.properties,zookeeper.properties配置介绍

http://blog.csdn.net/suifeng3051/article/details/48053965

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容