一、Kafka命令行生产者发送消息和消费者消费消息

创建topic
./kafka-topics.sh --create --zookeeper xx.xx.xx.160:2181 --replication-factor 1 --partitions 2 --topic wnn-topic

•查看topic
./kafka-topics.sh --list --zookeeper xx.xx.xx.160:2181

•生产者发送消息
./kafka-console-producer.sh --broker-list xx.xx.xx.160:9092  --topic wnn-topic

•消费者消费消息 ( --from-beginning：会把主题中以往所有的数据都读取出来, 重启后会有这个重复消费)
./kafka-console-consumer.sh --bootstrap-server xx.xx.xx.160:9092 --from-beginning --topic wnn-topic

•删除topic
./kafka-topics.sh --zookeeper xx.xx.xx.160:2181 --delete --topic wnn-topic

•查看broker节点topic状态信息
./kafka-topics.sh --describe --zookeeper xx.xx.xx.160:2181  --topic wnn-topic

二、Kafka点对点模型和发布订阅模型

JMS规范目前支持两种消息模型
点对点（point to point)
    消息生产者生产消息发送到queue中，然后消息消费者从queue中取出并且消费消息
    消息被消费以后，queue中不再有存储，所以消息消费者不可能消费到已经被消费的消息。 Queue支持存在多个消费者，但是对一个消息而言，只会有一个消费者可以消费
发布/订阅（publish/subscribe）
    消息生产者（发布）将消息发布到topic中，同时有多个消息消费者（订阅）消费该消息。
    和点对点方式不同，发布到topic的消息会被所有订阅者消费。
点对点的配置：

编辑消费者配置（确保同个名称group.id一样）
	编辑 config/consumer.properties 
•创建topic, 1个分区
./kafka-topics.sh --create --zookeeper xxx.xx.xx.160:2181 --replication-factor 1 --partitions 2 --topic t1

•指定配置文件启动 两个消费者
./kafka-console-consumer.sh --bootstrap-server xxx.xx.xx.160:9092 --from-beginning --topic t1 --consumer.config ../config/consumer.properties

•现象
只有一个消费者可以消费到数据，一个分区只能被同个消费者组下的某个消费者进行消费

发布订阅的配置：

编辑消费者配置（确保group.id 不一样）
	编辑 config/consumer-1.properties 
	编辑 config/consumer-2.properties 
•创建topic, 2个分区
./kafka-topics.sh --create --zookeeper xx.xx.xx.160:2181 --replication-factor 1 --partitions 2 --topic t2

•指定配置文件启动 两个消费者
./kafka-console-consumer.sh --bootstrap-server xx.xx.xx.160:9092 --from-beginning --topic t1 --consumer.config ../config/consumer-1.properties
​./kafka-console-consumer.sh --bootstrap-server xx.xx.xx.160:9092 --from-beginning --topic t1 --consumer.config ../config/consumer-2.properties

•现象
◦两个不同消费者组的节点，都可以消费到消息，实现发布订阅模型