一、大数据框架三种语义???? 在分布式系统中,如kafka、spark、flink等构成系统的任何节点都是被定义为可以彼此独立失败的。比如在 Kafka 中,broker 可能会 crash,在 producer 推送数据至 topic 的过程中也可能会遇到网络问题。根据 producer 处理此 ...
分类:
其他好文 时间:
2021-04-09 13:27:18
阅读次数:
0
环境:RAC1:192.168.56.111 (db版本:12.2.0.1)RAC2:192.168.56.112 (db版本:12.2.0.1)DG备库:192.168.56.19 (db版本:12.2.0.1) OGG源库OGG目标库:192.168.56.166 (db版本:11.2.0.4) ...
分类:
其他好文 时间:
2021-04-08 14:02:34
阅读次数:
0
zkCli.sh ls / 记住zk的根目录下内容 ls或者get /kafka/cluster/id 查看zk下的kafuka controller ls /kafka/brokers/ kafka目录下 config查看配置:server.properties broker.id=0 liste ...
分类:
其他好文 时间:
2021-04-08 13:49:09
阅读次数:
0
Half Message: 预处理消息,当broker收到此类消息后,会存储到RMQ_SYS_TRANS_HALF_TOPIC的消息消费队列中 检查事务状态: Broker会开启一个定时任务,消费RMQ_SYS_TRANS_HALF_TOPIC队列中的消息, 每次执行任务会向消息发送者确认事务执行状 ...
分类:
编程语言 时间:
2021-03-31 12:18:34
阅读次数:
0
各角色介绍 Producer:消息的发送者;举例:发信者 Consumer:消息接收者;举例:收信者 Broker:暂存和传输消息;举例:邮局 NameServer:管理Broker;举例:各个邮局的管理机构 Topic:区分消息的种类;一个发送者可以发送消息给一个或者多个Topic;一个消息的接收 ...
分类:
其他好文 时间:
2021-03-30 13:23:18
阅读次数:
0
emqx 安装教程 启动失败 根据提示,我们查看启动失败日志 接着我们查看官网,对应常见错误,找到对应的解决办法, 查询 crypto依赖的 .so 动态库列表及其在内存中的地址:(其中 OPENSSL_1.0.2' not found表明指定的 OPENSSL 版本的 .so 库未正确安装) 我是 ...
分类:
其他好文 时间:
2021-03-06 14:53:32
阅读次数:
0
目前,编程人员面对的最大挑战就是复杂性,硬件越来越复杂,OS越来越复杂,编程语言和API越来越复杂,我们构建的应用也越来越复杂。根据外媒的一项调查报告,以下列出了Java程序员在过去12个月内一直使用的一些工具或框架,或许会对你有意义。 先来看看大数据的概念。根据维基百科,大数据是庞大或复杂的数据集 ...
分类:
编程语言 时间:
2021-03-02 12:15:50
阅读次数:
0
RocketMq灰皮书(三) MQ使用 在使用MQ之前,我们回顾一下前两篇博文的内容. 我们大致了解了RocketMQ的四个概念,分别是:Producer,Consumer,Message和Broker 我们在本地的Windows10系统上,部署了RocketMQ和其后台系统 在本篇博文中,我们会使 ...
分类:
其他好文 时间:
2021-02-19 13:45:46
阅读次数:
0
操作步骤如下: 前提:已经安装了docker 1.docker search rocketmq 2.docker pull rocketmqinc/rocketmq 3. 创建 mq 配置文件 broker.conf,文件放置到 /opt/rocketmq/conf ,配置如下: brokerClu ...
分类:
其他好文 时间:
2021-02-03 11:08:50
阅读次数:
0
dfs 题解前递归 根节点是0,变量保存最大深度,如果当前深度大于最大深度就更新,返回最大深度 var maxDepth = function(root) { let maxDeep = 0 //最大深度 let dg = (root,deep = 0) => { //deep当前深度 if(roo ...
分类:
其他好文 时间:
2021-01-20 12:06:48
阅读次数:
0