一、为什么分区 kafka有主题(Topic)的概念,它是承载真实数据的逻辑容器,而在主题之下还分为若干个分区,也...[作者空间]
前言:该博客主要是记录自己学习的过程,方便以后查看,当然也希望能够帮到大家。 完整代码地址在结尾!! 第一步,在p...[作者空间]
(1)RabbitMQ的高可用性 RabbitMQ是比较有代表性的,因为是基于主从做高可用性的,我们就以他为例子讲...[作者空间]
简介 kafka是一个分布式消息队列。具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息,消费者从...[作者空间]
本篇是在《Kafka Stream简单示例(一)》 和《Kafka Stream简单示例(二)---聚合 Aggr...[作者空间]
本篇是在《Kafka Stream简单示例(一)》 和《Kafka Stream简单示例(二)---聚合 Aggr...[作者空间]
在《Kafka Stream简单示例(一)》基础上,我们稍作修改实现一个基于固定时间窗口统计总和的例子。 项目需求...[作者空间]
问题来源 实际项目中,我们会遇到kafka消费不及时,系统发现最新的数据一致无法出现,这时候通过其他kafka工具...[作者空间]
实际项目中我们可能在创建topic时没有设置好正确的replication-factor,导致kafka集群虽然是...[作者空间]
版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/russle/a...[作者空间]
转自:https://blog.csdn.net/russle/article/details/81258590 ...[作者空间]
1、安装zookeeper 下载zookeeper-3.4.9.tar; 解压tar -zxvf zookeepe...[作者空间]
本文转载自:http://www.cnblogs.com/likehua/p/3999538.html,作者做了一...[作者空间]