Kafka快速入门(二)——Kafka架构一、Kafka架构简介1、Kafka架构简介2、RecordRecord即Kafka消息,是Kafka处理的主要对象。3、TopicTopic是承载Kafka消息数据的逻辑容器,用于区分具体的业务,但在物理上,不同Topic的消息分开存储,逻辑上一个Topic的消息虽然保存在一个或多个Broker上,但用户只需指定消息的Topic即可生产或消费数据而不必关
分类:
其他好文 时间:
2020-05-24 10:09:12
阅读次数:
47
问题描述: 昨天晚上都下班了,突然领导发消息实时数据没有了,我去什么鬼,我记得我走的时候数据还是正常启动的,怎么就没数据那, 我们数据是通过flink 从kafka 消费数据,然后写入到hbase.怎么就没数据那什么情况。 然后我去yarn的资源管理器上面查看运行情况 发现,程序挂掉了,什么情况。好 ...
分类:
其他好文 时间:
2020-05-22 19:12:15
阅读次数:
88
一开始用别人封装好的W-picker进行时间日期选择,后来测试的时候发现IOS系统不兼容,后改成原生picker去选择 完整代码 <template> <view class="container"> <view class="uni-padding-wrap uni-common-mt"> <fo ...
分类:
其他好文 时间:
2020-05-22 15:37:48
阅读次数:
62
Advanced One to one video call 本示例是上一个示例的进阶版,添加了滤镜和录像回放功能 官网文档 Advanced One to one video call 首先从github上获取代码(如果已经获取可以跳过,获取的代码已经包括后面的示例代码了) git clone h ...
分类:
其他好文 时间:
2020-05-20 15:53:22
阅读次数:
53
双指针 思路: 一个指针负责遍历,另一个指针负责记录,遇到不同值时更新状态。 class Solution: def countAndSay(self, n: int) -> str: def getResult(para:str)->str: record = para[len(para)-1] ...
分类:
其他好文 时间:
2020-05-20 14:04:26
阅读次数:
45
CPU 1.查看CPU利用率较高的进程 pidstat 1 5 | grep -v $(hostnmae) |grep -v '^$' | sort -k 5 -rn | head 2.查看某个进程的调用关系 perf record -g -p pid Ctrl + C 中断收集 perf repo ...
分类:
系统相关 时间:
2020-05-18 16:19:43
阅读次数:
72
synchronized 锁定的是一个对象,执行某段代码的时候必须锁定一个对象,不锁定就无法执行 一、概念介绍 1.1 用户态与内核态 内核态(kener):内核/操作系统可以做的一些操作。 用户态(APP):用户的程序可以做的一些操作。 用户态的程序要访问一些比较危险的操作的时候,比如格式化硬盘或 ...
分类:
其他好文 时间:
2020-05-17 16:04:20
阅读次数:
86
create table order_ipad( id bigint(20) unsigned not null auto_increment,comment '自增主键', uuid bigint(20) unsigned not null default '0' comment '用户id', ...
分类:
其他好文 时间:
2020-05-15 17:55:14
阅读次数:
55
有一系列产品的版本,如果其中一个版本错了,则在它之后的都错了。调用API函数 isBadVersion( )找到错误开始的源头,要求尽量少的调用API。Given n = 5, and version = 4 is the first bad version. call isBadVersion(3 ...
分类:
其他好文 时间:
2020-05-14 01:20:55
阅读次数:
66
3.12 实战二:如何实现一个支持各种统计规则的性能计数器? 3.12.1 划分职责进而识别出有哪些类 根据需求描述,先大致识别出下面几个接口或类。这一步不难,完全就是翻译需求。 MetricsCollector 类负责提供 API,来采集接口请求的原始数据。我们可以为 MetricsCollect ...
分类:
其他好文 时间:
2020-05-13 23:05:03
阅读次数:
60