kafka的安装和使用（单节点单broker） kafka的安装和使用（单节点单

下载安装zookeeper 下载地址：http://archive.cloudera.com/cdh5/cdh/5/ （选择自己需要的版本）
我下载的版本：http://archive.cloudera.com/cdh5/cdh/5/zookeeper-3.4.5-cdh5.7.0.tar.gz
下载完成后解压到指定目录。
选择合适的路径，运行以下代码

wget http://archive.cloudera.com/cdh5/cdh/5/zookeeper-3.4.5-cdh5.7.0.tar.gz tar -zxvf zookeeper-3.4.5-cdh5.7.0.tar.gz cd zookeeper-3.4.5-cdh5.7.0/conf cp zoo_sample.cfg zoo_sample.cfg vi zoo.cfg

【kafka的安装和使用（单节点单broker）】修改如下代码

dataDir=(你自己新建的文件夹路径)

运行zookeeper

../bin/zkServer.sh start

下载安装kafka 下载地址：http://kafka.apache.org/downloads
我下载的版本：https://archive.apache.org/dist/kafka/0.9.0.0/kafka_2.11-0.9.0.0.tgz （注意看自己scala的版本）
1）下载完成后解压到指定目录，
2）修改config文件夹下的server.properties文件，修改log.dirs的值为自己新建的文件夹
3）在bin目录下执行以下操作
kafka的使用启动kafka

#./kafka-server-start.sh [-daemon] server.properties [--override property=value]* ./kafka-server-start.sh$KAFKA_HOME/config/server.properties

创建topic

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

查看topic

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

开启新的窗口，启动生产者，输入信息，观察消费者

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

开启新的窗口，启动消费者

# --from-beginning:从头开始消费 ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic my_topic --from-beginning

查看describe

./kafka-topics.sh --describe --zookeeper localhost:2181 ./kafka-topics.sh --describe --zookeeper localhost:2181 --topic my_topicTopic:my_topicPartitionCount:1ReplicationFactor:1 Configs: Topic: my_topic Partition: 0Leader: 0Replicas: 0 Isr: 0