openstack环境上安装kafka

1. <span class="pln">wget http</span><span class="pun">://</span><span class="pln">mirrors</span><span class="pun">.</span><span class="pln">cnnic</span><span class="pun">.</span><span class="pln">cn</span><span class="pun">/</span><span class="pln">apache</span><span class="pun">/</span><span class="pln">kafka</span><span class="pun">/</span><span class="lit">0.8</span><span class="pun">.</span><span class="lit">2.1</span><span class="pun">/</span><span class="pln">kafka</span><span class="pun">-</span><span class="lit">0.8</span><span class="pun">.</span><span class="lit">2.1</span><span class="pun">-</span><span class="pln">src</span><span class="pun">.</span><span class="pln">tgz</span>

2. <span class="pln">tar </span><span class="pun">-</span><span class="pln">xzf </span>kafka-0.8.2.1-src.tgz

   2.编辑conf/server.properties文件

3. <span class="pln">advertised.host.name=59.46.101.43 外网访问地址</span>

   
   
   3.按照官方文档启动zookeeper、kafka，创建topic

4. <span class="pln">bin</span><span class="pun">/</span><span class="pln">zookeeper</span><span class="pun">-</span><span class="pln">server</span><span class="pun">-</span><span class="pln">start</span><span class="pun">.</span><span class="pln">sh config</span><span class="pun">/</span><span class="pln">zookeeper</span><span class="pun">.</span><span class="pln">properties</span>

5. <span class="pln">bin</span><span class="pun">/</span><span class="pln">kafka</span><span class="pun">-</span><span class="pln">server</span><span class="pun">-</span><span class="pln">start</span><span class="pun">.</span><span class="pln">sh config</span><span class="pun">/</span><span class="pln">server</span><span class="pun">.</span><span class="pln">properties</span>

6. <span class="pln">bin</span><span class="pun">/</span><span class="pln">kafka</span><span class="pun">-</span><span class="pln">topics</span><span class="pun">.</span><span class="pln">sh </span><span class="pun">--</span><span class="pln">create </span><span class="pun">--</span><span class="pln">zookeeper localhost</span><span class="pun">:</span><span class="lit">2181</span><span class="pln"> </span><span class="pun">--</span><span class="pln">replication</span><span class="pun">-</span><span class="pln">factor </span><span class="lit">1</span><span class="pln"> </span><span class="pun">--</span><span class="pln">partitions </span><span class="lit">1</span><span class="pln"> </span><span class="pun">--</span><span class="pln">topic test</span>

   以上就完成了安装。
   4.完成两个端口的外网映射，2181和9092保证外网可以telnet可达
   5.完成回路配置，保证内网虚机上ping外网地址59.46.101.43可达
   6.然后就可以使用了，按照官网的生产和消费命令试一下吧

7. <span class="pln">bin</span><span class="pun">/</span><span class="pln">kafka</span><span class="pun">-</span><span class="pln">console</span><span class="pun">-</span><span class="pln">producer</span><span class="pun">.</span><span class="pln">sh </span><span class="pun">--</span><span class="pln">broker</span><span class="pun">-</span><span class="pln">list localhost</span><span class="pun">:</span><span class="lit">9092</span><span class="pln"> </span><span class="pun">--</span><span class="pln">topic test </span>

8. <span class="pln">bin</span><span class="pun">/</span><span class="pln">kafka</span><span class="pun">-</span><span class="pln">console</span><span class="pun">-</span><span class="pln">consumer</span><span class="pun">.</span><span class="pln">sh </span><span class="pun">--</span><span class="pln">zookeeper localhost</span><span class="pun">:</span><span class="lit">2181</span><span class="pln"> </span><span class="pun">--</span><span class="pln">topic test </span><span class="pun">--</span><span class="pln">from</span><span class="pun">-</span><span class="pln">beginning</span>