2024-09-03 厉飞雨 阅读(328) 评论(0) 赞(15)

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

2024-09-03 厉飞雨 阅读(253) 评论(0) 赞(16)

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

2024-09-03 厉飞雨 阅读(191) 评论(0) 赞(17)

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

2024-09-03 厉飞雨 阅读(340) 评论(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...

2024-09-03 厉飞雨 阅读(275) 评论(0) 赞(16)

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

2024-09-03 厉飞雨 阅读(259) 评论(0) 赞(15)

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

2024-09-03 厉飞雨 阅读(294) 评论(0) 赞(16)

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

2024-09-03 厉飞雨 阅读(262) 评论(0) 赞(18)

filebeat对接kafka  - 模拟filebeat作为生产者 ----------------- 1.启动消费者 ...

2024-09-03 厉飞雨 阅读(202) 评论(0) 赞(14)

kafka开源监控组件-kafka-eagle 需要 kafka zk 开启 jmx 服务 参考文档: http://www.kafka-eagle.org/articles/docs/installation/dashu-macos.html http://www.kafka-eagle.org/articles/docs/changelog/changelog.htm...

2024-09-03 厉飞雨 阅读(385) 评论(0) 赞(19)

<p>kafka堆内存调优:</p> <h3>1.查看堆内存大小</h3> <pre><code>jmap -heap `jps | awk '/Kafka/{print $1}'` | grep MaxHeapSize </code></pre> <p>...