kafka环境搭建

1.下载kafka压缩包kafka_2.9.1-0.8.2.1.tgz 用tar -zxvf 命令解压到建立kafka的目录下面

2.建立kafkalog配置文件kafkaLog

3.修改kafka配置文件 server.properties

   主要说明下须要修改的基本参数，其余能够参照apache kafka官方文档

   我本身是三台虚拟服务器：

   broker.id=0 从0开始 每一台及其取名不同，你能够设置为0，1，2····

   host.name=ip 这个注解须要放开并将后面的localhost替换成你的ip地址

   log.dirs=/home/test/kafka/kafkaLogs 这个指向刚才建立的日志目录

   num.partitions=2 默认是1，你也能够不修改

   message.max.byte=573741824设置信息最大致谅为5M（后加）
   default.replication.factor=2
   replica.fetch.max.bytes=573741824

   zookeeper.connect=IP:12181,IP:12181 设置的zookeeper集群及其的IP以及端口

4.启动与测试kafka服务

  建立一个kafka的topic命令 ./kafka-topics.sh --create --zookeeper Ip:12181 --replication-factor 1 --partitions 2 --topic test

  查看kakfa中topic列表./kafka-topics.sh --list --zookeeper IP:12181

  

  启动生产者./kafka-console-producer.sh --broker-list IP:9092 --topic test

  启动消费端./kafka-console-consumer.sh --zookeeper 121.40.194.104:12181 --topic talk --from-beginning

   以上基本是kafka的部署内容。