原始地址：http://kafka.apache.org/quickstart
tar -xzf kafka_2.11-2.1.0.tgz
cd kafka_2.11-2.1.0
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties
创建主题
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看主题
bin/kafka-topics.sh --list --zookeeper localhost:2181
创建一个producter
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
启动一个consumer
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test –from-beginning
设置集群
cp config/server.properties config/server-1.properties
broker.id=1
listeners=PLAINTEXT://:9093
log.dirs=/tmp/kafka-logs-1
cp config/server.properties config/server-2.properties
broker.id=2 listeners=PLAINTEXT://:9094
log.dirs=/tmp/kafka-logs-2
启动两个新节点
bin/kafka-server-start.sh config/server-1.properties &
bin/kafka-server-start.sh config/server-2.properties &
创建一个分区为3的TOPIC
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic
查看分区状态
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-replicated-topic
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
