直接生產者發送消息,但是version1-topic這個topic是之前不存在的
###
`./kafka-console-producer.sh --broker-list 10.10.15.132:9092 --topic version1-topic`
###
上述命令時向version1-topic這個topic當中發送消息,但是我們并沒有事先創建version1-topic 所以kafka會為我們自動創建這個topic 并發送消息
###
再來看消費者消費消息
###
`./kafka-console-consumer.sh --bootstrap-server 10.10.15.132:9092 --topic version1-topic`
###
--topic version1-topic 指定要消費哪個topic
###

###
**--from-beginning會把主題中以往所有的數據都讀取出來,重啟消費者會重復消費topic當中的消息**
###
- 前言介紹
- 什么是MQ消息中間件和應用場景
- 對比當下主流消息隊列和選擇
- kafka的快速認知和核心概念
- 部署安裝Zookeeper和Kafka
- kafka命令行初步創建topic查看topic
- kafka命令行生產消費消息實戰
- kafka命令行刪除topic和查看broker節點信息
- kafka命令行點對點和發布訂閱模型理論
- kafka命令行消費組配置實現點對點消費
- kafka命令行消費組配置實現訂閱消費
- kafka當中數據存儲流程原理概述LEO+HW等的講解
- Springboot2.x整合kafka客戶端+創建topic
- Springboot2.x列舉/刪除/詳情/增加topic
- kafka生產者原理詳解
- Springboot2.x實現消息發送(對key進行hash方案)
- 惡補ProducerRecord和key的作用
- Springboot2.x實現消息發送回調函數(對key進行hash方案)
- Springboot2.x實現消息發送(指定分區發送消息方案)
- Springboot2.x實現生產者根據自定義策略到指定分區
- Kafka的Consumer消費者機制和分區策略講解
- Kafka當中Consumer消費者重新分配策略和offset維護機制
- Springboot2.x實現消費消息實戰
- kafka當中如何實現消費者重頭消費
- kafka當中手工提交offset
- kafka數據文件存儲和log日志講解
- 分布式應用核心CAP理論講解
- kafka可靠性保障理論講解(Replica+Ack)(上)
- kafka可靠性保障理論講解(Replica+Ack)(下)
- kafka當中HighWatermark的作用
- kafka高可用集群之zookeeper集群搭建實戰
- kafka高可用集群之kafkaf集群搭建實戰
- Springboot2.x實現鏈接kafka創建查看topic實戰
- Springboot2.x實現kafka生產發送消息實戰
- kafka當中日志數據清理理論講解
- Kafka高性能原理分析
- Springboot2.x整合spring-kafka并實現發送消息實戰
- Springboot2.x整合spring-kafka并實現消費消息實戰
- Springboot2.x整合spring-kafka并實現事務消息實戰
- 大總結