文章列表
-
- java自己手動控制kafka的offset操作
- 之前使用kafka的KafkaStream，讓每個消費者和對應的patition建立對應的流來讀取kafka上面的數據，如果comsumer得到數據，那么kafka就會自動去維護該comsumer的offset，例如在獲取到kafka的消息后正準備入庫（未入庫），但是消費者掛了，那么如果讓kafka...
- 日期：2022-08-16
- 瀏覽：136
- 標簽： Java
-
- Spring boot集成Kafka消息中間件代碼實例
- 一．創建Spring boot項目，添加如下依賴<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web...
- 日期：2023-09-05
- 瀏覽：132
- 標簽： Spring
-
- Zabbix對Kafka topic積壓數據監控的問題(bug優化)
- 這篇文章主要介紹了Zabbix對Kafka topic積壓數據監控,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
- 日期：2023-04-06
- 瀏覽：152
- 標簽： Zabbix
-
- Apache Kafka 分區重分配的實現原理解析
- 這篇文章主要介紹了Apache Kafka 分區重分配的實現原理,本文結合 2.0.0 版本的 Kafka 源碼，詳細介紹了 Kafka 分區副本重分配的流程和邏輯，需要的朋友可以參考下
- 日期：2023-03-07
- 瀏覽：153
-
- Kafka Java Producer代碼實例詳解
- 根據業務需要可以使用Kafka提供的Java Producer API進行產生數據，并將產生的數據發送到Kafka對應Topic的對應分區中，入口類為：ProducerKafka的Producer API主要提供下列三個方法： public void send(KeyedMessage<K,...
- 日期：2022-08-31
- 瀏覽：84
- 標簽： Java
-
- Java kafka如何實現自定義分區類和攔截器
- 生產者發送到對應的分區有以下幾種方式：（1）指定了patition，則直接使用；(可以查閱對應的java api, 有多種參數)（2）未指定patition但指定key，通過對key的value進行hash出一個patition；（3）patition和key都未指定，使用輪詢選出一個patitio...
- 日期：2022-08-31
- 瀏覽：36
- 標簽： Java
-
- CentOS7上如何安裝Kafka?CentOS7上安裝Kafka教程
- Kafka 是一種高吞吐的分布式發布訂閱消息系統，能夠替代傳統的消息隊列用于解耦合數據處理，緩存未處理消息等。那么CentOS7上如何安裝Kafka?下面小編將為大家帶來CentOS7上安裝Kafka教程！有需要的朋友一起去看看吧
- 日期：2022-06-06
- 瀏覽：84
-
- Zabbix對Kafka topic積壓數據監控的解決方案
- 這篇文章主要介紹了Zabbix對Kafka topic積壓數據監控的解決方案,它與Apache Storm和Spark非常好地集成，用于實時流式數據分析，需要的朋友跟隨小編一起看看吧
- 日期：2023-04-06
- 瀏覽：191
- 標簽： Zabbix
-
- Spring boot 整合KAFKA消息隊列的示例
- 這里使用 spring-kafka 依賴和 KafkaTemplate 對象來操作 Kafka 服務。一、添加依賴和添加配置項1.1、在 Pom 文件中添加依賴<dependency> <groupId>org.springframework.kafka</group...
- 日期：2023-08-08
- 瀏覽：109
- 標簽： Spring
-
- SpringBoot集成Kafka的步驟
- SpringBoot集成Kafka本篇主要講解SpringBoot 如何集成Kafka ，并且簡單的 編寫了一個Demo 來測試 發送和消費功能前言選擇的版本如下：springboot ： 2.3.4.RELEASEspring-kafka ： 2.5.6.RELEASEkafka : 2.5.1z...
- 日期：2023-03-31
- 瀏覽：5
- 標簽： Spring
網公網安備