文章列表
-
- Kafka Java Producer代碼實例詳解
- 根據業務需要可以使用Kafka提供的Java Producer API進行產生數據，并將產生的數據發送到Kafka對應Topic的對應分區中，入口類為：ProducerKafka的Producer API主要提供下列三個方法： public void send(KeyedMessage<K,...
- 日期：2022-08-31
- 瀏覽：84
- 標簽： Java
-
- Spring Boot集群管理工具KafkaAdminClient使用方法解析
- 原理介紹在Kafka官網中這么描述AdminClient：The AdminClient API supports managing and inspecting topics, brokers, acls, and other Kafka objects. 具體的KafkaAdminClient包...
- 日期：2023-09-20
- 瀏覽：3
- 標簽： Spring
-
- Spring boot集成Kafka消息中間件代碼實例
- 一．創建Spring boot項目，添加如下依賴<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web...
- 日期：2023-09-05
- 瀏覽：136
- 標簽： Spring
-
- spring 整合kafka監聽消費的配置過程
- 前言最近項目里有個需求，要消費kafka里的數據。之前也手動寫過代碼去消費kafka數據。但是轉念一想。既然spring提供了消費kafka的方法。就沒必要再去重復造輪子。于是嘗試使用spring的API。項目技術背景，使用springMVC，XML配置和注解相互使用。kafka的配置都是使用XML...
- 日期：2023-07-20
- 瀏覽：11
- 標簽： Spring
-
- SpringBoot集成Kafka的步驟
- SpringBoot集成Kafka本篇主要講解SpringBoot 如何集成Kafka ，并且簡單的 編寫了一個Demo 來測試 發送和消費功能前言選擇的版本如下：springboot ： 2.3.4.RELEASEspring-kafka ： 2.5.6.RELEASEkafka : 2.5.1z...
- 日期：2023-03-31
- 瀏覽：3
- 標簽： Spring
-
- Java將CSV的數據發送到kafka的示例
- 為什么將CSV的數據發到kafka flink做流式計算時，選用kafka消息作為數據源是常用手段，因此在學習和開發flink過程中，也會將數據集文件中的記錄發送到kafka，來模擬不間斷數據； 整個流程如下： 您可能會覺得這樣做多此一舉：flink直接讀取CSV不就行了嗎？這樣做的原因如...
- 日期：2022-08-21
- 瀏覽：5
- 標簽： 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
- 瀏覽：6
-
- Spring boot 整合KAFKA消息隊列的示例
- 這里使用 spring-kafka 依賴和 KafkaTemplate 對象來操作 Kafka 服務。一、添加依賴和添加配置項1.1、在 Pom 文件中添加依賴<dependency> <groupId>org.springframework.kafka</group...
- 日期：2023-08-08
- 瀏覽：112
- 標簽： Spring
-
- 使用spring boot 整合kafka,延遲啟動消費者
- spring boot 整合kafka,延遲啟動消費者spring boot整合kafka的時候一般使用@KafkaListener來設置消費者，但是這種方式在spring啟動的時候就會立即開啟消費者。如果有需要根據配置信息延遲開啟指定的消費者就不能使用這種方式。參考了類：KafkaListener...
- 日期：2023-02-18
- 瀏覽：99
- 標簽： Spring
-
- Java實現Kafka生產者消費者代碼實例
- Kafka的結構與RabbitMQ類似，消息生產者向Kafka服務器發送消息，Kafka接收消息后，再投遞給消費者。生產者的消費會被發送到Topic中，Topic中保存著各類數據，每一條數據都使用鍵、值進行保存。每一個Topic中都包含一個或多個物理分區（Partition），分區維護著消息的內容和...
- 日期：2022-09-02
- 瀏覽：2
- 標簽： Java
排行榜
網公網安備