一、概述 Spring Integration Kafka 是基于 Apache Kafka 和Spring Integration来集成Kafka，对开发配置提供了方便。 二、配置 1、spring-kafka-consumer.xml 2、spring-kafka-producer.xml 3、 ...
分类：
编程语言 时间：
2016-05-02 22:44:04
阅读次数：
543
本文转发自Jason’s Blog，原文链接 http://www.jasongj.com/2015/12/31/KafkaColumn5_kafka_benchmark 摘要 本文主要介绍了如何利用Kafka自带的性能测试脚本及Kafka Manager测试Kafka的性能，以及如何使用Kafka ...
分类：
其他好文 时间：
2016-05-02 22:41:43
阅读次数：
289
本文转发自Jason’s Blog，原文链接 http://www.jasongj.com/2015/06/08/KafkaColumn3 摘要 本文在上篇文章基础上，更加深入讲解了Kafka的HA机制，主要阐述了HA相关各种场景，如Broker failover，Controller failov ...
分类：
其他好文 时间：
2016-05-02 21:30:16
阅读次数：
290
本文转发自Jason’s Blog，原文链接 http://www.jasongj.com/2015/04/24/KafkaColumn2 摘要 Kafka在0.8以前的版本中，并不提供High Availablity机制，一旦一个或多个Broker宕机，则宕机期间其上所有Partition都无法继 ...
分类：
其他好文 时间：
2016-05-02 21:24:40
阅读次数：
266
本文转发自Jason’s Blog，原文链接 http://www.jasongj.com/2015/01/02/Kafka深度解析 背景介绍 Kafka简介 Kafka是一种分布式的，基于发布/订阅的消息系统。主要设计目标如下： 以时间复杂度为O(1)的方式提供消息持久化能力，即使对TB级以上数据 ...
分类：
其他好文 时间：
2016-05-02 20:05:14
阅读次数：
382
本文转发自Jason’s Blog，原文链接 http://www.jasongj.com/2015/03/10/KafkaColumn1 摘要 Kafka是由LinkedIn开发并开源的分布式消息系统，因其分布式及高吞吐率 而被广泛使用，现已与Cloudera Hadoop，Apache Stor ...
分类：
其他好文 时间：
2016-05-02 20:05:04
阅读次数：
348
一、Kafka概述 Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据。 这种动作（网页浏览，搜索和其他用户的行动）是在现代网络上的许多社会功能的一个关键因素。 这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。 对于像Hadoop的一样的日志 ...
分类：
其他好文 时间：
2016-05-02 16:51:21
阅读次数：
254
Producer端 1、channel的创建 无论是才用什么样的Exchange，创建channel代码都是相同的，如下 2、Exchange的创建 2.1 direct direct使用默认的Exchange，不需要声明，单需要指定消息发送到那个队列 2.2 fanout 2.3 topic如下 ...
分类：
编程语言 时间：
2016-04-30 15:30:59
阅读次数：
234
日志收集之kafka http://www.jianshu.com/p/f78b773ddde5 一、介绍 Kafka是一种分布式的，基于发布/订阅的消息系统。主要设计目标如下： 以时间复杂度为O(1)的方式提供消息持久化能力，即使对TB级以上数据也能保证常数时间复杂度的访问性能 高吞吐率。即使在非 ...
分类：
其他好文 时间：
2016-04-30 01:04:45
阅读次数：
387
Zookeeper算是现在互联网公司中软件开发中最常接触的“软件”之一了。它的设计目标就是将那些复杂且容易出错的分布式一致性服务封装起来，然后构成一个高效可靠的原语集，然后提供一系列简单易用的接口给用户。其实比如一些RPC框架、Kafka等消息队列机制，内部都是依赖了Zookeeper来进行分布式调 ...
分类：
其他好文 时间：
2016-04-30 01:04:30
阅读次数：
192
