為您找到相關(guān)結(jié)果185,624個
深入理解Apache Kafka(分布式流處理平臺)_Linux_腳本之家
Apache Kafka是一個分布式流處理平臺,最初由LinkedIn開發(fā),后成為Apache頂級項目。它具有以下核心特性:發(fā)布-訂閱消息系統(tǒng):支持生產(chǎn)者-消費(fèi)者模式的消息傳遞 高吞吐量:即使是非常普通的硬件也能支持每秒數(shù)十萬條消息 持久化存儲:消息可持久化到磁盤,并支持?jǐn)?shù)據(jù)備份 分布式架構(gòu):易于水平擴(kuò)展,支持集群部署 實(shí)時處理:支持
www.dbjr.com.cn/server/339644q...htm 2025-5-31
一文教你如何監(jiān)控Kafka Topic的生產(chǎn)者客戶端_Linux_腳本之家
查看kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec,可獲取 Topic 的寫入速率。 (3)使用命令行查詢 JMX 1 2 # 使用 jcmd 查看指標(biāo)(需 Java 11+) jcmd <Kafka_PID> PerfCounter.print |grepProducer 4. 方法 3:分析 Kafka Broker 日志 Kafka Broker 日志默認(rèn)位于 logs/server.log,可從中提取生...
www.dbjr.com.cn/server/340324y...htm 2025-5-22
Kafka攔截器的神奇操作方法_java_腳本之家
定義:攔截器是 Kafka 中的一種插件,用于在消息發(fā)送和接收的關(guān)鍵步驟中進(jìn)行攔截和處理。它可以捕獲消息并對其進(jìn)行修改、記錄、監(jiān)控或者執(zhí)行其他定制化的操作。 基本原理:攔截器通過實(shí)現(xiàn) Kafka 的org.apache.kafka.clients.producer.ProducerInterceptor接口(生產(chǎn)者攔截器)和org.apache.kafka.clients.consumer.ConsumerInterceptor...
www.dbjr.com.cn/program/334689g...htm 2025-5-25
SpringBoot集成Kafka的實(shí)現(xiàn)示例_java_腳本之家
三、Spring Boot 集成 Kafka 的步驟 (一)添加依賴 在Spring Boot 項目的 pom.xml 文件中添加以下依賴: 1 2 3 4 <dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka</artifactId> </dependency> 這個依賴將引入 Spring Kafka 模塊,使我們能夠在 Spring Boot 項目中使用 Kafk...
www.dbjr.com.cn/program/3340904...htm 2025-6-6
Flink結(jié)合Kafka實(shí)現(xiàn)通用流式數(shù)據(jù)處理_java_腳本之家
Partition:Kafka中的Partition是Topic的基本單位,表示一組連續(xù)的數(shù)據(jù)塊,用于實(shí)現(xiàn)數(shù)據(jù)的分布式存儲和并行處理。 Producer:Kafka中的Producer是一種生產(chǎn)者組件,用于將數(shù)據(jù)發(fā)送到Topic中的Partition。 Consumer:Kafka中的Consumer是一種消費(fèi)者組件,用于從Topic中讀取數(shù)據(jù)。
www.dbjr.com.cn/program/3372415...htm 2025-5-29
解讀RabbitMQ和kafka的相同點(diǎn)和不同點(diǎn)是什么_java_腳本之家
Kafka: 具有高吞吐量的特點(diǎn),能夠處理海量的消息。 它是為大數(shù)據(jù)處理和流處理場景設(shè)計的,在處理大規(guī)模數(shù)據(jù)寫入和讀取時性能優(yōu)勢明顯。 不過,Kafka的消息傳遞可能會有一定的延遲,在對實(shí)時性要求極高的場景下可能不太適用。 例如,在大數(shù)據(jù)分析系統(tǒng)中,Kafka可以高效地收集和傳輸各種數(shù)據(jù)源產(chǎn)生的大量數(shù)據(jù),供后續(xù)的數(shù)據(jù)分析...
www.dbjr.com.cn/program/332358r...htm 2025-6-5
Kafka之kafka-topics.sh的使用解讀_java_腳本之家
一、kafka的基本操作 1.1、創(chuàng)建topic 1 sh kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 參數(shù)說明: –create 是創(chuàng)建主題的的動作指令。 –zookeeper 指定kafka所連接的zookeeper服務(wù)地址。 –replicator-factor 指定了副本因子(即副本數(shù)量); 表示該topi...
www.dbjr.com.cn/article/2773...htm 2025-6-3