文章列表
-
- 使用spring boot 整合kafka,延遲啟動消費者
- spring boot 整合kafka,延遲啟動消費者spring boot整合kafka的時候一般使用@KafkaListener來設置消費者，但是這種方式在spring啟動的時候就會立即開啟消費者。如果有需要根據配置信息延遲開啟指定的消費者就不能使用這種方式。參考了類：KafkaListener...
- 日期：2023-02-18
- 瀏覽：111
- 標簽： Spring
-
- Spring boot 整合KAFKA消息隊列的示例
- 這里使用 spring-kafka 依賴和 KafkaTemplate 對象來操作 Kafka 服務。一、添加依賴和添加配置項1.1、在 Pom 文件中添加依賴<dependency> <groupId>org.springframework.kafka</group...
- 日期：2023-08-08
- 瀏覽：124
- 標簽： Spring
-
- Java kafka如何實現自定義分區類和攔截器
- 生產者發送到對應的分區有以下幾種方式：（1）指定了patition，則直接使用；(可以查閱對應的java api, 有多種參數)（2）未指定patition但指定key，通過對key的value進行hash出一個patition；（3）patition和key都未指定，使用輪詢選出一個patitio...
- 日期：2022-08-31
- 瀏覽：51
- 標簽： Java
-
- Java將CSV的數據發送到kafka的示例
- 為什么將CSV的數據發到kafka flink做流式計算時，選用kafka消息作為數據源是常用手段，因此在學習和開發flink過程中，也會將數據集文件中的記錄發送到kafka，來模擬不間斷數據； 整個流程如下： 您可能會覺得這樣做多此一舉：flink直接讀取CSV不就行了嗎？這樣做的原因如...
- 日期：2022-08-21
- 瀏覽：11
- 標簽： Java
-
- spring 整合kafka監聽消費的配置過程
- 前言最近項目里有個需求，要消費kafka里的數據。之前也手動寫過代碼去消費kafka數據。但是轉念一想。既然spring提供了消費kafka的方法。就沒必要再去重復造輪子。于是嘗試使用spring的API。項目技術背景，使用springMVC，XML配置和注解相互使用。kafka的配置都是使用XML...
- 日期：2023-07-20
- 瀏覽：4
- 標簽： Spring
-
- Java Kafka 消費積壓監控的示例代碼
- 后端代碼：Monitor.java代碼：package com.suncreate.kafkaConsumerMonitor.service;import com.suncreate.kafkaConsumerMonitor.model.ConsumerInfo;import org.apache....
- 日期：2022-08-10
- 瀏覽：5
- 標簽： Java
-
- 利用擴展的方式在PHP中使用Kafka的教程分享
- 這篇文章主要為大家詳細介紹了如何利用擴展的方式實現在PHP中使用Kafka，具體包括擴展安裝和這種方式的基本操作，感興趣的小伙伴可以跟隨小編一起學習一下
- 日期：2022-06-14
- 瀏覽：9
- 標簽： PHP
-
- Zabbix對Kafka topic積壓數據監控的問題(bug優化)
- 這篇文章主要介紹了Zabbix對Kafka topic積壓數據監控,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
- 日期：2023-04-06
- 瀏覽：163
- 標簽： Zabbix
-
- Apache Kafka 分區重分配的實現原理解析
- 這篇文章主要介紹了Apache Kafka 分區重分配的實現原理,本文結合 2.0.0 版本的 Kafka 源碼，詳細介紹了 Kafka 分區副本重分配的流程和邏輯，需要的朋友可以參考下
- 日期：2023-03-07
- 瀏覽：167
-
- Spring boot集成Kafka消息中間件代碼實例
- 一．創建Spring boot項目，添加如下依賴<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web...
- 日期：2023-09-05
- 瀏覽：148
- 標簽： Spring
排行榜
網公網安備