kafka 相关的知识进入 /usr/local/kafka 目录下查看端口 vim zookeeper.properties #文件中dataDir=/tmp/zookeeper代表zookeeper数据存储路径,clientPort=2182代表zookeeper的端口号为:2182,消费者需要 ...
分类:
其他好文 时间:
2020-01-13 20:22:45
阅读次数:
124
ack应答机制 有三个值: 0:producer不需要确认消息,直接发送消息给leader,有没有收到消息,producer不管; 上图中去掉5、6步;速度块,安全性最低(当broker故障,会 丢失数据 )。 1:producer发送消息,确保leader写入成功,followers不管;上图中, ...
分类:
其他好文 时间:
2020-01-13 12:54:21
阅读次数:
496
本文记录一下kafka多机多Broker(集群)的基本配置,在上篇的基础上进行,上篇配置在192.168.7.151上,本篇在152上。 一、在服务器192.168.7.152上配置两个Broker 1、将151上的kafka远程拷贝到152上 [root@localhost local]# scp ...
分类:
其他好文 时间:
2020-01-12 16:42:11
阅读次数:
102
2019-04-11 分类:Oracle 阅读(2626) 评论(0) 文章目录[隐藏] 一、DataGuard 工作原理 二、搭建环境 三、主库配置 四、备库配置 五、主备切换 一、DataGuard 工作原理 Data Gurad 通过冗余数据来提供数据保护,Data Gurad 通过日志同步机 ...
分类:
数据库 时间:
2020-01-12 09:54:58
阅读次数:
253
Dataguard主、备库切换方法总结 2019-04-11 分类:Oracle 阅读(754) 评论(0) 文章目录[隐藏] 一、主备切换: 一、主备切换: 1.将主库切换成物理standby: alter database commit to switchover to physical sta ...
分类:
其他好文 时间:
2020-01-12 09:47:35
阅读次数:
115
1.消息发送机制 Kafka的ack机制。 当producer向leader发送数据时,可以通过request.required.acks参数来设置数据可靠性的级别: 1(默认):这意味着producer在ISR中的leader已成功收到的数据并得到确认后发送下一条message。如果leader宕 ...
分类:
其他好文 时间:
2020-01-11 20:15:43
阅读次数:
92
Celery架构 Celery的架构由三部分组成,消息中间件(message broker)、任务执行单元(worker)和 任务执行结果存储(task result store)组成。 消息中间件 Celery本身不提供消息服务,但是可以方便的和第三方提供的消息中间件集成。包括,RabbitMQ, ...
分类:
其他好文 时间:
2020-01-11 20:06:41
阅读次数:
97
IntroductionRabbitMQ is a message broker: it accepts and forwards messages. You can think about it as a post office: when you put the mail that you wa... ...
分类:
其他好文 时间:
2020-01-11 18:48:55
阅读次数:
94
RabbitMQ介绍以下内容搬运自RabbitMQ官网RabbitMQ is the most widely deployed open source message broker.RabbitMQ是使用最广泛的开源的消息中转器With tens of thousands of users, Rab... ...
分类:
其他好文 时间:
2020-01-11 11:35:30
阅读次数:
98
一、概念 相当于一个ActiveMQ服务实例 Broker其实就是实现了用代码的形式启动了ActiveMQ将MQ嵌入到java代码中,以便随时用随时启动,在用的时候再去启动这样能节约资源,也保证了可靠性。 二、按照不同配置文件启动ActiveMQ 1、 先将ActiveMQ根目录下conf文件夹中的 ...
分类:
其他好文 时间:
2020-01-10 22:19:39
阅读次数:
123