JMeter插件发送Kafka消息

JMeter直接加载一个扩展插件,可以直接发送Kafka消息

链接:https://github.com/BrightTag/kafkameter

放到JMeter_Dir/lib/ext里,重新启动jmeter之后,新增一个Java Request

就可以发现Kafka消息发送的信息

编辑brokers,topic,key和message即可

格式请按照约定的kafka消息格式来编辑

最好[……]

Read more

Kafka知识一览

来自:Kafka知识点整理

作者:cyfonly

一、为什么需要消息系统

1.解耦:
  允许你独立的扩展或修改两边的处理过程,只要确保它们遵守同样的接口约束。
2.冗余:
  消息队列把数据进行持久化直到它们已经被完全处理,通过这一方式规避了数据丢失风险。许多消息队列所采用的"插入-获取-删除"范式中,在把一个消息从队列中删除之前,需要你的处理系统明确的指出该消息已经被处理完[......]

Read more

Kafka单节点消息测试

最近迷上了互联网中间件,终于又有了深入钻研新鲜玩意的动力了

其实Kafka表面看起来是很简单的,就一个发布-订阅的消息中间件系统,但是就其使用广泛性来说,肯定有它的优势,而且它涉及到的概念还是挺多的,broker,topic,partitions,producer,consumer,每个概念还有一些属性,比如offset,leader,具体这些都在下面的测试过程中体会下

创建一个CentOS7的虚[……]

Read more