[大数据]kafka安装

准备安装包

从官网下载kafka安装包，本次安装下载的kafka的版本是0.9.0.1，对应的scala版本是2.11.0。将安装包解压到/usr/local/kafka/目录下。使用配置好的 Zookeeper，并把消息日志保存在 /tmp/kafka-logs 目录下。

tar -zxf kafka_2.10-0.9.0.1.tgz -C /usr/local/kafka

启动kafka

./kafka-server-start.sh -daemon ../config/server.properties

创建并验证主题

[root@192 bin]# ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
Created topic "test".

[root@192 bin]# ./kafka-topics.sh --zookeeper localhost:2181 --describe --topic test
Topic:test	PartitionCount:1	ReplicationFactor:1	Configs:
	Topic: test	Partition: 0	Leader: 0	Replicas: 0	Isr: 0

往测试主题上发布消息

[root@192 bin]# ./kafka-console-producer.sh --broker-list localhost:9092 --topic test
Test Message 1
Test m

从测试主题上读取消息

[root@192 bin]# ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
Test Message 1
Test M