14篇文章 · 21642字 · 2人关注
producer还分为同步和异步模式，由属性producer.type指定，默认是sync，即同步发送模式。 mmap和producer.typ...
kafka中的消费者在读取服务端的数据时，需要将服务端的磁盘文件通过网络发送到消费者进程，网络发送需要经过几种网络节点。如下图所示： 传统的读取...
一、kafka的存储机制 kafka通过topic来分主题存放数据，主题内有分区，分区可以有多个副本，分区的内部还细分为若干个segment。 ...
调优目标 在做调优之前，我们必须明确优化 Kafka 的目标是什么。通常来说，调优是为了满足系统常见的非功能性需求。在众多的非功能性需求中，性能...
sarama是kafka go语言的的一个框架，star数也挺高的，这里记录下使用遇到的一些问题。 跟着官方给的例子学习，文件consumer_...
创建topic ./kafka-topics.sh --create --zookeeper localhost:2181 --replicat...
压缩秉承了用时间去换空间的经典 trade-off 思想，具体来说就是用 CPU 时间去换磁盘空间或网络 I/O 传输量，希望以较小的 CPU ...
我们在使用 Apache Kafka 生产和消费消息的时候，肯定是希望能够将数据均匀地分配到所有服务器上。比如很多公司使用 Kafka 收集应用...
Topic 级别参数 你可能会有这样的疑问：如果同时设置了 Topic 级别参数和全局 Broker 参数，到底听谁的呢？哪个说了算呢？答案就是...
文集作者
