技术积累20170415（2）

kafka-shell操作

1.创建一个叫做test的topic，只有一个分区一个副本

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

2.通过list来查看创建的topic

./kafka-topics.sh --list --zookeeper  localhost:2181 test

3.发送消息：kafka使用一个简单的命令行producer，从文件中或者标准输入中读取消息并发送到服务端。ctrl+c可以退出发送

./kafka-console-producer.sh --broker-list localhost:9092 --topic test

4.启动consumer，读取消息并输出到标准输出
./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

启动kafka

1.首先启动zookeeper

  ./zookkeeper-server-start.sh  /kafka/config/zookeeper.properties &

  (命令的结尾加个&，就可以启动后离开控制台)（在30.81上无法启动zookeeper，直接启动2也可以）

2.启动kafka

  ./kafka-server-start.sh  /kafka/config/server.properties &

 log4j依赖哪个jar包

  可以是这个：

compile 'log4j:log4j:1.2.17:sources'

 compile 'com.oracle:ojdbc6:11.2.0.3'

这个包中也包含org.apache.log4j.Logger