在kafka中,我们能创建多种类型的集群,一般如下:单节点——单个broker集群单节点——多broker集群多结点——多broker集群kafka集群中主要有五个组件:Topic:主题主要用于用一个名字标识生产者往kafka发送了什么类型的消息,作为消息归类的标识唯一键。在kafka中,主题被分区...
分类:
其他好文 时间:
2015-10-28 19:11:12
阅读次数:
167
在broker的配置中,auto.leader.rebalance.enable (false) 那么这个leader是如何进行rebalance的? 首先在controller启动的时候会打开一个scheduler, if (config.autoLeaderRebalanceEnable) { ...
分类:
Web程序 时间:
2015-10-27 13:07:08
阅读次数:
292
kafka apis反映出kafka broker server可以提供哪些服务,broker server主要和producer,consumer,controller有交互,搞清这些api就清楚了broker server的所有行为 handleOffsetRequest 提供对offset的查...
Toolkit界面初识 上面的界面是Toolkit启动后的第一个界面,我们最常用的有5个区块: 菜单区:系统菜单区,包括所有的操作。 Broker开发区:开发工程树结构就在此区,这里最常用的有创建应用程序和创建库,单击右键将...
分类:
Web程序 时间:
2015-10-26 22:45:39
阅读次数:
343
本次配置11Grac到单机ASM的dataguard配置,11Grac的安装参考oracle11Grac安装(VMware+rhel6.3),11G单机ASM安装参考Oracle11G单机asm安装。环境介绍:主库:112032节点RAC实例名:racdb1,racdb2db_name:racdbdb_unique_name:racdb备库:11203单机ASM实例名:racdbstddb_name..
分类:
数据库 时间:
2015-10-21 17:37:07
阅读次数:
423
kafka 集群--3个broker 3个zookeeper创建实战准备工作:1. 准备3台机器,IP地址分别为:192.168.0.10,192.168.0.11,192.168.0.122. 下载kafka稳定版本,我的版本为:kafka_2.9.2-0.8.1.1.tgz3. 分别解压放入到想...
分类:
其他好文 时间:
2015-10-21 12:15:22
阅读次数:
459
1 Use HelloWorldDB 2 go 3 4 SET NOCOUNT ON 5 DECLARE @conversationHandle uniqueidentifier 6 7 Begin Transaction 8 -- 开始 Hello World 服务的对话 9 10 BEGI...
分类:
其他好文 时间:
2015-10-18 01:15:28
阅读次数:
226
每个rabbitmqnode运行RabbitMQapplication,共享用户virtual hosts, queues, exchanges, etc.一个nodes组称之为一个集群。所有的RabbitMQ broker上的操作所需要的data/state都是全节点复制,唯一的例外是messag...
分类:
其他好文 时间:
2015-10-15 17:55:14
阅读次数:
227
接上一篇oracledataguard概念篇,现在进行下详细的配置,此次配置的是单实例到单实例,也就是说主库和备库都是基于文件系统的单实例。主机环境:RedHatEnterpriseLinuxServerrelease6.3Rdbms版本:11.2.0.3其他详细信息如下所示:需要注意的是,两边的/etc/hosts文件保证都包含..
分类:
数据库 时间:
2015-10-14 21:55:45
阅读次数:
398
在dataguard的配置当中,LOG_ARCHIVE_DEST_n参数的配置比较重要,故做下整理以下是reference中的截图TheLOG_ARCHIVE_DEST_ninitializationparameterdefinesupto31(wheren=1,2,3,...31)destinations,eachofwhichmustspecifyeithertheLOCATIONortheSERVICEattributetospecifywher..
分类:
其他好文 时间:
2015-10-12 19:28:05
阅读次数:
294