Whenever a broker stops or crashes leadership for that broker's partitions transfers to other replicas. This means that by default when the broker is
分类：
其他好文 时间：
2016-02-25 13:41:16
阅读次数：
136
1.Kafka独特设计在什么地方？
2.Kafka如何搭建及创建topic、发送消息、消费消息？
3.如何书写Kafka程序？
4.数据传输的事务定义有哪三种？
5.Kafka判断一个节点是否活着有哪两个条件？
6.producer是否直接将数据发送到broker的leader(主节点)？
7.Kafa consumer是否可以消费指定分区消息？
8.Kafka消息是采用Pull模式...
分类：
其他好文 时间：
2016-02-18 12:04:01
阅读次数：
367
1.准备工作 ■ 创建oracle11g的primary和standby库，物理standby，最大性能模式 ■ DG_BROKER_START设置为TRUE 2.创建broker配置 DGMGRL> CREATE CONFIGURATION 'DRTEST' AS PRIMARY DATABASE
分类：
其他好文 时间：
2016-02-13 11:04:24
阅读次数：
191
使用broker查看dataguard信息时有告警 DGMGRL> show configuration; Configuration - DRTEST Protection Mode: MaxPerformance Databases: ora11gn1 - Primary database or
分类：
其他好文 时间：
2016-02-12 18:43:35
阅读次数：
779
ActiveMQ支持多种通讯协议TCP/UDP等，我们选取最常用的TCP来分析ActiveMQ的通讯机制。首先我们来明确一个概念: 客户(Client)：消息的生产者、消费者对ActiveMQ来说都叫作客户。 消息中介(Message broker)：接收消息并进行相关处理后分发给消息的消费者. 为
分类：
其他好文 时间：
2016-02-02 20:38:23
阅读次数：
186
新建了一个kafka集群，在window下写了一个简单的producer做测试，结果遇到了消息发送失败的问题，代码如下： Properties props = new Properties(); props.put("metadata.broker.list", "192.168.1.107:666...
分类：
其他好文 时间：
2016-01-31 02:45:19
阅读次数：
363
When messages expire on the ActiveMQ broker (they exceed their time-to-live, if set) or can’t be redelivered, they’re moved to a dead-letter queue, so...
分类：
其他好文 时间：
2016-01-19 21:00:11
阅读次数：
247
简单说kafka是一个高吞吐的分部式消息系统kafka的架构? producer：消息生存者? consumer：消息消费者? broker：kafka集群的server，负责处理消息读、写请求，存储消息? topic：消息队列/分类? Queue里面有生产者消费者模型? broker就是代理，在k...
分类：
其他好文 时间：
2016-01-19 20:54:59
阅读次数：
245
server.properties配置如下：broker.id=0num.network.threads=2num.io.threads=8socket.send.buffer.bytes=1048576socket.receive.buffer.bytes=1048576socket.reques...
分类：
其他好文 时间：
2016-01-14 20:56:58
阅读次数：
909
The easiest way to secure the broker is through the use of authentication credentials placed directly in the broker’s XML configuration file. Such fun...
分类：
其他好文 时间：
2016-01-13 12:58:52
阅读次数：
164
