文章列表
-
- Springboot 1.5.7整合Kafka-client代碼示例
- 在一次項目中，因甲方需要使用kafka消息隊列推送數據，所以需要接入kafka，并且kafka的版本是2.11。但是我們項目使用的是Springboot 1.5.7的版本，對應的springboot.kafka.starter有沖突，所以就接入了kafka-client。Kafka 是一個分布式消息...
- 日期：2023-04-13
- 瀏覽：4
- 標簽： Spring
-
- 使用spring boot 整合kafka,延遲啟動消費者
- spring boot 整合kafka,延遲啟動消費者spring boot整合kafka的時候一般使用@KafkaListener來設置消費者，但是這種方式在spring啟動的時候就會立即開啟消費者。如果有需要根據配置信息延遲開啟指定的消費者就不能使用這種方式。參考了類：KafkaListener...
- 日期：2023-02-18
- 瀏覽：74
- 標簽： Spring
-
- CentOS7上如何安裝Kafka?CentOS7上安裝Kafka教程
- Kafka 是一種高吞吐的分布式發布訂閱消息系統，能夠替代傳統的消息隊列用于解耦合數據處理，緩存未處理消息等。那么CentOS7上如何安裝Kafka?下面小編將為大家帶來CentOS7上安裝Kafka教程！有需要的朋友一起去看看吧
- 日期：2022-06-06
- 瀏覽：36
-
- Apache Kafka 分區重分配的實現原理解析
- 這篇文章主要介紹了Apache Kafka 分區重分配的實現原理,本文結合 2.0.0 版本的 Kafka 源碼，詳細介紹了 Kafka 分區副本重分配的流程和邏輯，需要的朋友可以參考下
- 日期：2023-03-07
- 瀏覽：116
-
- Spring Boot集群管理工具KafkaAdminClient使用方法解析
- 原理介紹在Kafka官網中這么描述AdminClient：The AdminClient API supports managing and inspecting topics, brokers, acls, and other Kafka objects. 具體的KafkaAdminClient包...
- 日期：2023-09-20
- 瀏覽：2
- 標簽： Spring
-
- Spring boot集成Kafka消息中間件代碼實例
- 一．創建Spring boot項目，添加如下依賴<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web...
- 日期：2023-09-05
- 瀏覽：99
- 標簽： Spring
-
- Java實現Kafka生產者消費者代碼實例
- Kafka的結構與RabbitMQ類似，消息生產者向Kafka服務器發送消息，Kafka接收消息后，再投遞給消費者。生產者的消費會被發送到Topic中，Topic中保存著各類數據，每一條數據都使用鍵、值進行保存。每一個Topic中都包含一個或多個物理分區（Partition），分區維護著消息的內容和...
- 日期：2022-09-02
- 瀏覽：2
- 標簽： Java
-
- Kafka Java Producer代碼實例詳解
- 根據業務需要可以使用Kafka提供的Java Producer API進行產生數據，并將產生的數據發送到Kafka對應Topic的對應分區中，入口類為：ProducerKafka的Producer API主要提供下列三個方法： public void send(KeyedMessage<K,...
- 日期：2022-08-31
- 瀏覽：66
- 標簽： Java
-
- Java kafka如何實現自定義分區類和攔截器
- 生產者發送到對應的分區有以下幾種方式：（1）指定了patition，則直接使用；(可以查閱對應的java api, 有多種參數)（2）未指定patition但指定key，通過對key的value進行hash出一個patition；（3）patition和key都未指定，使用輪詢選出一個patitio...
- 日期：2022-08-31
- 瀏覽：15
- 標簽： Java
-
- Python confluent kafka客戶端配置kerberos認證流程詳解
- kafka的認證方式一般有如下3種：1.SASL/GSSAPI 從版本0.9.0.0開始支持2.SASL/PLAIN 從版本0.10.0.0開始支持3.SASL/SCRAM-SHA-256 以及 SASL/SCRAM-SHA-512 從版本0.10.2.0開始支持其中第一種SASL/GSSAPI的認...
- 日期：2022-07-08
- 瀏覽：2
排行榜
網公網安備