1.坑
1.1 外网访问
0.8.2.0新增外网访问支持，此版本以前不支持外网访问。
开启外网访问：在config/server.properties中，advertised.listeners中配置外网ip
advertised.listeners=PLAINTEXT://146.56.249.122:9092
2.命令行客户端
2.1.创建topic
当kafka开启自动创建topic时（auto.create.topics.enable=true），可以不用手动创建。
./kafka-create-topic.sh --zookeeper localhost:2181 --replica 3 --partition 1 --topic test
0.8.2版本
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
2.2.消费者消费数据
./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
2.3.查看topic
./kafka-list-topic.sh --zookeeper localhost:2181
topic: my-replicated-topic partition: 0 leader: 1 replicas: 1,2,0 isr: 1,2,0
topic: test partition: 0 leader: 0 replicas: 0 isr: 0
- leader：主副本
- replicas：副本列表（包括活跃和挂掉的副本）
- isr：活跃副本
0.8.2版本
./kafka-topics.sh --list --zookeeper localhost:2181
test
2.4.生产者写入数据
./kafka-console-producer.sh --broker-list localhost:9092 --topic test