在kafka中,每一个broker都是一个服务器。按照一般理解,服务器就是一个SocketServer,其不断接收用户的请求并进行处理。在Java中进行网络连接有两种方式一种为阻塞模式一种为非阻塞模式。Jafka采用非阻塞模式进行网络通讯。在Java的非阻塞模式中,建立socket server的一般流程如下:
1.启动ServerSocketChannel并将其绑定到特定的端口。
2.将Se...
分类:
其他好文 时间:
2014-06-28 09:25:54
阅读次数:
235
在Kafka中,LogManager负责管理broker上所有的Log(每一个topic-partition为一个Log)。通过阅读源代码可知其具体完成的功能如下:
1. 按照预设规则对消息队列进行清理。
2. 按照预设规则对消息队列进行持久化(flush操作)。
3. 连接ZooKeeper进行broker、topic、partition相关的ZooKeeper操作。
4. 管理brok...
分类:
其他好文 时间:
2014-06-28 08:25:21
阅读次数:
208
对dataguard 官方文档里面的这句话不理解,是否能给出一个样例说明:10.2.0.5的版本号Effect of Switchovers, Failovers, and Control File Creation on BackupsAll the archived redo log files...
分类:
其他好文 时间:
2014-06-24 13:50:08
阅读次数:
226
1.创建测试数据库
create database ServerbrokerTest
on primary(
name=ServerbrokerTest_data,
filename='C:\Program Files\Microsoft SQL Server\MSSQL11.SQLEXPRESS\MSSQL\DATA\ServerbrokerTest_data.mdf',
size=5...
分类:
数据库 时间:
2014-06-22 22:03:04
阅读次数:
354
1. Consumers and producers Producers create messages and publish (send) them to a broker server (RabbitMQ). A message has two parts: a payload and a l...
分类:
其他好文 时间:
2014-06-21 14:33:14
阅读次数:
431
Dataguard 环境:操作系统:Redhat6.4Primary数据库:IP 地址:192.168.1.122数据库SID:ora11gDB_UNIQUE_NAME:ora11g_primaryStandby数据库:IP 地址:192.168.1.123数据库SID:ora11gDB_UNIQU...
分类:
数据库 时间:
2014-06-18 17:42:54
阅读次数:
338
主库参数详解:保持同一个Data Guard中所有的DB_NAME相同DB_NAME=ora11g为一个数据库指定一个唯一的名称,该参数一经指定就不会发生改动除非DBA主动改动DB_UNIQUE_NAME=ora11g_primary 初始化参数LOG_ARCHIVE_CONFIG用于控制发送归档....
分类:
数据库 时间:
2014-06-18 17:41:38
阅读次数:
304
TSSessionBroker是WindowsServer2008中的新特点,是用于终端服务的MicrosoftNetworkLoadBalancing更简单的一个替代。该特点并不局限于某些服务器,而是为二到五台服务器中心提供了极大价值。通过TSSessionBroker,新会话分布在整个中心任务最少的服务器上,这不但优化性能,同..
分类:
其他好文 时间:
2014-06-17 17:23:07
阅读次数:
499
当某次事务处理对生产数据库中的数据作出更改时,Oracle数据库将在一个联机重做日志文件中记录此次更改。在DataGuard中可以配置写日志的这个过程,除了把日志记录到本地的联机日志文件和归档日志文件中,还可以通过网络,把日志信息发送到远程的从(standby)数据库服务器上。这个备用日志文件写入过程可以是实时、同步的,以实现零数据丢失(最大保护模式maximum protection);也可以是异步的,以减少对网络带宽的压力(最大性能模式maximum performance);或者是异步和同步可以自动切...
分类:
数据库 时间:
2014-06-14 17:57:25
阅读次数:
499
查看topics:ls
/brokers/topics[mytopic]查看topic所在的broker,下面例子,mytopic在broker 0 中管理。ls
/brokers/topics/mytopic[0]查看brocker中,某个topic有多少partition:get /broker...
分类:
其他好文 时间:
2014-06-07 09:34:35
阅读次数:
222