消息的两种模式
- 点对点模式，消费消息后删除消息
- 发布订阅模式，消息携带主题，消费消息后不删除消息
架构
- 消息分组，将消息分成多个Partition
- 消费者分组
- Partition主从备份
命令
kafka-topics.sh
创建主题
# 创建test主题，分区数1，分区副本1
KAFKA_HOME/bin/kafka-topics.sh --create --topic test --partitions 1 --zookeeper zookeeper:2181 --replication-factor 1
查看所有主题
$KAFKA_HOME/bin/kafka-topics.sh --zookeeper zookeeper:2181 --list
查看主题详细
$KAFKA_HOME/bin/kafka-topics.sh --zookeeper zookeeper:2181 --describe --topic test
kafka-console-producer.sh
发送消息
$KAFKA_HOME/bin/kafka-console-producer.sh --bootstrap-server localhost:2181 --topic test
kafka-console-consumer.sh
获取实时消息
$KAFKA_HOME/bin/kafka-console-consumer.sh --bootstrap-server localhost:2181 --topic test
获取历史消息
$KAFKA_HOME/bin/kafka-console-consumer.sh --bootstrap-server localhost:2181 --topic test --from-beginning
原创文章，作者：6024010，如若转载，请注明出处：https://blog.ytso.com/275320.html