2.2 安装Kafka Broker

配置好Java和Zookeeper之后，接下来就可以安装Kafka了。可以从http://kafka.apache.org/downloads.html下载最新版本的Kafka。截至本书写作时，Kafka的版本是0.9.0.1，对应的Scala版本是2.11.0。

下面的例子将Kafka安装在/usr/local/kafka目录下，使用之前配置好的Zookeeper，并把消息日志保存在/tmp/kafka-logs目录下。

        # 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
        #

一旦Kafka创建完毕，就可以对这个集群做一些简单的操作来验证它是否安装正确，比如创建一个测试主题，发布一些消息，然后读取它们。

创建并验证主题：

        # /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181
        --replication-factor 1--partitions 1--topic test
        Created topic "test".
        # /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
        #

往测试主题上发布消息：

        # /usr/local/kafka/bin/kafka-console-producer.sh --broker-list
        localhost:9092--topic test
        Test Message 1
        Test Message 2
        ^D
        #

从测试主题上读取消息：

        # /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
        #