文章列表
-
- java自己手動控制kafka的offset操作
- 之前使用kafka的KafkaStream，讓每個消費者和對應(yīng)的patition建立對應(yīng)的流來讀取kafka上面的數(shù)據(jù)，如果comsumer得到數(shù)據(jù)，那么kafka就會自動去維護(hù)該comsumer的offset，例如在獲取到kafka的消息后正準(zhǔn)備入庫（未入庫），但是消費者掛了，那么如果讓kafka...
- 日期：2022-08-16
- 瀏覽：162
- 標(biāo)簽： Java
-
- Kafka Java Producer代碼實例詳解
- 根據(jù)業(yè)務(wù)需要可以使用Kafka提供的Java Producer API進(jìn)行產(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
- 瀏覽：97
- 標(biāo)簽： Java
-
- Apache Kafka 分區(qū)重分配的實現(xiàn)原理解析
- 這篇文章主要介紹了Apache Kafka 分區(qū)重分配的實現(xiàn)原理,本文結(jié)合 2.0.0 版本的 Kafka 源碼，詳細(xì)介紹了 Kafka 分區(qū)副本重分配的流程和邏輯，需要的朋友可以參考下
- 日期：2023-03-07
- 瀏覽：176
-
- Spring Boot集群管理工具KafkaAdminClient使用方法解析
- 原理介紹在Kafka官網(wǎng)中這么描述AdminClient：The AdminClient API supports managing and inspecting topics, brokers, acls, and other Kafka objects. 具體的KafkaAdminClient包...
- 日期：2023-09-20
- 瀏覽：3
- 標(biāo)簽： Spring
-
- Spring Boot 集成 Kafkad的實現(xiàn)示例
- Spring Boot 作為主流微服務(wù)框架，擁有成熟的社區(qū)生態(tài)。市場應(yīng)用廣泛，為了方便大家，整理了一個基于spring boot的常用中間件快速集成入門系列手冊，涉及RPC、緩存、消息隊列、分庫分表、注冊中心、分布式配置等常用開源組件，大概有幾十篇文章，陸續(xù)會開放出來，感興趣同學(xué)請?zhí)崆瓣P(guān)注&...
- 日期：2023-07-18
- 瀏覽：4
- 標(biāo)簽： Spring
-
- CentOS7上如何安裝Kafka?CentOS7上安裝Kafka教程
- Kafka 是一種高吞吐的分布式發(fā)布訂閱消息系統(tǒng)，能夠替代傳統(tǒng)的消息隊列用于解耦合數(shù)據(jù)處理，緩存未處理消息等。那么CentOS7上如何安裝Kafka?下面小編將為大家?guī)鞢entOS7上安裝Kafka教程！有需要的朋友一起去看看吧
- 日期：2022-06-06
- 瀏覽：101
-
- Zabbix對Kafka topic積壓數(shù)據(jù)監(jiān)控的問題(bug優(yōu)化)
- 這篇文章主要介紹了Zabbix對Kafka topic積壓數(shù)據(jù)監(jiān)控,本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下
- 日期：2023-04-06
- 瀏覽：168
- 標(biāo)簽： Zabbix
-
- Java實現(xiàn)Kafka生產(chǎn)者消費者代碼實例
- Kafka的結(jié)構(gòu)與RabbitMQ類似，消息生產(chǎn)者向Kafka服務(wù)器發(fā)送消息，Kafka接收消息后，再投遞給消費者。生產(chǎn)者的消費會被發(fā)送到Topic中，Topic中保存著各類數(shù)據(jù)，每一條數(shù)據(jù)都使用鍵、值進(jìn)行保存。每一個Topic中都包含一個或多個物理分區(qū)（Partition），分區(qū)維護(hù)著消息的內(nèi)容和...
- 日期：2022-09-02
- 瀏覽：2
- 標(biāo)簽： Java
-
- Java kafka如何實現(xiàn)自定義分區(qū)類和攔截器
- 生產(chǎn)者發(fā)送到對應(yīng)的分區(qū)有以下幾種方式：（1）指定了patition，則直接使用；(可以查閱對應(yīng)的java api, 有多種參數(shù))（2）未指定patition但指定key，通過對key的value進(jìn)行hash出一個patition；（3）patition和key都未指定，使用輪詢選出一個patitio...
- 日期：2022-08-31
- 瀏覽：55
- 標(biāo)簽： Java
-
- Java實現(xiàn)Kafka生產(chǎn)者和消費者的示例
- Kafka簡介Kafka是由Apache軟件基金會開發(fā)的一個開源流處理平臺，由Scala和Java編寫。Kafka的目標(biāo)是為處理實時數(shù)據(jù)提供一個統(tǒng)一、高吞吐、低延遲的平臺。方式一：kafka-clients引入依賴在pom.xml文件中，引入kafka-clients依賴：<dependenc...
- 日期：2022-08-17
- 瀏覽：129
- 標(biāo)簽： Java
排行榜
網(wǎng)公網(wǎng)安備