51工具盒子

依楼听风雨
笑看云卷云舒,淡观潮起潮落

kafka

prometheus监控kafka集群

prometheus监控kafka集群

厉飞雨 阅读(295) 评论(0) 赞(22)

<p>k8s 监控kafka集群</p> <p>kafka_exporter地址:<a href="https://github.com/danielqsj/kafka_exporter">https://github.com/danielqsj/kafka_exporter</a></p&g...

idea插件 kafka

idea插件 kafka

厉飞雨 阅读(328) 评论(0) 赞(15)

IDEA插件 Kafka ============ JetBrains官方研发的插件,支持 IntelliJ IDEA Ultimate, AppCode, Aqua, CLion, DataGrip, DataSpell, GoLand, PhpStorm, PyCharm Professional, Rider, RubyMine, WebStorm。 <http...

k8s 部署kafka (kubesphere)

k8s 部署kafka (kubesphere)

厉飞雨 阅读(251) 评论(0) 赞(16)

<p>这里白眉大叔用 kubesphere 来部署kafka</p> <p>因为 kafka依赖 zookeeper,先 安装一下 zookeeper 吧。<a href="https://51tbox.com/">k8s 部署zookeeper(kubesphere)</a></p> ...

Kafka 数据可靠性如何保证?

Kafka 数据可靠性如何保证?

厉飞雨 阅读(190) 评论(0) 赞(17)

Kafka 数据可靠性如何保证? 对于 kafka 来说,以下几个方面来保障消息分发的可靠性: 1.消息发送的可靠性保障(producer) 2.消息消费的可靠性保障(consumer) 3.Kafka 集群的可靠性保障(Broker) ### 生产者 目前生产者发送消息(acks)有三种方式。 acks=0 producer 不等待 broker 的...

kafka参数调优

kafka参数调优

厉飞雨 阅读(338) 评论(0) 赞(14)

<p>kafka参数调优</p> <h3>1.broke</h3> <pre><code>可以按如下配置 将自动生成 brokeid 自动识别 host.name #broker.id=2 listeners=SASL_PLAINTEXT://:9092 zookeeper.connect=10.161.1...

kafka原理之为什么快

kafka原理之为什么快

厉飞雨 阅读(274) 评论(0) 赞(16)

kafka原理之为什么快 消息持久化及其缓存 磁盘性能:在传统的磁盘写入很慢,因为它使用随机写入 50k/s(6 个 7200 转的 sata 硬盘组成的 raid-5),但是线性写入速度有 300ms/s 的速度,所以 kafka 利用线性写入的方式。 线性写入:将数据调用操作系统文件接口写到文件系统里面去这样就缓存到操作系统的页面缓存中,然后传统意思来说将其 flus...

logstash对接kafka (待完善)

logstash对接kafka (待完善)

厉飞雨 阅读(257) 评论(0) 赞(15)

logstash对接kafka: - 模拟logstash作为kafka的生产者 ----------------------- ![](http://static.51tbox.com/static/2024-08-29/col/94bde040234b4a71fb9b494b37e33cdb/057438c131f446249fdcec3adf6551ba.png....

kafka集群压力测试

kafka集群压力测试

厉飞雨 阅读(291) 评论(0) 赞(16)

### 1.什么叫压力测试 在软件工程中,压力测试是对系统不断施加压力的测试,是通过确定一个系统的瓶颈或者不能接收的性能点,来获得系统能提供的最大服务级别的测试。 ​ 简单来说,所谓压力测试就是对一个集群的处理能力的上限做一个评估。为将来集群扩容提供有效的依据。 ### 2.为什么要进行压力测试 (1)压力测试可以了解当前集群的处理能力上限; (2)当修改集群...