文章列表
-
- SpringBoot集成Kafka的步驟
- SpringBoot集成Kafka本篇主要講解SpringBoot 如何集成Kafka ,并且簡單的 編寫了一個Demo 來測試 發送和消費功能前言選擇的版本如下:springboot : 2.3.4.RELEASEspring-kafka : 2.5.6.RELEASEkafka : 2.5.1z...
- 日期:2023-03-31
- 瀏覽:7
- 標簽: Spring
-
- Spring Boot集群管理工具KafkaAdminClient使用方法解析
- 原理介紹在Kafka官網中這么描述AdminClient:The AdminClient API supports managing and inspecting topics, brokers, acls, and other Kafka objects. 具體的KafkaAdminClient包...
- 日期:2023-09-20
- 瀏覽:6
- 標簽: Spring
-
- Zabbix對Kafka topic積壓數據監控的問題(bug優化)
- 這篇文章主要介紹了Zabbix對Kafka topic積壓數據監控,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
- 日期:2023-04-06
- 瀏覽:159
- 標簽: Zabbix
-
- Spring boot集成Kafka消息中間件代碼實例
- 一.創建Spring boot項目,添加如下依賴<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web...
- 日期:2023-09-05
- 瀏覽:138
- 標簽: Spring
-
- Spring boot 整合KAFKA消息隊列的示例
- 這里使用 spring-kafka 依賴和 KafkaTemplate 對象來操作 Kafka 服務。一、添加依賴和添加配置項1.1、在 Pom 文件中添加依賴<dependency> <groupId>org.springframework.kafka</group...
- 日期:2023-08-08
- 瀏覽:115
- 標簽: Spring
-
- 使用spring boot 整合kafka,延遲啟動消費者
- spring boot 整合kafka,延遲啟動消費者spring boot整合kafka的時候一般使用@KafkaListener來設置消費者,但是這種方式在spring啟動的時候就會立即開啟消費者。如果有需要根據配置信息延遲開啟指定的消費者就不能使用這種方式。參考了類:KafkaListener...
- 日期:2023-02-18
- 瀏覽:102
- 標簽: Spring
-
- java自己手動控制kafka的offset操作
- 之前使用kafka的KafkaStream,讓每個消費者和對應的patition建立對應的流來讀取kafka上面的數據,如果comsumer得到數據,那么kafka就會自動去維護該comsumer的offset,例如在獲取到kafka的消息后正準備入庫(未入庫),但是消費者掛了,那么如果讓kafka...
- 日期:2022-08-16
- 瀏覽:142
- 標簽: Java
-
- Python通過kerberos安全認證操作kafka方式
- 如何通過Kerberos認證.1.安裝Kerberos客戶端CentOS:yum install krb5-workstation使用which kinit查看是否安裝成功;2.拷貝Kerberos配置文件conf目錄下krb5.conf和kafka.keytab和jaas.conf拷貝到客戶端機器...
- 日期:2022-07-22
- 瀏覽:8
-
- Apache Kafka 分區重分配的實現原理解析
- 這篇文章主要介紹了Apache Kafka 分區重分配的實現原理,本文結合 2.0.0 版本的 Kafka 源碼,詳細介紹了 Kafka 分區副本重分配的流程和邏輯,需要的朋友可以參考下
- 日期:2023-03-07
- 瀏覽:159
-
- 利用擴展的方式在PHP中使用Kafka的教程分享
- 這篇文章主要為大家詳細介紹了如何利用擴展的方式實現在PHP中使用Kafka,具體包括擴展安裝和這種方式的基本操作,感興趣的小伙伴可以跟隨小編一起學習一下
- 日期:2022-06-14
- 瀏覽:4
- 標簽: PHP