zookeeper+kafkaのインストール

1、準備
1.1、機械の準備

server1:10.40.33.11
server2:10.40.33.12
server3:10.40.33.13

1.2、ポート占有状況

zookeeper：2181,3888,4888
kafka：9092

1.3、ソフトウェアの準備

jdk1.7.0_51（     kafka-0.8.2.1    1.7      jdk）
zookeeper3.4.5（     ）
kafka_2.11-0.8.2.1（    ）

2、取り付け
2.1、zookeeperのインストール

1.  zookeeper
        ：http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz
2.  zookeeper
    server1,server2,server3    a,b,c  。
           ：$ZOOKEEPER_HOME=/home/sinova/zookeeper-3.4.6
    a.  
        tar -zxvf zookeeper-3.4.6.tar.gz
    b.  
         conf/zoo_sample.cfg       zoo.cfg，   conf   。              ：
            tickTime=2000
            initLimit=10
            syncLimit=5
            dataDir=/disk0/var/zookeeper/datas
            dataLogDir=/disk0/var/zookeeper/logs
            clientPort=2181
            server.1=10.40.33.11:3888:4888
            server.2=10.40.33.12:3888:4888
            server.3=10.40.33.13:3888:4888
    c.  myid  
      ：
        cd dataDir(/disk0/var/zookeeper/datas)
        echo 1 > myid
     ：1 zookeeper   id，serverX  X myid  。
3.    server1，server2,server3 zookeeper  
    ：       
    $ZOOKEEPER_HOME/bin/zkServer.sh start
    ：
    $ZOOKEEPER_HOME/bin/zkServer.sh stop
4.  zookeeper      ， server1       
    a.jps     QuorumPeerMain  
    b.$ZOOKEEPER_HOME/bin/zkCli.sh -server 192.168.0.2:2181

インストールkafka

1.  kafka
        ：http://mirror.bit.edu.cn/apache/kafka/0.8.2.1/kafka_2.11-0.8.2.1.tgz
2.  kafka
    server1,server2,server3    a,b  。
           ：$KAFKA_HOME=/home/sinova/kafka_2.11-0.8.2.1
    a.  
        tar -zxvf kafka_2.11-0.8.2.1.tgz
    b.  
          $KAFKA_HOME/conf/server.properties  ，          。
            broker.id=0#   id     
            port=9092
            num.network.threads=2
            num.io.threads=8
            socket.send.buffer.bytes=1048576
            socket.receive.buffer.bytes=1048576
            socket.request.max.bytes=104857600
            log.dirs=/disk0/var/kafka/logs#       
            num.partitions=2
            log.retention.hours=168
            log.segment.bytes=536870912
            log.retention.check.interval.ms=60000
        zookeeper.connect=10.40.33.11:2181,10.40.33.12:2181,10.40.33.13:2181/kafka
            log.cleaner.enable=false
            zookeeper.connection.timeout.ms=1000000
            delete.topic.enable=true
            queue.buffering.max.ms=5000ms
            queue.buffering.max.message=5000
     ：broker.id serverX  X   ，         。
3.    server1，server2,server3 kafka  
        ：
        cd $KAFKA_HOME
        nohup bin/kafka-server-start.sh config/server.properties &
        ：
        cd $KAFKA_HOME
        bin/kafka-server-stop.sh
4.  zookeeper      ， server1       
    a.jps     kafka   
    b.    topic
      ：
        cd $KAFKA_HOME
        bin/kafka-topics.sh --create --zookeeper 10.40.33.11:2181,10.40.33.12:2181,10.40.33.13:2181/kafka --replication-factor 1 --partitions 1 --topic test