一、kafka架构1.1拓扑结构如下图:图.11.2相关概念如图.1中,kafka相关名词解释如下:1.producer:消息生产者,发布消息到kafka集群的终端或服务。2.broker:kafka集群中包含的服务器。3.topic:每条发布到kafka集群的消息属于的类别,即kafka是面向topic的。4.partition:part..
分类:
其他好文 时间:
2017-06-02 01:01:32
阅读次数:
254
本文转自:http://m.blog.csdn.net/article/details?id=54311277 在生产者通过channel的basicPublish方法发布消息时,通常有几个参数需要设置,为此我们有必要了解清楚这些参数代表的具体含义及其作用,查看Channel接口,会发现存在3个重载 ...
分类:
其他好文 时间:
2017-05-31 18:56:58
阅读次数:
286
Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能,但具有自己独特的设计。这个独特的设计是什么样的呢? 首先让我们看几个基本的消息系统术语: Kafka将消息以topic为单位进行归纳。 将向Kafka topic发布消息的程序成为producers. 将预订t... ...
分类:
其他好文 时间:
2017-05-23 15:48:41
阅读次数:
106
介绍 Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能,但具有自己独特的设计。这个独特的设计是什么样的呢? 首先让我们看几个基本的消息系统术语: Kafka将消息以topic为单位进行归纳。 将向Kafka topic发布消息的程序成为producers. ... ...
分类:
其他好文 时间:
2017-05-12 16:07:15
阅读次数:
186
Topic:标签名,一个消息队列的名称 Producer:生产者,发布消息 Consumer:消费者,订阅发布消息,进行处理的存在 Broker:kafka集群,有一个、多个Topic Partition:分区,采用分区的设计有几个目的。一是可以处理更多的消息,不受单台服务器的限制。Topic拥有多 ...
分类:
其他好文 时间:
2017-05-09 13:43:37
阅读次数:
151
spec 的目标为:为丢失物品的在校学生提供一个专门的平台,寻找丢失的物品。但是功能不包括:(1)不保证每一个发布消息的人都能找到丢失的物品(2)不包括帮助失主找回丢失的物品。 ...
分类:
其他好文 时间:
2017-04-17 20:58:30
阅读次数:
166
在上一篇kafka入门的基础之上,本篇主要介绍Kafka的生产者和消费者。 Kafka 生产者 kafka Producer发布消息记录到Kakfa集群。生产者是线程安全的,在线程之间共享生产者实例。一个简单的例子,使用producer发送一个有序的key/value(键值对),放到java的mai ...
分类:
其他好文 时间:
2017-04-16 16:20:01
阅读次数:
271
原文出处: xingoo 发布订阅中使用到的命令就只有三个:PUBLISH,SUBSCRIBE,PSUBSCRIBE PUBLISH 用于发布消息 SUBSCRIBE 也叫频道订阅,用于订阅某一特定的频道 PSUBSCRIBE 也叫模式订阅,用于订阅某一组频道,使用glob的方式,比如xxx-*可以 ...
分类:
其他好文 时间:
2017-04-14 09:30:22
阅读次数:
279