Kafka Producer相关代码分析
标签(空格分隔): kafka
Kafka Producer将用户的消息发送到Kafka集群(准确讲是发送到Broker)。本文将分析Producer相关的代码实现。
类kafka.producer.Producer
如果你自己实现Kafka客户端来发送消息的话,你就是用到这个类提供的接口来发送消息。(如果你对如何利用Producer AP...
分类:
其他好文 时间:
2015-01-17 20:53:34
阅读次数:
233
2014-02-03 Created By BaoXinjianOracle 双机/RAC/Dataguard的区别 Data Guard 是Oracle的远程复制技术,它有物理和逻辑之分,但是总的来说,它需要在异地有一套独立的系统,这是两套硬件配置可以不同的系统,但是这两套系统的软件结构保持一致,...
分类:
数据库 时间:
2015-01-15 23:32:50
阅读次数:
433
Kafka的通讯协议
标签:kafka
Kafka的Producer、Broker和Consumer之间采用的是一套自行设计的基于TCP层的协议。Kafka的这套协议完全是为了Kafka自身的业务需求而定制的,而非要实现一套类似于Protocol Buffer的通用协议。本文将介绍这套协议的相关内容。
基本数据类型
定长数据类型:int8,int16,int32和int64,对...
分类:
其他好文 时间:
2015-01-15 20:23:45
阅读次数:
260
2014-06-03 Created By BaoXinjian一、摘要Oracle DataGuard是Oracle自带的数据同步功能,基本原理是将日志文件从原数据库传输到目标数据库,然后在目标数据库上应用这些日志文件,从而使目标数据库与源数据库保持同步,是一种数据库级别的高可用性方案。DataG...
分类:
数据库 时间:
2015-01-15 19:57:49
阅读次数:
292
2014-09-09 Created By BaoXinjian一、摘要二、Thanks and Regardshttp://blog.csdn.net/giianhui/article/details/7199682http://blog.csdn.net/l106439814/article/d...
分类:
数据库 时间:
2015-01-15 19:46:15
阅读次数:
169
Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能,但具有自己独特的设计
Kafka将消息以topic为单位进行归纳。将向Kafka topic发布消息的程序成为producers.将预订topics并消费消息的程序成为consumer.Kafka以集群的方式运行,可以由一个或多个服务组成,每个服务叫做一个broker.
下面来看下如何简单的使用:
...
分类:
其他好文 时间:
2015-01-14 11:06:44
阅读次数:
150
如果你要利用代码来跑kafka的应用,那你最好先把官网给出的example先在单机环境和分布式环境下跑通,然后再逐步将原有的consumer、producer和broker替换成自己写的代码。所以在阅读这篇文章前你需要具备以下前提:1.简单了解kafka功能,理解kafka的分布式原理2.能在分布式...
分类:
其他好文 时间:
2015-01-08 17:16:27
阅读次数:
191
这部分内容对了解系统和提高软件性能都有很大的帮助,kafka官网上也给出了比较详细的配置详单,但是我们还是直接从代码来看broker到底有哪些配置需要我们去了解的,配置都有英文注释,所以每一部分是干什么的就不翻译了,都能看懂:?123456789101112131415161718192021222...
分类:
其他好文 时间:
2015-01-08 16:53:32
阅读次数:
157
Oracle 11g在创建data guard时,恢复standby控制文件不成功。在mount standby database时告诉我,控制文件不是standby控制文件,具体信息为“ORA-01665: control file is not a standby control file”。
控制文件我在主库中,使用rman生成的。
backup current controlf...
分类:
数据库 时间:
2015-01-07 13:15:22
阅读次数:
283
MQ全称为Message Queue,消息队列(MQ)是一种应用程序对应用程序的通信方法RabbitMQ是流行的开源消息队列系统,用erlang语言开发几个概念说明:Broker:简单来说就是消息队列服务器实体。 Exchange:消息交换机,它指定消息按什么规则,路由到哪个队列。 Queu...
分类:
其他好文 时间:
2015-01-04 16:35:20
阅读次数:
295