文章列表
-
- java自己手動控制kafka的offset操作
- 之前使用kafka的KafkaStream,讓每個消費者和對應的patition建立對應的流來讀取kafka上面的數據,如果comsumer得到數據,那么kafka就會自動去維護該comsumer的offset,例如在獲取到kafka的消息后正準備入庫(未入庫),但是消費者掛了,那么如果讓kafka...
- 日期:2022-08-16
- 瀏覽:165
- 標簽: Java
-
- Zabbix對Kafka topic積壓數據監控的問題(bug優化)
- 這篇文章主要介紹了Zabbix對Kafka topic積壓數據監控,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
- 日期:2023-04-06
- 瀏覽:173
- 標簽: Zabbix
-
- Apache Kafka 分區重分配的實現原理解析
- 這篇文章主要介紹了Apache Kafka 分區重分配的實現原理,本文結合 2.0.0 版本的 Kafka 源碼,詳細介紹了 Kafka 分區副本重分配的流程和邏輯,需要的朋友可以參考下
- 日期:2023-03-07
- 瀏覽:179
-
- Kafka Java Producer代碼實例詳解
- 根據業務需要可以使用Kafka提供的Java Producer API進行產生數據,并將產生的數據發送到Kafka對應Topic的對應分區中,入口類為:ProducerKafka的Producer API主要提供下列三個方法: public void send(KeyedMessage<K,...
- 日期:2022-08-31
- 瀏覽:99
- 標簽: Java
-
- CentOS7上如何安裝Kafka?CentOS7上安裝Kafka教程
- Kafka 是一種高吞吐的分布式發布訂閱消息系統,能夠替代傳統的消息隊列用于解耦合數據處理,緩存未處理消息等。那么CentOS7上如何安裝Kafka?下面小編將為大家帶來CentOS7上安裝Kafka教程!有需要的朋友一起去看看吧
- 日期:2022-06-06
- 瀏覽:104
-
- Spring Boot 集成 Kafkad的實現示例
- Spring Boot 作為主流微服務框架,擁有成熟的社區生態。市場應用廣泛,為了方便大家,整理了一個基于spring boot的常用中間件快速集成入門系列手冊,涉及RPC、緩存、消息隊列、分庫分表、注冊中心、分布式配置等常用開源組件,大概有幾十篇文章,陸續會開放出來,感興趣同學請提前關注&...
- 日期:2023-07-18
- 瀏覽:6
- 標簽: Spring
-
- Spring Boot集群管理工具KafkaAdminClient使用方法解析
- 原理介紹在Kafka官網中這么描述AdminClient:The AdminClient API supports managing and inspecting topics, brokers, acls, and other Kafka objects. 具體的KafkaAdminClient包...
- 日期:2023-09-20
- 瀏覽:4
- 標簽: Spring
-
- Java kafka如何實現自定義分區類和攔截器
- 生產者發送到對應的分區有以下幾種方式:(1)指定了patition,則直接使用;(可以查閱對應的java api, 有多種參數)(2)未指定patition但指定key,通過對key的value進行hash出一個patition;(3)patition和key都未指定,使用輪詢選出一個patitio...
- 日期:2022-08-31
- 瀏覽:57
- 標簽: Java
-
- Zabbix對Kafka topic積壓數據監控的解決方案
- 這篇文章主要介紹了Zabbix對Kafka topic積壓數據監控的解決方案,它與Apache Storm和Spark非常好地集成,用于實時流式數據分析,需要的朋友跟隨小編一起看看吧
- 日期:2023-04-06
- 瀏覽:213
- 標簽: Zabbix
-
- Springboot 1.5.7整合Kafka-client代碼示例
- 在一次項目中,因甲方需要使用kafka消息隊列推送數據,所以需要接入kafka,并且kafka的版本是2.11。但是我們項目使用的是Springboot 1.5.7的版本,對應的springboot.kafka.starter有沖突,所以就接入了kafka-client。Kafka 是一個分布式消息...
- 日期:2023-04-13
- 瀏覽:3
- 標簽: Spring
排行榜
