(Azure Service Bus服务总线的两大类消息处理方式： 队列Queue和主题Topic) 问题描述 使用Service Bus作为企业消息代理，当有大量的数据堆积再Queue或Topic中时，如何来优化接收端处理消息的能力呢？ 详细解释 在接收端(Receover)的代码中，有两个属性与 ...
分类：
其他好文 时间：
2021-03-17 14:56:44
阅读次数：
0
pip install setuptools pip install kafka-python执行以上两个命令就可以安装成功。说明：setuptools是kafka-python的依赖库 ...
分类：
编程语言 时间：
2021-03-17 14:49:03
阅读次数：
0
目录 一、Kafka的架构 二、Topics和Partition 三、Producer消息路由 四、Consumer Group 五、Push vs. Pull 六、Kafka delivery guarantee 正文 回到顶部 一、Kafka的架构 如上图所示，一个典型的Kafka集群中包含若干 ...
分类：
其他好文 时间：
2021-03-17 14:25:54
阅读次数：
0
大数据技术板块划分 数据采集 flume kafka logstash filebeat ... 数据存储 mysql redis hbase hdfs ... 虽然mysql不属于大数据范畴 但是我在这也列出来了，因为你在工作中离不开它 数据查询 hive impala elasticsearch ...
分类：
其他好文 时间：
2021-03-17 14:04:41
阅读次数：
0
问题：springboot集成kafka，并由KafkaStreams处理，启动报错 org.apache.kafka.streams.errors.StreamsException: Input record ConsumerRecord(topic = crawler_events, parti ...
分类：
编程语言 时间：
2021-03-16 14:11:28
阅读次数：
0
引言 NoSql：主要指非关系型、分布式、不提供ACID的数据库设计模式。 1 ES总结 主旨在于随时可用和按需扩容，通过购买性能更强大（垂直扩容、或纵向扩容）或者数量更多的服务器（水平扩容、或横向扩容）来实现。 垂直扩容有限，真正的扩容能力来自于水平扩容（为集群增加更多的节点，将负载压力和稳定性分 ...
分类：
其他好文 时间：
2021-03-15 10:34:48
阅读次数：
0
TopN的常见应用场景，最热商品购买量，最高人气作者的阅读量等等。 1. 用到的知识点 Flink创建kafka数据源； 基于 EventTime 处理，如何指定 Watermark； Flink中的Window，滚动（tumbling）窗口与滑动（sliding）窗口； State状态的使用； P ...
分类：
其他好文 时间：
2021-03-12 13:00:59
阅读次数：
0
相对于 synchronized 它具备如下特点 可中断 可以设置超时时间 可以设置为公平锁 支持多个条件变量，即对与不满足条件的线程可以放到不同的集合中等待 与 synchronized 一样，都支持可重入 基本语法 // 获取锁 reentrantLock.lock(); try { // 临界 ...
分类：
其他好文 时间：
2021-03-09 13:42:27
阅读次数：
0
转自：http://man-yutao.iteye.com/blog/1317446 ArrayList和Vector都是继承了相同的父类和实现了相同的接口。如下 Java代码 public class Vector<E> extends AbstractList<E> implements Lis ...
分类：
其他好文 时间：
2021-03-09 13:08:46
阅读次数：
0
图片来源于：极客时间《数据结构与算法之美》 https://time.geekbang.org/column/intro/126 1. 数组 数组是最简单的数据结构，它的结构特点是：需要连续的内存空间，能够通过数组下标快速的访问数组内的元素，但是初始时需要指定大小，并且不能动态扩容，当容量不够时，需 ...
分类：
编程语言 时间：
2021-03-08 14:07:35
阅读次数：
0
