Wesley13 Wesley13
3年前
apache kafka系列之性能测试报告(虚拟机版)
测试方法在其他虚拟机上使用Kafka自带 kafkaproducerperftest.sh脚本进行测试Kafka写入性能尝试使用 kafkasimpleconsumerperftest.sh脚本测试KafkaConsumer性能,但由于获取到的数据不靠谱,放弃这个测试方法性能数据注:Gzip和Snappy
Stella981 Stella981
3年前
Kafka设计解析(五):Kafka Benchmark
性能测试及集群监控工具Kafka提供了非常多有用的工具,如Kafka设计解析(三)KafkaHighAvailability(下)(https://www.oschina.net/action/GoToLink?urlhttp%3A%2F%2Fwww.infoq.com%2Fcn%2Farticles%2Fkafk
Stella981 Stella981
3年前
Apache Kafka 概述
kafka教程,完全参照w3school:https://www.w3cschool.cn/apache\_kafka/apache\_kafkadac11yot.html(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fwww.w3cschool.cn%2Fapache_kafk
Stella981 Stella981
3年前
KafkaProducer Sender 线程详解(含详细的执行流程图)
\温馨提示:本文基于Kafka2.2.1版本。上文《源码分析Kafka消息发送流程》(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fblog.csdn.net%2Fprestigeding%2Farticle%2Fdetails%2F102994716)已经详细介绍
Stella981 Stella981
3年前
Kafka Producer端封装自定义消息
这篇文章主要讲kafkaproducer端的编程,通过一个应用案例来描述kafka在实际应用中的作用。如果你还没有搭建起kafka的开发环境,可以先参考:<kafka开发环境搭建(http://my.oschina.net/ielts0909/blog/95440)首先描述一下应用的情况:一个站内的搜索引擎,运营人员想知道某一时段,各类用户对商品
Stella981 Stella981
3年前
Kafka开发环境搭建
如果你要利用代码来跑kafka的应用,那你最好先把官网给出的example先在单机环境和分布式环境下跑通,然后再逐步将原有的consumer、producer和broker替换成自己写的代码。所以在阅读这篇文章前你需要具备以下前提:1.简单了解kafka功能,理解kafka的分布式原理2.能在分布式环境下成功运行—topictest。如果你
Stella981 Stella981
3年前
Spring Boot 2.x 快速集成Kafka
1KafkaKafka是一个开源分布式的流处理平台,一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者在网站中的所有动作流数据。Kafka由Scala和Java编写,2012年成为Apache基金会下顶级项目。2Kafka优点低延迟:Kafka支持低延迟消息传递,速度极快,能达到200w写/秒
Stella981 Stella981
3年前
Kafka 简介
Kafka简介_Kafka是分布式流平台。_一个流平台有3个主要特征:发布和订阅消息流,这一点与传统的消息队列相似。以容灾持久化方式的消息流存储。在消息流发生时处理消息流。Kafka通常使用在两大类应用中:在系统或应用之间,构建实时、可靠的消息流管道。构建实时流应用
Stella981 Stella981
3年前
Spark Streaming 结合 Kafka 两种不同的数据接收方式比较
SparkStreaming结合Kafka两种不同的数据接收方式比较博客分类:sparkDirectKafkaInputDStream只在driver端接收数据,所以继承了InputDStream,是没有receivers的在结合SparkStreaming及Kafka的实时应用中,我们通常使用以下两个API来获
Stella981 Stella981
3年前
Kafka01
Kafka之生产者入门前言:  Kafka诞生至今,产生两个版本的生产者客户端:1是早期基于scala语言编写的客户端;2是随着Java用户的广泛涌入,kafka0.9版本开始退出Java版本的客户端;  一个基本生产者producer逻辑需要具备以下基本条件:配置Producer,创建生产者实例;