文章列表
-
- Spring boot 整合KAFKA消息隊(duì)列的示例
- 這里使用 spring-kafka 依賴和 KafkaTemplate 對(duì)象來操作 Kafka 服務(wù)。一、添加依賴和添加配置項(xiàng)1.1、在 Pom 文件中添加依賴<dependency> <groupId>org.springframework.kafka</group...
- 日期:2023-08-08
- 瀏覽:118
- 標(biāo)簽: Spring
-
- 使用spring boot 整合kafka,延遲啟動(dòng)消費(fèi)者
- spring boot 整合kafka,延遲啟動(dòng)消費(fèi)者spring boot整合kafka的時(shí)候一般使用@KafkaListener來設(shè)置消費(fèi)者,但是這種方式在spring啟動(dòng)的時(shí)候就會(huì)立即開啟消費(fèi)者。如果有需要根據(jù)配置信息延遲開啟指定的消費(fèi)者就不能使用這種方式。參考了類:KafkaListener...
- 日期:2023-02-18
- 瀏覽:104
- 標(biāo)簽: Spring
-
- java自己手動(dòng)控制kafka的offset操作
- 之前使用kafka的KafkaStream,讓每個(gè)消費(fèi)者和對(duì)應(yīng)的patition建立對(duì)應(yīng)的流來讀取kafka上面的數(shù)據(jù),如果comsumer得到數(shù)據(jù),那么kafka就會(huì)自動(dòng)去維護(hù)該comsumer的offset,例如在獲取到kafka的消息后正準(zhǔn)備入庫(未入庫),但是消費(fèi)者掛了,那么如果讓kafka...
- 日期:2022-08-16
- 瀏覽:144
- 標(biāo)簽: Java
-
- 利用擴(kuò)展的方式在PHP中使用Kafka的教程分享
- 這篇文章主要為大家詳細(xì)介紹了如何利用擴(kuò)展的方式實(shí)現(xiàn)在PHP中使用Kafka,具體包括擴(kuò)展安裝和這種方式的基本操作,感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下
- 日期:2022-06-14
- 瀏覽:7
- 標(biāo)簽: PHP
-
- Zabbix對(duì)Kafka topic積壓數(shù)據(jù)監(jiān)控的問題(bug優(yōu)化)
- 這篇文章主要介紹了Zabbix對(duì)Kafka topic積壓數(shù)據(jù)監(jiān)控,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
- 日期:2023-04-06
- 瀏覽:160
- 標(biāo)簽: Zabbix
-
- Zabbix對(duì)Kafka topic積壓數(shù)據(jù)監(jiān)控的解決方案
- 這篇文章主要介紹了Zabbix對(duì)Kafka topic積壓數(shù)據(jù)監(jiān)控的解決方案,它與Apache Storm和Spark非常好地集成,用于實(shí)時(shí)流式數(shù)據(jù)分析,需要的朋友跟隨小編一起看看吧
- 日期:2023-04-06
- 瀏覽:199
- 標(biāo)簽: Zabbix
-
- Apache Kafka 分區(qū)重分配的實(shí)現(xiàn)原理解析
- 這篇文章主要介紹了Apache Kafka 分區(qū)重分配的實(shí)現(xiàn)原理,本文結(jié)合 2.0.0 版本的 Kafka 源碼,詳細(xì)介紹了 Kafka 分區(qū)副本重分配的流程和邏輯,需要的朋友可以參考下
- 日期:2023-03-07
- 瀏覽:161
-
- Spring boot集成Kafka消息中間件代碼實(shí)例
- 一.創(chuàng)建Spring boot項(xiàng)目,添加如下依賴<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web...
- 日期:2023-09-05
- 瀏覽:139
- 標(biāo)簽: Spring
-
- Java實(shí)現(xiàn)Kafka生產(chǎn)者消費(fèi)者代碼實(shí)例
- Kafka的結(jié)構(gòu)與RabbitMQ類似,消息生產(chǎn)者向Kafka服務(wù)器發(fā)送消息,Kafka接收消息后,再投遞給消費(fèi)者。生產(chǎn)者的消費(fèi)會(huì)被發(fā)送到Topic中,Topic中保存著各類數(shù)據(jù),每一條數(shù)據(jù)都使用鍵、值進(jìn)行保存。每一個(gè)Topic中都包含一個(gè)或多個(gè)物理分區(qū)(Partition),分區(qū)維護(hù)著消息的內(nèi)容和...
- 日期:2022-09-02
- 瀏覽:6
- 標(biāo)簽: Java
-
- CentOS7上如何安裝Kafka?CentOS7上安裝Kafka教程
- Kafka 是一種高吞吐的分布式發(fā)布訂閱消息系統(tǒng),能夠替代傳統(tǒng)的消息隊(duì)列用于解耦合數(shù)據(jù)處理,緩存未處理消息等。那么CentOS7上如何安裝Kafka?下面小編將為大家?guī)鞢entOS7上安裝Kafka教程!有需要的朋友一起去看看吧
- 日期:2022-06-06
- 瀏覽:89
排行榜
