一、准备 1、启动zookeeper 2、启动kafka 3、kafka创建主题。主题名称为：couponTopic ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor ...

项目路径:https://github.com/zhaopeng01/springboot-study/tree/master/study_14 序言 Kafka 是一种高吞吐的分布式发布订阅消息系统，能够替代传统的消息队列用于解耦合数据处理，缓存未处理消息等，同时具有更高的吞吐率，支持分区 ...

　　菜谱微信小程序，操作简单，教程详细，欢迎大家使用 　　 导读 集成spring-kafka，生产者生产邮件message，消费者负责发送 引入线程池，多线程发送消息 多邮件服务器配置 定时任务生产消息；计划邮件发送 实现过程 ...

1Docker Compose 1.1运行以下命令以下载Docker Compose的当前稳定版本： 1.2将可执行权限应用于二进制文件： 1.3卸载 如果使用curl以下命令卸载Docker Compose ： 2单机版kafka ...

一、硬件考量 1.1、内存 不建议为kafka分配超过5g的heap，因为会消耗28-30g的文件系统缓存，而是考虑为kafka的读写预留充足的buffer。Buffer大小的快速计算方法是平均磁盘写入数量的30倍。推荐使用64GB及以上内存的服务器，低于32GB内存的机器可能会适得其反 ...

一、Kafka设计原理参考： http://blog.csdn.net/suifeng3051/article/details/48053965?locationNum=2 http://www.cnblogs.com/metoy/p/4452124.html 二、常见问题 ...

1.引言 最近接触到一个APP流量分析的项目，类似于友盟。涉及到几个C端（客户端）高并发的接口，这几个接口主要用于C端数据的提交。在没有任何缓冲的情况下，一个接口涉及到5张表的提交。压测 ...

1.1 背景介绍 最近，腾讯云的一个重要客户发现kafka broker内部的topic分区数据存储分布不均匀，导致部分磁盘100%耗尽，而部分磁盘只有40%的消耗量。 分析原因，发现存在部分topic的分区数据过于集中在某些磁盘导致，比如，以下截图显示的/data5 数据盘 ...