单节点Kafka部署 zookeeper安装
Zookeeper启动：zkServer.sh start
Kafka单节点broker的部署及使用
安装zookeeper和Scala 配置到系统环境变量中
Kafka配置文件
- server.properties broker.id=0
Listeners：9092
host.name
log.dirs
zookeeper.connect=localhost:2181
启动kafka bin/kafka-server-start.sh config/server.properties
提示信息：USAGE: /app/kafka_2.11-0.9.0.0/bin/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 test
kafka-topics.sh --create --zookeeper hadoop000:2181 --replication-factor 1 --partitions 1 --topic hello_topic
查看所有topic
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
kafka-topics.sh --list --zookeeper hadoop000:2181
发送消息 ：broker
kafka-console-producer.sh --broker-list hadoop000:9092 --topic hello_topic
9092是监听端口（Listeners）
消费消息：zk
kafka-console-consumer.sh --zookeeper hadoop000:2181 --topic hello_topic --from-beginning
–from being的使用
Describe的使用（查看所有topic的详细信息）
kafka-topics.sh --describe --zookeeper hadoop000:2181
查看制定topic的详细信息：kafka-topics.sh --describe --zookeeper hadoop000:2181 --topic hello_topic