kafka权威指南 第二章第2节：安装kafka Broker

问题导读
1.kafka安装需要做哪些操作？
2.如何验证kafka是否安装成功？
3./tmp/kafka-logs的作用是什么？




Java和zookeeper配置完毕，你可以安装kafka.软件下载http://kafka.apache.org/downloads.html。这里下载的版本为0.9.0.1，Scala 版本2.11.0.下面的例子安装kafka在 /usr/local/kafka，开始之前配置使用zookeeper server和在/tmp/kafka-logs路径下存储消息日志.
[mw_shl_code=bash,true]# tar -zxf kafka_2.11-0.9.0.1.tgz
# mv kafka_2.11-0.9.0.1 /usr/local/kafka
# mkdir /tmp/kafka-logs
# export JAVA_HOME=/usr/java/jdk1.8.0_51
# /usr/local/kafka/bin/kafka-server-start.sh -daemon
/usr/local/kafka/config/server.properties
#

[/mw_shl_code]
一旦Kafka  broker 启动，我们可以创建test topic，来验证是否工作。

创建验证topic:
[mw_shl_code=bash,true]# /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181
--replication-factor 1 --partitions 1 --topic test[/mw_shl_code]
创建topic "test".
[mw_shl_code=bash,true]# /usr/local/kafka/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
#[/mw_shl_code]

在topic下面，生产者产生消息
[mw_shl_code=bash,true]# /usr/local/kafka/bin/kafka-console-producer.sh --broker-list
localhost:9092 --topic test
Test Message 1
Test Message 2
^D
#[/mw_shl_code]
在test topic下面消费消息

[mw_shl_code=bash,true]# /usr/local/kafka/bin/kafka-console-consumer.sh --zookeeper
localhost:2181 --topic test --from-beginning
Test Message 1
Test Message 2
^C
Consumed 2 messages
#[/mw_shl_code]

感谢分享