文章列表
-
- CentOS7上如何安裝Kafka?CentOS7上安裝Kafka教程
- Kafka 是一種高吞吐的分布式發(fā)布訂閱消息系統(tǒng)，能夠替代傳統(tǒng)的消息隊列用于解耦合數(shù)據(jù)處理，緩存未處理消息等。那么CentOS7上如何安裝Kafka?下面小編將為大家?guī)鞢entOS7上安裝Kafka教程！有需要的朋友一起去看看吧
- 日期：2022-06-06
- 瀏覽：50
-
- Spring boot集成Kafka消息中間件代碼實例
- 一．創(chuàng)建Spring boot項目，添加如下依賴<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web...
- 日期：2023-09-05
- 瀏覽：107
- 標簽： Spring
-
- 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
- 瀏覽：6
-
- Java實現(xiàn)Kafka生產(chǎn)者和消費者的示例
- Kafka簡介Kafka是由Apache軟件基金會開發(fā)的一個開源流處理平臺，由Scala和Java編寫。Kafka的目標是為處理實時數(shù)據(jù)提供一個統(tǒng)一、高吞吐、低延遲的平臺。方式一：kafka-clients引入依賴在pom.xml文件中，引入kafka-clients依賴：<dependenc...
- 日期：2022-08-17
- 瀏覽：88
- 標簽： Java
-
- Java Kafka 消費積壓監(jiān)控的示例代碼
- 后端代碼：Monitor.java代碼：package com.suncreate.kafkaConsumerMonitor.service;import com.suncreate.kafkaConsumerMonitor.model.ConsumerInfo;import org.apache....
- 日期：2022-08-10
- 瀏覽：7
- 標簽： Java
-
- Kafka Java Producer代碼實例詳解
- 根據(jù)業(yè)務(wù)需要可以使用Kafka提供的Java Producer API進行產(chǎn)生數(shù)據(jù)，并將產(chǎn)生的數(shù)據(jù)發(fā)送到Kafka對應(yīng)Topic的對應(yīng)分區(qū)中，入口類為：ProducerKafka的Producer API主要提供下列三個方法： public void send(KeyedMessage<K,...
- 日期：2022-08-31
- 瀏覽：70
- 標簽： Java
-
- java自己手動控制kafka的offset操作
- 之前使用kafka的KafkaStream，讓每個消費者和對應(yīng)的patition建立對應(yīng)的流來讀取kafka上面的數(shù)據(jù)，如果comsumer得到數(shù)據(jù)，那么kafka就會自動去維護該comsumer的offset，例如在獲取到kafka的消息后正準備入庫（未入庫），但是消費者掛了，那么如果讓kafka...
- 日期：2022-08-16
- 瀏覽：111
- 標簽： Java
-
- 使用spring boot 整合kafka,延遲啟動消費者
- spring boot 整合kafka,延遲啟動消費者spring boot整合kafka的時候一般使用@KafkaListener來設(shè)置消費者，但是這種方式在spring啟動的時候就會立即開啟消費者。如果有需要根據(jù)配置信息延遲開啟指定的消費者就不能使用這種方式。參考了類：KafkaListener...
- 日期：2023-02-18
- 瀏覽：81
- 標簽： Spring
-
- Java將CSV的數(shù)據(jù)發(fā)送到kafka的示例
- 為什么將CSV的數(shù)據(jù)發(fā)到kafka flink做流式計算時，選用kafka消息作為數(shù)據(jù)源是常用手段，因此在學習和開發(fā)flink過程中，也會將數(shù)據(jù)集文件中的記錄發(fā)送到kafka，來模擬不間斷數(shù)據(jù)； 整個流程如下： 您可能會覺得這樣做多此一舉：flink直接讀取CSV不就行了嗎？這樣做的原因如...
- 日期：2022-08-21
- 瀏覽：3
- 標簽： 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
- 瀏覽：3
排行榜
網(wǎng)公網(wǎng)安備