Kafka 架构

生产者 ，broker -> 主题 -> 分区 -> 分区多副本，消费者(负载均衡，再均衡)

Kafka Shell

要先启动zookeeper
$ kafka-server-start.sh -daemon $KAFKA_HOME/config/server.properties &
创建主题
$ kafka-topics.sh --zookeeper host000:2181 --create --topic hello_test --partitions 1 --replication-factor 1
查看主题
$ kafka-topics.sh --zookeeper host000:2181 --list
$ kafka-topics.sh --zookeeper host000:2181 --desc
（或者：--describe
（指定主题：kafka-topics.sh --zookeeper host000:2181 --topic hello_test --desc
启动生产者
$ kafka-console-producer.sh --broker-list host000:9092 --topic hello_test
启动消费者
$ kafka-console-consumer.sh --zookeeper host000:2181 --topic hello_test --from-beginning
关闭消费者|关闭生产者
ctrl+c
关闭kafka
$ kafka-server-stop.sh
删除主题
$ kafka-topics.sh --zookeeper host000:2181 --delete --topic hello_test