文章列表
-
- Kafka Java Producer代碼實(shí)例詳解
- 根據(jù)業(yè)務(wù)需要可以使用Kafka提供的Java Producer API進(jìn)行產(chǎn)生數(shù)據(jù)，并將產(chǎn)生的數(shù)據(jù)發(fā)送到Kafka對(duì)應(yīng)Topic的對(duì)應(yīng)分區(qū)中，入口類為：ProducerKafka的Producer API主要提供下列三個(gè)方法： public void send(KeyedMessage<K,...
- 日期：2022-08-31
- 瀏覽：150
- 標(biāo)簽： Java
-
- Python通過kerberos安全認(rèn)證操作kafka方式
- 如何通過Kerberos認(rèn)證.1.安裝Kerberos客戶端CentOS：yum install krb5-workstation使用which kinit查看是否安裝成功；2.拷貝Kerberos配置文件conf目錄下krb5.conf和kafka.keytab和jaas.conf拷貝到客戶端機(jī)器...
- 日期：2022-07-22
- 瀏覽：18
-
- Spring Boot 集成 Kafkad的實(shí)現(xiàn)示例
- Spring Boot 作為主流微服務(wù)框架，擁有成熟的社區(qū)生態(tài)。市場(chǎng)應(yīng)用廣泛，為了方便大家，整理了一個(gè)基于spring boot的常用中間件快速集成入門系列手冊(cè)，涉及RPC、緩存、消息隊(duì)列、分庫(kù)分表、注冊(cè)中心、分布式配置等常用開源組件，大概有幾十篇文章，陸續(xù)會(huì)開放出來，感興趣同學(xué)請(qǐng)?zhí)崆瓣P(guān)注&...
- 日期：2023-07-18
- 瀏覽：11
- 標(biāo)簽： Spring
-
- Springboot 1.5.7整合Kafka-client代碼示例
- 在一次項(xiàng)目中，因甲方需要使用kafka消息隊(duì)列推送數(shù)據(jù)，所以需要接入kafka，并且kafka的版本是2.11。但是我們項(xiàng)目使用的是Springboot 1.5.7的版本，對(duì)應(yīng)的springboot.kafka.starter有沖突，所以就接入了kafka-client。Kafka 是一個(gè)分布式消息...
- 日期：2023-04-13
- 瀏覽：15
- 標(biāo)簽： Spring
-
- Java實(shí)現(xiàn)Kafka生產(chǎn)者消費(fèi)者代碼實(shí)例
- Kafka的結(jié)構(gòu)與RabbitMQ類似，消息生產(chǎn)者向Kafka服務(wù)器發(fā)送消息，Kafka接收消息后，再投遞給消費(fèi)者。生產(chǎn)者的消費(fèi)會(huì)被發(fā)送到Topic中，Topic中保存著各類數(shù)據(jù)，每一條數(shù)據(jù)都使用鍵、值進(jìn)行保存。每一個(gè)Topic中都包含一個(gè)或多個(gè)物理分區(qū)（Partition），分區(qū)維護(hù)著消息的內(nèi)容和...
- 日期：2022-09-02
- 瀏覽：11
- 標(biāo)簽： Java
-
- Java kafka如何實(shí)現(xiàn)自定義分區(qū)類和攔截器
- 生產(chǎn)者發(fā)送到對(duì)應(yīng)的分區(qū)有以下幾種方式：（1）指定了patition，則直接使用；(可以查閱對(duì)應(yīng)的java api, 有多種參數(shù))（2）未指定patition但指定key，通過對(duì)key的value進(jìn)行hash出一個(gè)patition；（3）patition和key都未指定，使用輪詢選出一個(gè)patitio...
- 日期：2022-08-31
- 瀏覽：13
- 標(biāo)簽： Java
-
- Java實(shí)現(xiàn)Kafka生產(chǎn)者和消費(fèi)者的示例
- Kafka簡(jiǎn)介Kafka是由Apache軟件基金會(huì)開發(fā)的一個(gè)開源流處理平臺(tái)，由Scala和Java編寫。Kafka的目標(biāo)是為處理實(shí)時(shí)數(shù)據(jù)提供一個(gè)統(tǒng)一、高吞吐、低延遲的平臺(tái)。方式一：kafka-clients引入依賴在pom.xml文件中，引入kafka-clients依賴：<dependenc...
- 日期：2022-08-17
- 瀏覽：197
- 標(biāo)簽： Java
-
- java自己手動(dòng)控制kafka的offset操作
- 之前使用kafka的KafkaStream，讓每個(gè)消費(fèi)者和對(duì)應(yīng)的patition建立對(duì)應(yīng)的流來讀取kafka上面的數(shù)據(jù)，如果comsumer得到數(shù)據(jù)，那么kafka就會(huì)自動(dòng)去維護(hù)該comsumer的offset，例如在獲取到kafka的消息后正準(zhǔn)備入庫(kù)（未入庫(kù)），但是消費(fèi)者掛了，那么如果讓kafka...
- 日期：2022-08-16
- 瀏覽：244
- 標(biāo)簽： Java
-
- 利用擴(kuò)展的方式在PHP中使用Kafka的教程分享
- 這篇文章主要為大家詳細(xì)介紹了如何利用擴(kuò)展的方式實(shí)現(xiàn)在PHP中使用Kafka，具體包括擴(kuò)展安裝和這種方式的基本操作，感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下
- 日期：2022-06-14
- 瀏覽：34
- 標(biāo)簽： PHP
-
- Zabbix對(duì)Kafka topic積壓數(shù)據(jù)監(jiān)控的問題(bug優(yōu)化)
- 這篇文章主要介紹了Zabbix對(duì)Kafka topic積壓數(shù)據(jù)監(jiān)控,本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下
- 日期：2023-04-06
- 瀏覽：543
- 標(biāo)簽： Zabbix
排行榜
網(wǎng)公網(wǎng)安備