RocketMQ为什么要保证订阅关系的一致性？ 搭建 RocketMQ 集群过程中遇到了关于消费订阅的问题，具体问题如下 报错的日志信息： the consumer's subscription not exist找到源码里报错的位置 org.apache.rocketmq.broker.proce ...
分类：
其他好文 时间：
2020-03-30 14:40:55
阅读次数：
92
第一次重启： 第二次重启再次进入安装光盘/USB： 此时按Shift + F10调出命令提示符，输入regedit打开注册表： 加载以下文件到注册表【HKEY_USERS】下（系统所在盘符）:\Windows\System32\config\SAM（系统所在盘符）:\Windows\System32 ...
分类：
Windows程序 时间：
2020-03-28 00:59:42
阅读次数：
1459
目录 6.2 Zookeeper在大型分布式系统中的应用 6.2.1 Hadoop YARN介绍 如何解决ResourceManager单点问题，实现高可用？ 6.2.3 Kafka 术语介绍 问题 Kafka与Zookeeper Broker注册管理 Topic注册管理 生产者负载均衡 消费者负载 ...
分类：
其他好文 时间：
2020-03-27 10:40:50
阅读次数：
117
Kafka-常用术语(消息、生产者、消费者、集群、broker解释) 消息和批次 kafka的数据单元被称为消息。类似于数据库表中的一行数据。 消息由字节数组组成，所以对于kafka来说，消息里的数据没有特别的格式或含义。 消息可以有一个可选的元数据，也就是键，键也是一个字节数组，当消息以一种可控的 ...
分类：
其他好文 时间：
2020-03-24 21:43:11
阅读次数：
88
SASL/PLAIN 是一种简单的 username/password 认证机制, 通常与 TLS 加密一起使用, 用于实现安全认证. Kafka 提供了一个默认的 SASL/PLAIN 实现, 可以做扩展后在生产环境使用. 1 配置kafka server端（每个broker） JAAS文件作为每 ...
分类：
其他好文 时间：
2020-03-23 00:29:27
阅读次数：
86
1、celery执行定时任务1)几点几分执行：celery_task-s1.pyfrom celery import Celeryimport time# redis不加密码broker='redis://127.0.0.1:6379/0'backend='redis://127.0.0.1:637... ...
分类：
其他好文 时间：
2020-03-22 01:25:03
阅读次数：
67
记录下和kafka相关的Message、日志文件、索引文件、consumer记录消费的offset相关内容，文中很多理解参考文末博文、书籍还有前辈。 kafka中的消息 kafka中的消息Message，在V1版本中是如下部分组成，主要关系key和value。 （1）key：当需要将消息写入到某个t ...
分类：
其他好文 时间：
2020-03-22 01:01:11
阅读次数：
82
1、什么是celeryCelery是一个简单、灵活且可靠的，处理大量消息的分布式系统专注于实时处理的异步任务队列同时也支持任务调度celery架构：Celery的架构由三部分组成，消息中间件（message broker），任务执行单元（worker）和任务执行结果存储（task result st... ...
分类：
其他好文 时间：
2020-03-22 00:59:24
阅读次数：
82
`为SDB创建模式用户，表空间集，分片表和重复表。验证DDL已传播到所有分片，并在连接到分片时，通过快速启动故障转移验证Data Guard Broker的自动配置。` 1.连接到分片目录数据库，创建应用程序模式用户，并向该用户授予特权和角色 2.为分片表创建一个表空间集 3.为重复的表创建一个表空 ...
分类：
数据库 时间：
2020-03-21 23:50:12
阅读次数：
174
(按行枚举) O(n!)说明：对角线dg[u + i]，反对角线udg[n - u + i]中的下标表示的是截距(u, i)即(x, y)对角线y = x + b, 截距b = y - x（因为我们要把b当做数组下标，所以b不能是负的，所以我们+n，保证是结果是正的） 反对角线y = -x + b, ...
分类：
其他好文 时间：
2020-03-18 23:46:36
阅读次数：
53
