關於 Topic 和 Partition： 　　Topic： 在 kafka 中，topic 是一個存儲消息的邏輯概念，可以認為是一個消息集合。每條消息發送到 kafka 集群的消息都有一個類別。物理上來說，不同的 topic 的消息是分開存儲的，每個 topic 可以有多個生產者向它發送消息 ...

使用監聽器，來實現實時消費nsq的消息 一、目前spring boot中支持的事件類型如下 ApplicationFailedEvent：該事件為spring boot啟動失敗時的操作 ApplicationPreparedEvent：上下文context准備時觸發 ...

1、 consumer API kafka 提供了兩套 consumer API： 其中 high-level consumer API 提供了一個從 kafka 消費數據的高層抽象，而 SimpleConsumer API 則需要開發人員更多地關注細節。 1.1 ...

...

Kafka架構組成：由producer（消息生產者）、consumer（消息消費者）、borker(kafka集群的server，負責處理消息讀、寫請求，存儲消息，在kafka cluster這一層這里，其實里面是有很多個broker)、topic（消息隊列/分類相當於隊列，里面 ...

查看主題命令 展示topic列表 ./kafka-topics.sh --list --zookeeper 172.18.153.12:2188 描述topic ./kafka-topics.sh --describe --zookeeper 172.18.153.12:2188 ...

項目中最近使用kafka需要定時清理消息，我們知道kafka有周期性清理消息機制,但是項目中往往因為數據量較大，需要手動控制分區已消費消息的清理。 此處使用的是反編譯程序，具體幾個方法已標出， 個人清理想法：大致流程就是根據topic獲取所有的分區，然后根據遍歷每個分區的偏移量，然后存入 ...

導入Kafka <dependency> 　　<groupId>org.springframework.kafka</groupId> 　　<artifactId>spring-kafka</artifactId> 　　< ...