`
sillycat
  • 浏览: 2542735 次
  • 性别: Icon_minigender_1
  • 来自: 成都
社区版块
存档分类
最新评论

Kafka Cluster 2019(5)WRK Performance Testing

 
阅读更多
Kafka Cluster 2019(5)WRK Performance Testing

A very simple script to support the POST using LUA
> cat post_message.lua
method="POST"
path = "/kafka/topic1"
batch = 10
request  = function()
   headers = {}
   headers["Content-Type"] = "application/json"
   body = 'message sillycat from mvc'
   -- print(body)
   return wrk.format(method, path, headers, body)
end
response = function(status, headers, body)
   -- print(status)
end

Check the normal servlet driver
> wrk -t4 -c1000 -d60s --timeout 10s -s ./post_message.lua http://ubuntu-master:8082 --latency
Running 1m test @ http://ubuntu-master:8082
  4 threads and 1000 connections
  Thread Stats   Avg      Stdev     Max   +/- Stdev
    Latency   617.66ms  275.77ms   2.87s    75.73%
    Req/Sec   408.14    107.39   737.00     69.41%
  Latency Distribution
     50%  582.81ms
     75%  774.61ms
     90%  946.28ms
     99%    1.33s
  97320 requests in 1.00m, 11.70MB read
Requests/sec:   1619.96
Transfer/sec:    199.43KB

It is strange that the Reactive Driver does not have better performance in here
> wrk -t4 -c1000 -d60s --timeout 10s -s ./post_message.lua http://ubuntu-master:8083 --latency
Running 1m test @ http://ubuntu-master:8083
  4 threads and 1000 connections
  Thread Stats   Avg      Stdev     Max   +/- Stdev
    Latency     1.55s   792.12ms   9.90s    93.56%
    Req/Sec   268.95    269.73     1.49k    84.05%
  Latency Distribution
     50%    1.43s
     75%    1.65s
     90%    2.03s
     99%    5.48s
  37386 requests in 1.00m, 3.07MB read
  Socket errors: connect 0, read 0, write 0, timeout 109
Requests/sec:    622.27
Transfer/sec:     52.26KB


References:


分享到:
评论

相关推荐

    尚硅谷大数据技术之Kafka(2019新版)源码笔记

    尚硅谷大数据技术之Kafka(2019新版)源码笔记,视频bilibili上有

    docker-kafka-cluster集群安装

    【标题】:Docker-Kafka-Cluster集群安装 在现代分布式系统中,Apache Kafka作为一个高效、可扩展的消息中间件,广泛应用于数据流处理和实时数据分析。为了方便在各种环境中快速部署Kafka,我们可以利用Docker容器...

    kafkaCluster

    卡夫卡集群要部署此kafka系统,您需要一个docker swarm集群,在集群的管理器节点上运行以下命令: sudo docker stack deploy --compose-file=docker-compose.yml microservice就是这样!您已经部署了一个kafka集群!

    Packt.Learning.Apache.Kafka.2nd.Edition

    multi-broker Kafka cluster and shares the Kafka broker properties list. Chapter 3, Kafka Design, discusses the design concepts used to build the solid foundation for Kafka. It also talks about how ...

    kafka-cluster-infra:Terraform和Ansible安装Kafka集群

    在`kafka-cluster-infra-master`目录下,你应该会找到这些Terraform配置文件,包含了关于AWS资源的详细设定。 接下来,Ansible负责在创建的EC2实例上执行自动化脚本,完成Kafka和相关组件的安装与配置。Ansible使用...

    kafkatool 连接kafka工具

    **Kafka Tool 连接 Kafka 工具详解** 在大数据处理和实时流处理领域,Apache Kafka 是一个不可或缺的组件,它作为一个分布式的消息中间件,提供高效、可扩展且可靠的发布订阅服务。为了方便管理和操作 Kafka 集群,...

    kafka-eagle

    **Kafka-eagle** 是一个专门针对Apache Kafka的开源监控和管理工具,旨在提供高效、直观的界面,帮助用户管理和监控Kafka集群的性能和健康状况。该项目包含两个已测试并确认好用的版本,即1.2.4和1.2.9,用户可以...

    building-data-streaming-applications-apache-kafka

    Chapter 5: Building Spark Streaming Applications with Kafka Chapter 6: Building Storm Applications with Kafka Chapter 7: Using Kafka with Confluent Platform Chapter 8: Building ETL Pipelines Using ...

    kafka_cluster.tar.gz

    5. **启动和验证服务**:使用Ansible的`service`模块启动Kafka和Zookeeper服务,并确保它们在启动后保持运行状态。此外,还可以编写脚本或命令来检查Kafka集群是否健康,例如通过`kafka-topics.sh`和`kafka-consumer...

    cluster-kafka集群配置9091-9093

    在分布式消息系统中,Apache Kafka是一个非常重要的组件,它提供了高效、可扩展和耐用的消息传递功能。在集群环境中,为了实现高可用性和负载均衡,Kafka通常会部署为多节点的集群。本篇将深入探讨如何配置一个使用...

    Kafka Streams in Action v8 MEAP 高清

    8 Testing a Kafka Streaming Application PART 4: ADVANCED CONCEPTS WITH KAFKA STREAMS 9 Advanced Applications with Kafka Streams APPENDIXES: A Additional Configuration Information B Exactly Once ...

    5、kafka监控工具Kafka-Eagle介绍及使用

    5. **开源免费**:Kafka-Eagle 是一款开源软件,社区活跃,不断更新和改进,适应不断变化的监控需求。 在部署 Kafka-Eagle 之前,需要确保 Kafka 和 ZooKeeper 已经正确安装并运行。开启 Kafka 的 JMX 端口是必要的...

    Kafka管理工具Kafka Tool

    5. **性能测试**:内置的生产者和消费者模拟器可以用于测试Kafka集群的性能,包括消息发送速率、延迟等,这对于优化集群配置和评估扩展性具有重要意义。 6. **监控与报警**:Kafka Tool可以设置阈值监控,当达到...

    kafkatool_64bit.exe.zip

    It provides an intuitive UI that allows one to quickly view objects within a Kafka cluster as well as the messages stored in the topics of the cluster. It contains features geared towards both ...

    kafka_2.12-3.3.1.tgz

    5. **消息持久化与可靠性**: Kafka可以配置为保留消息一定的时间或达到一定的大小后才删除,这使得它可以作为数据湖的一部分,用于后期分析。Kafka还支持幂等性生产者,避免了重复消息的问题。 6. **灵活的数据模型...

    Kafka the Definitive Guide 2nd Edition

    * 集群(Cluster):Kafka 中的集群概念,用于分布式存储和处理消息。 3. Kafka 的优点 Kafka 的优点包括: * 高性能:Kafka 能够处理高吞吐量的消息数据。 * 可扩展性:Kafka 能够水平扩展,满足大规模数据处理...

    Kafka生产者守护进程Bruce.zip

    Bruce serves as a single intake point for a Kafka cluster, receiving messages from diverse clients regardless of what programming language a client is written in. Client code is currently available ...

Global site tag (gtag.js) - Google Analytics